diff --git a/chat.py b/chat.py index 006a2590da254fba5652abdd1d2913ace0e21b5b..086bc162f3a10f7714d295ee8d7900601a2c588f 100644 --- a/chat.py +++ b/chat.py @@ -53,7 +53,7 @@ async def echo(websocket): h = 0; r = {'type':'history_num','content':str(h)} message = json.dumps(r,ensure_ascii=False) - await websocket.send(message) + websockets.broadcast(users[room_id], message) #历史记录 if "history" in event["type"]: start = int(event['page']) @@ -66,7 +66,7 @@ async def echo(websocket): h = [] r = {'type':'history','content':h} message = json.dumps(r,ensure_ascii=False) - await websocket.send(message) + websockets.broadcast(users[room_id], message) #聊天 if "chat" in event['type']: chat = {