xkrs_manan/RODY
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

全局变量

Browse Source
This commit is contained in:
JIAKUNHAO 2022-11-24 11:19:34 +08:00
parent b31867f12a
commit 12df135953
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
app/utils/websocket_tool.py
View File

@ -43,9 +43,9 @@ class WebsocketUtil:
# ws关闭时 移除ws对象 # ws关闭时 移除ws对象
if ws.closed: if ws.closed:
if ws in active_connections_dist.values(): if ws in active_connections_dist.values():
global active_connections # global active_connections
active_connections.remove(ws) active_connections.remove(ws)
global active_connections_dist # global active_connections_dist
active_connections_dist[id].pop(ws) active_connections_dist[id].pop(ws)
@staticmethod @staticmethod
@ -55,13 +55,13 @@ class WebsocketUtil:
def broadcast(self, message: str): def broadcast(self, message: str):
# 广播消息 # 广播消息
global active_connections # global active_connections
for connection in active_connections: for connection in active_connections:
connection.send(message) connection.send(message)
def send_message_proj_json(self, message: Union[str, int, List, Dict], id: str): def send_message_proj_json(self, message: Union[str, int, List, Dict], id: str):
# 广播该项目的消息 # 广播该项目的消息
global active_connections_dist # global active_connections_dist
for connection in active_connections_dist[id]: for connection in active_connections_dist[id]:
try: try:
connection.send(json.dumps(message, cls=MyEncoder, indent=4), ) connection.send(json.dumps(message, cls=MyEncoder, indent=4), )