功能变化:

优化websocket
pull/93/head
猿小天 2023-04-08 14:48:35 +08:00
parent d1dc5c04c0
commit 6ac3c15832
1 changed files with 0 additions and 10 deletions

View File

@ -112,22 +112,12 @@ class MegCenter(DvadminWebSocket):
async def push_message(self, event): async def push_message(self, event):
"""消息发送""" """消息发送"""
message = event['json'] message = event['json']
print("进入消息发送",event)
await self.send(text_data=json.dumps(message)) await self.send(text_data=json.dumps(message))
def websocket_push(room_name,message): def websocket_push(room_name,message):
channel_layer = get_channel_layer() channel_layer = get_channel_layer()
print(channel_layer.__dict__)
# async_to_sync(channel_layer.group_send)(
# "dvadmin",
# {
# "type": "push.message",
# "json": message
# }
# )
print("进入推送了")
async_to_sync(channel_layer.group_send)( async_to_sync(channel_layer.group_send)(
room_name, room_name,
{ {