Django websockets 和通道 group_send 不起作用

Question

我开始研究 websockets，并且希望实现 Web 客户端（Angular 13）和 Python 应用程序之间的实时通信。作为后端，我使用了带有实现的 websockets 和通道的 Django

因为我遇到了问题，所以我尽可能地简化了代码，所以很多值都被硬编码以使其工作。 （现在是一个 WebClient 和一个 Bot）

我实现了 2 个消费者。 Bot 和 webclient：

class BotConsumer(AsyncJsonWebsocketConsumer):
async def connect(self):
    await self.accept()
    await self.channel_layer.group_add("bot","dev")

async def disconnect(self, close_code):
    await self.channel_layer.group_discard("bot","dev")

async def receive(self, text_data):
    await self.channel_layer.group_send("dev",{"type": "recv","text": "test"})
    print("Data sent to group")

class WebClientConsumer(AsyncJsonWebsocketConsumer):
async def connect(self):
    await self.accept()
    await self.channel_layer.group_add("client","dev")

async def recv(self,event):
    print("Consumer received smthing from channels")
    
async def disconnect(self, close_code):
    await self.channel_layer.group_discard("client","dev")

async def receive(self, text_data):
    print("Smthing received")

我在Setting.py 中设置的channel_layer

CHANNEL_LAYERS = {
'default': {
    # 'BACKEND': 'channels_redis.core.RedisChannelLayer',
    # 'CONFIG': {
    #      "hosts": [('192.168.1.10', 6379)],
    # },
    "BACKEND": "channels.layers.InMemoryChannelLayer"
}}

我尝试了本地服务器运行的Redis 和内存通道

我的websocket 的routing.py：

from django.urls import re_path
from . import consumers

websocket_urlpatterns = [
    re_path(r'live/bot', consumers.BotConsumer.as_asgi()),
    re_path(r'live/webclient', consumers.WebClientConsumer.as_asgi()),  
]

我的行为：

Django 日志：

HTTP POST /core/UpdateAvailableServers 200 [0.07, 127.0.0.1:50494]
HTTP POST /core/GetPostInfo 200 [0.02, 127.0.0.1:50497]
**WebSocket HANDSHAKING /live/bot [127.0.0.1:50498]**
**WebSocket CONNECT /live/bot [127.0.0.1:50498]**
HTTP POST /core/GetStatus 200 [0.00, 127.0.0.1:50501]
HTTP POST /core/GetPostInfo 200 [0.02, 127.0.0.1:50504]
HTTP POST /core/GetBots 200 [0.00, 127.0.0.1:50524]
**WebSocket HANDSHAKING /live/webclient [127.0.0.1:50527]**
**WebSocket CONNECT /live/webclient [127.0.0.1:50527]**
HTTP POST /core/GetStatus 200 [0.01, 127.0.0.1:50528]
HTTP POST /core/UpdateAvailableServers 200 [0.02, 127.0.0.1:50531]
HTTP POST /core/GetPostInfo 200 [0.02, 127.0.0.1:50534]
HTTP POST /core/GetStatus 200 [0.00, 127.0.0.1:50537]
HTTP POST /core/GetPostInfo 200 [0.02, 127.0.0.1:50540]
HTTP POST /core/UpdateAvailableServers 200 [0.06, 127.0.0.1:50544]
HTTP POST /core/GetStatus 200 [0.00, 127.0.0.1:50547]
HTTP POST /core/GetPostInfo 200 [0.02, 127.0.0.1:50550]
**Data sent to group**
HTTP POST /core/GetPostInfo 200 [0.00, 127.0.0.1:50554]
HTTP POST /core/GetStatus 200 [0.00, 127.0.0.1:50557]
HTTP POST /core/UpdateAvailableServers 200 [0.06, 127.0.0.1:50560]
HTTP POST /core/GetPostInfo 200 [0.02, 127.0.0.1:50563]

正如您在日志中看到的那样，我从我的 python 应用程序（BOT）和 Angular 应用程序（WebClient）成功获得了 websocket 连接，两者都被添加到 connect 函数的组中。

然后，机器人应用程序将使用 websockets 发送一些数据，并且它们应该发送到整个组，我将得到确认，如日志中所示。

问题是我的网络客户端将完全忽略这一点。 recv 方法永远不会执行，WebClient 使用者也不会显示此操作的任何活动。

我犯了一些明显的错误吗？ （如果需要，我可以提供任何其他信息）

Answer 1

您不应该创建自定义频道。相反，将自定义组分配给通道。

await self.channel_layer.group_add("bot",self.channel_name)

另外，将套接字消息发送到同一通道中的客户端组。

await self.channel_layer.group_send("client",{
            "type":"recv",
            "message":text_data
        })

请参阅下面更正后的实现。

class BotConsumer(AsyncJsonWebsocketConsumer):
    async def connect(self):
        await self.accept()
        await self.channel_layer.group_add("bot",self.channel_name)
        

    async def disconnect(self, close_code):
        await self.channel_layer.group_discard("bot",self.channel_name)

    async def receive(self, text_data):
        
        await self.channel_layer.group_send("client",{
            "type":"recv",
            "message":text_data
        })

        print("Data sent to group")

class WebClientConsumer(AsyncJsonWebsocketConsumer):
    async def connect(self):
        await self.accept()
        await self.channel_layer.group_add("client",self.channel_name)

    async def recv(self,event):
        print("Consumer received smthing from channels")
        
    async def disconnect(self, close_code):
        await self.channel_layer.group_discard("client",self.channel_name)

    async def receive(self, text_data):
        print("Smthing received")