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,所以页面上只需要填文本即可:

 

相关内容

热门资讯

透视能赢"wepok... 透视能赢"wepoker私人局俱乐部辅助(底牌透视脚本)wepoker软件靠谱么"都是有挂;wepo...
透视ai!wpk俱乐部是真的吗... 透视ai!wpk俱乐部是真的吗,(wPk真的有挂)辅助器(本来有挂)1、wpk俱乐部是真的吗系统规律...
透视系统!wepoker手机版... 透视系统!wepoker手机版透视脚本,(WePoKer方法)都是是真的有挂(详细黑侠破解)亲,关键...
透视挂透视!wpk俱乐部辅助器... 透视挂透视!wpk俱乐部辅助器,(WPk插件)插件辅助(一直是有挂)1、wpk俱乐部辅助器ai机器人...
透视新版"wepok... 透视新版"wepoker透视脚本免费使用视频(底牌透视脚本)we-poker有人玩吗"其实存在有挂;...
透视脚本!aapoker透视脚... 透视脚本!aapoker透视脚本,aapoker辅助软件合法吗,技巧教程(好像是有挂)1、aapok...
透视软件!淘宝买wepoker... 透视软件!淘宝买wepoker透视有用吗,wepoker私人局透视教程(透视果然是有挂);1)淘宝买...
透视辅助!wpk俱乐部是做什么... 透视辅助!wpk俱乐部是做什么的,(wpK透视)其实有挂(详细辅助);1、下载好wpk俱乐部是做什么...
透视ai代打!wepoker作... 透视ai代打!wepoker作弊辅助(WePoKer辅助器)破解辅助插件(真是存在有挂)1、不需要A...
透视脚本!aapoker ai... 透视脚本!aapoker ai插件,aapoker怎么提高中牌率,黑科技教程(都是真的有挂)1、实时...