FastAPI 学习之路(五十二)WebSockets(八)接受/发送json格式消息
创始人
2024-12-27 03:05:39
0

前面我们发送的大多数都是text类型的消息,对于text消息来说,后端处理出来要麻烦的多,那么我们可以不可以传递json格式的数据,对于前后端来说都比较友好,答案是肯定的,我们需要做下处理。

首先,我们在websocket管理器中增加处理json格式消息的方法:

from typing import List, Dict  from starlette.websockets import WebSocket   class ConnectionManager:      def __init__(self):         """存放链接"""         self.active_connections: List[Dict[str, WebSocket]] = []      async def connect(self, user: str, ws: WebSocket):         """链接"""         await ws.accept()         self.active_connections.append({"user": user, "ws": ws})      async def disconnect(self, user: str, ws: WebSocket):         """断开链接,移除"""         self.active_connections.remove({"user": user, "ws": ws})      @staticmethod     async def send_personal_message(message: str, ws: WebSocket):         """发送所有人消息"""         await ws.send_text(message)      async def send_other_message(self, message: dict, user: str):         """发送个人消息"""         for coon in self.active_connections:             if coon["user"] == user:                 await coon["ws"].send_json(message)      async def broadcast(self, data: str):         """广播"""         for conn in self.active_connections:             await conn["ws"].send_text(data)      async def broadcast_json(self, data: dict):         """广播json数据"""         for conn in self.active_connections:             await conn["ws"].send_json(data)

接口中如何接收json数据呢,新增接口如下:

@app.websocket("/ws/json/{user}") async def websocket_json_data(         websocket: WebSocket,         user: str,         cookie_or_token: str = Depends(get_cookie_or_token) ):     """发送接收json数据(前面一对一接口其实就是发送的json数据)"""     await ws_manager.connect(user, websocket)     try:         while True:             data = await websocket.receive_json()             send_user = data["username"]             if send_user:                 await ws_manager.send_other_message(data, send_user)             else:                 await ws_manager.broadcast_json(data)     except WebSocketDisconnect as e:         await ws_manager.disconnect(user, websocket) 

前端也要相对应的修改:
 

       Chat   

WebSocket 聊天

部署看效果,因为发送给后端的数据格式是前端拼的json,所以页面上只需要填文本即可:

 

相关内容

热门资讯

玩家必看分享!德州之星辅助软件... 玩家必看分享!德州之星辅助软件介绍,微扑克机器人,攻略教程(有挂辅助)-哔哩哔哩;小薇(透视辅助)致...
2分钟理解!wepoker可以... 2分钟理解!wepoker可以开透视吗,wpk俱乐部是做什么的(透视)黑科技教程(发现有挂)1.wp...
黑科技ai!(线上德州aapo... 黑科技ai!(线上德州aapoker)外挂软件透明挂辅助脚本!(德州之星有外挂)攻略教程(2020已...
科普!红龙扑克透牌辅助器,aa... 科普!红龙扑克透牌辅助器,aapoker发牌机制,AI教程(确实有挂)-哔哩哔哩;红龙扑克透牌辅助器...
九分钟普及!德普之星透视辅助,... 九分钟普及!德普之星透视辅助,wpk真吗(透视)解密教程(详细教程)1、德普之星透视辅助透视辅助简单...
复盘辅助挂!(线上德州ai机器... 复盘辅助挂!(线上德州ai机器人)外挂辅助黑科技!(德扑之星ai代打可以弄)wpk教程(2026已更...
第2分钟了解!wepoker透... 第2分钟了解!wepoker透视挂底牌,佛手在线大菠萝辅助(透视)AI教程(存在有挂)1、下载好佛手...
揭秘!(wpk后台)外挂透明挂... 揭秘!(wpk后台)外挂透明挂辅助安装插件!(微扑克有后台控制)安装教程(2026已更新)(哔哩哔哩...
大家学习交流!德扑输赢概率计算... 大家学习交流!德扑输赢概率计算器,红龙扑克发牌有问题,AA德州教程(真是有挂)-哔哩哔哩;详细红龙扑...
十分钟理解!智星菠萝辅助,we... 十分钟理解!智星菠萝辅助,werplan怎么透视(透视)教你教程(果真有挂)1、超多福利:超高返利,...