FastAPI 学习之路(五十一)WebSockets(七)实现一对一聊天
有了上一遍的基础,其实这个一对一很简单,我们在之前的websockets管理中已经实现了一对一发消息的内容,这次呢,我们只需要实现一对一如何处理消息即可。
@app.websocket("/ws/{user}/")
async def websocket_many_point(
websocket: WebSocket,
user:str,
cookie_or_token: str = Depends(get_cookie_or_token),
):
await manager.connect(user, websocket)
try:
while True:
data = await websocket.receive_text()
await manager.send_other_message(message=data.split("?")[0],user=data.split("?")[1])
except WebSocketDisconnect as e:
manager.disconnect(user, websocket)


