当前位置：首页 > article >正文

【Django】在view中调用channel来主动进行websocket通信

article 2025/1/26 14:21:07

前提：consumer中已经写好了建立连接的代码，并且能够成功把连接加入到通道层的组内

可以参考我的另一个博客：

LuckySheet协同编辑后端示例(Django+Channel,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()

查看全文

http://www.kler.cn/a/428322.html