定制网站建设制作,怎么自学网站建设,四川住房和城乡建设厅网站咨询电话,亚马逊网站建设案例前提#xff1a;consumer中已经写好了建立连接的代码#xff0c;并且能够成功把连接加入到通道层的组内
可以参考我的另一个博客#xff1a;
LuckySheet协同编辑后端示例(DjangoChannel,Websocket通信)_lucksheet 协同编辑-CSDN博客
我是懒得去折腾luckysheet的源码…前提consumer中已经写好了建立连接的代码并且能够成功把连接加入到通道层的组内
可以参考我的另一个博客
LuckySheet协同编辑后端示例(DjangoChannel,Websocket通信)_lucksheet 协同编辑-CSDN博客
我是懒得去折腾luckysheet的源码所以尽量去把功能在后端实现但是又需要一些功能来通过点击按钮实现把消息广播出去所以就在视图函数里进行消息广播同理在别的任意类型的函数中也可以使用。具体代码如下
from channels.layers import get_channel_layer
import asyncio def send_message(self):# 获取通道层实例channel_layer get_channel_layer()async def send_group_message():await channel_layer.group_send(group_name, # 替换为实际的组名要和消费者加入的组名对应{type: broadcast_message, # 替换为消费者中处理该消息的对应方法名message: Message from the view})# 运行异步函数来执行消息发送操作loop asyncio.new_event_loop()asyncio.set_event_loop(loop)try:loop.run_until_complete(send_group_message())finally:loop.close()
