前言

上一篇我们分享了 FastAPI 学习之路（五十）WebSockets(七)实现一对一聊天 ，那么我们今天来实现呢，websockets接受和发送json格式消息。

正文

相对于之前的text的消息来说，我们之前发送的消息都是text的居多，那么对于text格式的消息来说，我们处理起来，尤其是后端要麻烦的多，那么我们可不可以传递json格式的，对于前后端来说都好处理的一种格式的消息，那么答案来说是可以的。我们需要做下处理。

我们在之前的websockets管理中的的消息的处理全部改造成json格式的。我们看下如何处理呢 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}) def disconnect(self, user: str, ws: WebSocket): # 关闭时 移除ws对象 self.active_connections.remove({"user": user, "ws": ws}) async def send_other_message_json(self, message: dict, user: str): # 发送个人消息 for connection in self.active_connections: if connection["user"] == user: await connection['ws'].send_json(message) async def broadcast_json(self, data: dict): # 广播消息 for connection in self.active_connections: await connection['ws'].send_json(data) 复制