diff --git a/app/utils/websocket_tool.py b/app/utils/websocket_tool.py index 13db4a2..ec90fb7 100644 --- a/app/utils/websocket_tool.py +++ b/app/utils/websocket_tool.py @@ -29,7 +29,7 @@ class WebsocketUtil: # 等待连接 msg = ws.receive() # 存储ws连接对象 - active_connections_dist = Queue.get() + active_connections_dist = self.queue.get() if id in active_connections_dist: active_connections_dist[id].append(ws) else: