python - Django Channels group send 仅将消息发送到最后一个通道
问题描述
我正在使用 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 %}
它从一个频道接收消息并将该消息发送回该频道到聊天室中连接的频道数。
〜提前谢谢..这是我在现场的第一个问题:)
更新!这是我的 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()),
]
)
)
)
})
解决方案
尝试这个:
get_asgi_application
从导入django.core.asgi
。- 允许 Django 的 ASGI 应用程序通过在字典里面添加as key &作为 key 的值来处理传统
http
请求。http
get_asgi_application()
ProtocolTypeRouter
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
])
)
)
})
推荐阅读
- android - 收到通知时,react-native-notifications 使应用程序崩溃
- javascript - 关于如何在 javascript 中组合这两个函数的提示?
- javascript - 是什么导致我的 tsx 在反应应用程序中没有 babel 的情况下正确渲染?
- mysql - 如何在 lambda nodejs 中连接 mysql
- javascript - 单击按钮上的图标会触发 React 中的两个 onClicks(按钮和图标)
- typescript - 带有 TypesScript index.ts 文件的 NextJS 未使用路径别名解析
- javascript - 将类导出为 webpack 中的模块
- python - 如何在 tkinter GUI 位于同一文件中的情况下运行 python 脚本?您如何处理用户条目?
- html - 当我们点击单选按钮时。我们根据我要显示模板的值在单选按钮中获得的值
- r - 比较R中的三个变量并通过在ggplot上分组来映射它