有了上一遍的基础,其实这个一对一很简单,我们在之前的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)
来源:https://www.cnblogs.com/leiziv5/p/15416901.html
图文来源于网络,如有侵权请联系删除。