Django Channels 组发送仅将消息发送到最后一个通道

问题描述 投票：0回答：2

我正在开发 django Channels-3.0.3，

group_send
只将我的消息发送到最后连接的通道给连接的用户次。

设置

...
INSTALLED_APPS = [
    "django.contrib.admin",
    "django.contrib.auth",
    "django.contrib.contenttypes",
    "django.contrib.sessions",
    "django.contrib.messages",
    "django.contrib.staticfiles",
    "chat",
    "channels",
]

ASGI_APPLICATION = "cfehome.routing.application"

CHANNEL_LAYERS = {
    "default": {
        "BACKEND": "channels_redis.core.RedisChannelLayer",
        "CONFIG": {
            "hosts": [("127.0.0.1", 6379)],
        },
    },
}

聊天/consumers.py

import asyncio
import json
from django.contrib.auth import get_user_model
from channels.consumer import AsyncConsumer
from channels.db import database_sync_to_async

from .models import Thread, ChatMessage


class ChatConsumer(AsyncConsumer):
    @database_sync_to_async
    def get_thread(self, user, other_username):
        return Thread.objects.get_or_new(user, other_username)[0]

    async def websocket_connect(self, event):
        other_user = self.scope['url_route']['kwargs']['username']
        me = self.scope['user']
        # print("connect!")
        # print(me, other_user)
        thread_obj = await self.get_thread(me, other_user)
        # print(me, thread_obj)
        chat_room = f"thread_{thread_obj.id}"
        self.chat_room = chat_room
        await self.channel_layer.group_add(
            chat_room,
            self.channel_name
        )
        print(f"{self.channel_name}, {self.chat_room}, {me} - connected!")
        await self.send({
            "type": "websocket.accept"
        })

    async def websocket_receive(self, event):
        print("msg recevied!", event)
        front_text = event.get("text", None)
        if front_text is not None:
            loaded_dic_Data = json.loads(front_text)
            msg = loaded_dic_Data.get("message")
            # print(msg)
            user = self.scope['user']
            username = "default"
            if user.is_authenticated:
                username = user.username
            myResponse = {
                "message": msg,
                "username": username
            }

            # brodcast msg to chatroom
            await self.channel_layer.group_send(
                self.chat_room,
                {
                    "type": "chat_message",
                    "text": json.dumps(myResponse),
                }
            )

    #  sends the actual msg
    async def chat_message(self, event):
        await self.send({
            "type": "websocket.send",
            "text": event["text"]

        })

    async def websocket_disconnect(self, event):
        print("disconnect!")
        await self.channel_layer.group_discard(
            self.chat_room,
            self.channel_name
        )

在consumers.py中我也尝试了

async_to_sync
设置了
async
和
await

chat/templates/chat/threads.html（我的渲染模板）

{% extends "base.html" %}

{% block content %}
<h3>Thread for {% if user != object.first %}{{ object.first }}{% else %}{{ object.second }}{% endif %}</h3>
<ul id='chat-items'>
{% for chat in object.chatmessage_set.all %}

<li>{{ chat.message }} via {{ chat.user }}</li>

{% endfor %}
</ul>

<form id='form' method='POST'> {% csrf_token %}
    <input type="hidden" id="myUsername" value="{{ user.username }}">
{{form.as_p }}
<input type='submit' class='btn btn-primary'/>
</form>

{% endblock %}

{% block script %}

<script>
// websocket scripts
var loc = window.location;

var formData = $("#form")
var msg = $("#id_message")
var chatHoler = $("#chat-items")
var me = $("#myUsername").val()

var wsStart = "ws://";
if(loc.protocol == "https:"){
    wsStart = "wss://"
};
var endpoint =  wsStart + loc.host + loc.pathname;
var socket = new WebSocket(endpoint);

console.log(endpoint)

socket.onmessage = function(e){
    console.log("message ",e)
    var chatDataMsg = JSON.parse(e.data)
    chatHoler.append("<li>" + chatDataMsg.message + "  -  " + chatDataMsg.username + "</li>")
};
socket.onopen = function(e){
    console.log("open ",e)
    formData.submit(function(event){
        event.preventDefault()
        var msgText = msg.val()
        // chatHoler.append("<li>" + msgText + " via " + me +"</li>")

        var finalData = {
            "message": msgText,
        }
        socket.send(JSON.stringify(finalData))
        formData[0].reset()
    });
};
socket.onerror = function(e){
    console.log("error ",e)
};
socket.onclose = function(e){
    console.log("close ",e)
};

</script>
{% endblock %}

它从某个频道接收消息，并将消息发送回该频道，以达到 chat_room 中已连接频道的数量。

〜提前致谢..这是我在现场的第一个问题:)

更新了！这是我的routing.py文件

from django.conf.urls import url
from channels.routing import ProtocolTypeRouter, URLRouter
from channels.auth import AuthMiddlewareStack
from channels.security.websocket import AllowedHostsOriginValidator, OriginValidator

from chat.consumers import ChatConsumer

application = ProtocolTypeRouter({
    "websocket": AllowedHostsOriginValidator(
        AuthMiddlewareStack(
            URLRouter(
                [
                    url(r"^messages/(?P<username>[\w.@+-]+)/$", ChatConsumer()),
                ]
            )
        )
    )
})
python django django-channels
2个回答
1
投票

试试这个：

  1. 从 
    get_asgi_application
    导入 
    django.core.asgi
    。
  2. 允许 Django 的 ASGI 应用程序通过添加 
    http
    作为键和 
    http
    作为 
    get_asgi_application()
    内部字典中键的值来处理传统 
    ProtocolTypeRouter
    请求。
  3. 在路由 
    as_asgi()
    消费者时使用/调用 
    ChatConsumer
    类方法。

路由.py

from django.conf.urls import url
from django.core.asgi import get_asgi_application #Change No.1

from channels.routing import ProtocolTypeRouter, URLRouter
from channels.auth import AuthMiddlewareStack
from channels.security.websocket import AllowedHostsOriginValidator, OriginValidator

from chat.consumers import ChatConsumer

application = ProtocolTypeRouter({
    "http": get_asgi_application(), #Change No.2
    "websocket": AllowedHostsOriginValidator(
        AuthMiddlewareStack(
            URLRouter([
                url(r"^messages/(?P<username>[\w.@+-]+)/$", ChatConsumer.as_asgi()), #Change No.3
           ])
        )
    )
})

有关 channels.readthedocs.io 的更多信息。

0
投票

我面临着同样的问题，我已经实现了上述答案，但问题仍然存在......你能帮忙吗

最新问题
© www.soinside.com 2019 - 2024. All rights reserved.