python - Django Websockets 数据到错误的套接字
问题描述
使用 Django Websockets + Channels,我创建了一个(一个)组,并且消息来回工作得很好。让我们称之为 A 组
当我在不同的浏览器中打开第二个组和第二个(让我们称之为 B 组)WebSocket 连接时,问题就开始了。
我尝试发送到组 A(第一个 WebSocket 连接)的消息将发送到组 B(第二个 WebSocket 连接)。属于 A 组的所有消息都进入第二个 WebSocket,B 组消息也进入第二个套接字。
这是我的消费者.py
import json
from asgiref.sync import async_to_sync
import logging
LOG = logging.getLogger(__name__)
from channels.generic.websocket import WebsocketConsumer, AsyncWebsocketConsumer
class EventConsumer(AsyncWebsocketConsumer):
async def connect(self):
self.id = self.scope['url_route']['kwargs']['id']
self.group_name = f'enl_events_log_{self.id}'
# Join room group
await self.channel_layer.group_add(
self.group_name,
self.channel_name
)
await self.accept()
async def disconnect(self, close_code):
# Leave room group
await self.channel_layer.group_discard(
self.group_name,
self.channel_name
)
# Receive message from WebSocket
async def receive(self, text_data):
# text_data_json = json.loads(text_data)
# message = text_data_json['message']
# Send message to room group
await self.channel_layer.group_send(
self.group_name,
{
'type': 'send.message',
'message': "Message received"
}
)
# Receive message from room group
async def send_message(self, event):
message = event['message']
# Send message to WebSocket
await self.send(text_data=json.dumps({
'message': message
}))
这是我的routing.py
from channels.auth import AuthMiddlewareStack
from channels.routing import ProtocolTypeRouter, URLRouter
from django.conf.urls import url
from app.consumers import EventConsumer
websocket_urlpatterns = [
url(r'^enl_events/(?P<id>[^/]+)', EventConsumer()),
]
application = ProtocolTypeRouter({
'websocket': AuthMiddlewareStack(
URLRouter(
websocket_urlpatterns
)
),
})
这是我的 ASGI.py + settings.py
import os
import django
from channels.routing import get_default_application
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'some_app.settings')
django.setup()
application = get_default_application()
--------------
ASGI_APPLICATION = "application"
WSGI_APPLICATION = 'application'
CHANNEL_LAYERS = {
"default": {
"BACKEND": "channels_redis.core.RedisChannelLayer",
"CONFIG": {
"hosts": [("127.0.0.1", 6379)],
},
},
}
这是我的意见.py
def events(request: HttpRequest) -> HttpResponse:
channel_layer = get_channel_layer()
async_to_sync(channel_layer.group_send)(
'groupA_id',
{'type': 'send.message', 'message': "please work"},
)
return HttpResponse(status=202)
我在端口 3000 上运行前端
我正在使用的后端
Daphne some_app.asgi:application --port=9000
注意:我能够很好地创建两个 WebSocket 连接。为什么会出现数据不匹配?
如果我为 A 组创建一个 WebSocket,那么属于 A 组的消息不应该转到 A 组/websocket 1 吗?
下面提供的日志
[2020-11-17 17:17:03 +0000] [89629] [INFO] Configuring endpoint tcp:port=9000:interface=127.0.0.1
[2020-11-17 17:17:03 +0000] [89629] [INFO] Listening on TCP address 127.0.0.1:9000
127.0.0.1:62209 - - [17/Nov/2020:17:17:17] "WSCONNECTING /events/12345" -
127.0.0.1:62209 - - [17/Nov/2020:17:17:17] "WSCONNECT /events/12345" - -
127.0.0.1:62265 - - [17/Nov/2020:17:17:26] "WSCONNECTING /events/56789" -
127.0.0.1:62265 - - [17/Nov/2020:17:17:26] "WSCONNECT /events/56789" - -
解决方案
所以,我弄清楚是什么导致了这些问题。
路由丢失as_asgi()
from channels.auth import AuthMiddlewareStack
from channels.routing import ProtocolTypeRouter, URLRouter
from django.conf.urls import url
from app.consumers import EventConsumer
websocket_urlpatterns = [
url(r'^events/(?P<id>[^/]+)', EventConsumer().as_asgi()),
]
application = ProtocolTypeRouter({
'websocket': AuthMiddlewareStack(
URLRouter(
websocket_urlpatterns
)
),
})
推荐阅读
- android - 警报管理器:每次打开活动时忽略警报参数并运行方法
- node.js - 使用 node.js 的 AWS Lambda 不执行承诺函数
- c - 带有函数指针参数的函数指针
- angular - 服务构造函数调用了两次
- java - 颤振应用程序无缘无故崩溃:E / Surface(6317):queueBuffer:错误将缓冲区排队到SurfaceTexture,-22
- julia - Floatmax 未定义阻止我解决 MIP
- javascript - 转换数据时 obj[i] 在 javascript 中不可迭代
- excel - VBA 将整个数据集移动到不同的行和列中
- python - SQLAlchemy中与关联代理的自引用多对多关系
- powershell - 如何以与 PowerShell 脚本不同的用户身份运行 exe?