From 7f0e578aa3dc4f753707eb0522f59fe995171122 Mon Sep 17 00:00:00 2001 From: JIAKUNHAO Date: Thu, 24 Nov 2022 15:30:06 +0800 Subject: [PATCH] ws --- app/utils/websocket_tool.py | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/app/utils/websocket_tool.py b/app/utils/websocket_tool.py index 3ae8a1e..cd313af 100644 --- a/app/utils/websocket_tool.py +++ b/app/utils/websocket_tool.py @@ -41,12 +41,11 @@ class WebsocketUtil: def disconnect(self, ws, id): # ws关闭时 移除ws对象 if ws.closed: - active_connections_dist = Queue.get() + active_connections_dist = self.queue.get() if active_connections_dist is not None: if ws in active_connections_dist.values(): active_connections_dist[id].pop(ws) - redis_client.get_redis().set("active_connections", json.dumps(active_connections)) - + self.queue.put(active_connections_dist) @staticmethod async def send_personal_message(message: str, ws): @@ -65,7 +64,7 @@ class WebsocketUtil: def send_message_proj_json(self, message: Union[str, int, List, Dict], id: str): # 广播该项目的消息 # global active_connections_dist - print(self.queue.qsize) + print(self.queue.qsize()) active_connections_dist = self.queue.get() self.queue.put(active_connections_dist) print(active_connections_dist)