我有一个 Django + Vue.js 聊天应用程序,我正在尝试连接到 django-channels。
要访问任何聊天室,您只需访问:
我的 JavaScript 连接如下所示:
connectToWebSocket () {
const chatSocket = new WebSocket(
`ws://localhost:8000/ws/rooms/${this.$route.params.id}/`
)
chatSocket.onopen = this.onOpen
chatSocket.onclose = this.onClose
chatSocket.onmessage = this.onMessage
chatSocket.onerror = this.onError
},
我的消费者.py:
class ChatConsumer(WebsocketConsumer):
def connect(self):
self.room_uri = self.scope['url_route']['kwargs']['uri']
self.room_group_name = 'chat_%s' % self.room_uri
# Join room group
async_to_sync(self.channel_layer.group_add)(
self.room_group_name,
self.channel_name
)
self.accept()
def disconnect(self, close_code):
# Leave room group
async_to_sync(self.channel_layer.group_discard)(
self.room_group_name,
self.channel_name
)
# Receive message from WebSocket
def receive(self, text_data):
text_data_json = json.loads(text_data)
message = text_data_json['message']
user = text_data_json['user.username']
# Send message to room group
async_to_sync(self.channel_layer.group_send)(
self.room_group_name,
{
'type': 'chat_message',
'user': user,
'message': message
}
)
# Receive message from room group
def chat_message(self, event):
user = event['user']
message = event['message']
# Send message to WebSocket
self.send(text_data=json.dumps({
'user': user,
'message': message
}))
和我的routing.py:
from django.conf.urls import url
from core import consumers
websocket_urlpatterns = [
url(r'^ws/rooms/<uri>/', consumers.ChatConsumer),
]
我的项目routing.py:
from channels.auth import AuthMiddlewareStack
from channels.routing import ProtocolTypeRouter, URLRouter
import core.routing
application = ProtocolTypeRouter({
'websocket': AuthMiddlewareStack(
URLRouter(
core.routing.websocket_urlpatterns
)
)
})
问题是,我无法连接到 websocket,我的 django 服务器说:
[失败实例:回溯::找不到路径“ws/rooms/759b9a8262ea4b7/”的路由。
我的代码有什么问题,无法通过 websocket 连接到特定房间?
完整堆栈跟踪:
[失败实例:回溯::找不到路径“ws/rooms/759b9a8262ea4b7/”的路由。 /home/dave/PycharmProjects/chatapp2/back/venv/lib/python3.6/site-packages/autobahn/websocket/protocol.py:2801:processHandshake /home/dave/PycharmProjects/chatapp2/back/venv/lib/python3.6/site-packages/txaio/tx.py:429:as_future /home/dave/PycharmProjects/chatapp2/back/venv/lib/python3.6/site-packages/twisted/internet/defer.py:151:maybeDeferred /home/dave/PycharmProjects/chatapp2/back/venv/lib/python3.6/site-packages/daphne/ws_protocol.py:82:onConnect --- --- /home/dave/PycharmProjects/chatapp2/back/venv/lib/python3.6/site-packages/twisted/internet/defer.py:151:maybeDeferred /home/dave/PycharmProjects/chatapp2/back/venv/lib/python3.6/site-packages/daphne/server.py:198:create_application /home/dave/PycharmProjects/chatapp2/back/venv/lib/python3.6/site-packages/channels/staticfiles.py:41:call /home/dave/PycharmProjects/chatapp2/back/venv/lib/python3.6/site-packages/channels/routing.py:58:call /home/dave/PycharmProjects/chatapp2/back/venv/lib/python3.6/site-packages/channels/sessions.py:43:call /home/dave/PycharmProjects/chatapp2/back/venv/lib/python3.6/site-packages/channels/sessions.py:141:call /home/dave/PycharmProjects/chatapp2/back/venv/lib/python3.6/site-packages/channels/sessions.py:165:init /home/dave/PycharmProjects/chatapp2/back/venv/lib/python3.6/site-packages/channels/middleware.py:31:call /home/dave/PycharmProjects/chatapp2/back/venv/lib/python3.6/site-packages/channels/routing.py:154:call
你需要使用
url
,我也遇到了同样的问题:
websocket_urlpatterns = [
path('ws/chat/<str:room_name>/$', consumers.ChatConsumer),
]
websocket_urlpatterns = [
url(r'^ws/chat/(?P<room_name>[^/]+)/$', consumers.ChatConsumer),
]
尝试这样的事情:
routing.py(在 django 应用程序文件夹内)
from django.urls import path
from core import consumers
websocket_urlpatterns = [
path('ws/rooms/<uri>/', consumers.ChatConsumer),
]
routing.py(与您的settings.py同一级别)
from channels.auth import AuthMiddlewareStack
from channels.routing import ProtocolTypeRouter, URLRouter
import myapp.routing
application = ProtocolTypeRouter({
# (http->django views is added by default)
'websocket': AuthMiddlewareStack(
URLRouter(
myapp.routing.websocket_urlpatterns
)
),
})
最后在您的设置中。py
CHANNEL_LAYERS = {
'default': {
'BACKEND': 'channels_redis.core.RedisChannelLayer',
'CONFIG': {
"hosts": [REDIS_URL],
},
},
}
INSTALLED_APPS.append('channels')
ASGI_APPLICATION = 'myapp.routing.application'
我遇到了和你一样的问题,刚刚解决了! 在我的 ws_client.py 中我写了这个
ws.create_connection("ws://127.0.0.1:8000/alarm")
在routing.py中我将其更改为下面的内容并且它起作用了
from django.urls import path
channel_routing = [
path('alarm',consumers.ws_message),
# before I wrote 'alarm/', I just change from alarm/ to alarm
]
并且成功了!你可以尝试一下
对于任何可能面临此问题的新人。不要将
path
模式匹配器与正则表达式一起使用。如果您想使用,请使用 url
或 re_path
代替。
使用
path
匹配不带尾随或前导斜杠 (/) 的模式,并确保模式与客户端 Web 套接字 URL 相对应
websocket_urlpatterns = [
path("ws/chat/<int:uri>", ChatConsumer.as_asgi()),
]
使用
re_path
或 url
匹配不带尾部斜杠 (/) 的模式。
url(r'^ws/chat/(?P<uri>[^/]+)/$', ChatConsumer.as_asgi()),
注意:我建议使用
path
,因为它更容易匹配模式和阅读。
从 app.routing 路由文件中删除斜杠解决了问题,我猜它被计为该套接字的 URL 中的重复斜杠。
例如,我有:
url(r'/ws/documents/get-df', consumers.DFConsumer.as_asgi())
这不起作用,但是当我删除之前的第一个斜杠时它起作用了
url(r'ws/documents/get-df', consumers.DFConsumer.as_asgi())
我有类似的问题并添加了 .as_asgi() 并且它有效
url(r"messages/(?P<username>[\w.@+-]+)/", ChatConsumer.as_asgi())
,
您可能需要重新启动服务,似乎不会自动重新加载。
我花了一个多小时来解决这个问题,我发现我的默认 django 项目没有考虑 asgi.py 配置设置。
将 daphne 安装到您的项目中
python -m pip install daphne
列入您的
INSTALLED_APPS
数组
INSTALLED_APPS = [
"daphne",
...,
]
ASGI_APPLICATION = "myproject.asgi.application"
运行您的项目并查看它是否与您的 websocket 连接。
对于上下文,我的 asgi.py 文件是这样的
import os
from django.urls import path,
from channels.routing import ProtocolTypeRouter, URLRouter
from chat_app.routing import ChatConsumer
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'teacher_gpt_chat.settings')
websocket_urlpatterns = [
path('ws/chat', ChatConsumer.as_asgi())
]
application = ProtocolTypeRouter(
{
# "http": get_asgi_application(),
"websocket": URLRouter(websocket_urlpatterns),
}
)