Django 频道：消息在一个频道中重复

Posted 2023-02-16

【中文标题】Django 频道：消息在一个频道中重复

【英文标题】：Django channels: messages are duplicated in a one channel

【发布时间】：2021-04-21 17:55:01

【问题描述】：

我正在阅读官方 Django Channels 教程，遇到了和这个人一样的问题： Django Channels group send only sends the message to last channel

所以，我有一堆标准文件：

# asgi.py
import os
from channels.auth import AuthMiddlewareStack
from channels.routing import ProtocolTypeRouter, URLRouter
from django.core.asgi import get_asgi_application
import chat.routing

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'mysite.settings')

application = ProtocolTypeRouter(
    "http": get_asgi_application(),
    "websocket": AuthMiddlewareStack(
        URLRouter(
            chat.routing.websocket_urlpatterns
        )
    ),
)

# routing.py
from django.urls import re_path
from . import consumers
websocket_urlpatterns = [
    re_path(r'ws/chat/(?P<room_name>\w+)/$', consumers.ChatConsumer.as_asgi()),
]


# consumers.py
import json
from channels.generic.websocket import AsyncWebsocketConsumer

class ChatConsumer(AsyncWebsocketConsumer):
async def connect(self):
    self.room_name = self.scope['url_route']['kwargs']['room_name']
    self.room_group_name = 'chat_%s' % self.room_name
    await self.channel_layer.group_add(
        self.room_group_name,
        self.channel_name
    )
    await self.accept()

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

async def receive(self, text_data):
    print('def receive from websocket')
    text_data_json = json.loads(text_data)
    message = text_data_json['message']
    await self.channel_layer.group_send(
        self.room_group_name,
        
            'type': 'chat_message',
            'message': message
        
    )

async def chat_message(self, event):
    message = event['message']
    await self.send(text_data=json.dumps(
        'message': message
    ))

以及settings.py的一部分

ASGI_APPLICATION = 'mysite.asgi.application'
CHANNEL_LAYERS = 
    'default': 
        'BACKEND': 'channels_redis.core.RedisChannelLayer',
        'CONFIG': 
            "hosts": [('127.0.0.1', 6379)],
        ,
    ,

这是一个简单的聊天室。我在同一个浏览器中打开两个选项卡，在第一个选项卡中输入“Hello”，然后在第二个选项卡中获得两个“Hello”，第一个选项卡中的“Hello”为零。

更新！！！ 我做了一些实验，我认为消费者功能正常工作（我在发送消息期间记录了 channel_name 参数，在 def receive() 中我可以准确地看到我发送消息的那个 channel_name，同时在 def chat_message( ）我可以看到所有频道）。那么，问题应该出在js上？

<textarea id="chat-log" cols="100" rows="20"></textarea><br>
    <input id="chat-message-input" type="text" size="100"><br>
    <input id="chat-message-submit" type="button" value="Send">
     room_name|json_script:"room-name" 
    <script>
        const roomName = JSON.parse(document.getElementById('room-name').textContent);

        const chatSocket = new WebSocket(
            'ws://'
            + window.location.host
            + '/ws/chat/'
            + roomName
            + '/'
        );

        chatSocket.onmessage = function(e) 
            const data = JSON.parse(e.data);
            document.querySelector('#chat-log').value += (data.message + '\n');
        ;

        chatSocket.onclose = function(e) 
            console.error('Chat socket closed unexpectedly');
        ;

        document.querySelector('#chat-message-input').focus();
        document.querySelector('#chat-message-input').onkeyup = function(e) 
            if (e.keyCode === 13)   // enter, return
                document.querySelector('#chat-message-submit').click();
            
        ;

        document.querySelector('#chat-message-submit').onclick = function(e) 
            const messageInputDom = document.querySelector('#chat-message-input');
            const message = messageInputDom.value;
            chatSocket.send(JSON.stringify(
                'message': message
            ));
            messageInputDom.value = '';
        ;
    </script>

【参考方案1】：

问题解决了。在我的情况下，它与 django 环境一起使用。我使用了常见的，我也用于其他项目。问题的原因可能是某些安装之间存在冲突。我创建了一个新环境，安装了 django 和频道，现在一切正常。

【参考方案2】：

我也遇到过这个问题。我认为这是 channels=3.0.0 中的一个错误

我升级到了 channels=3.0.4，现在可以使用了！