WebSocket 服务器拒绝 Django 通道中的所有连接

Question

我正在与 django（后端）聊天并做出反应（前端）。我使用 Django Channels 创建 WebSocket 服务器，但它不工作：当尝试连接 React 时，它抛出 Forums.jsx:61 WebSocket connection to 'ws://localhost:8000/forums/divers/' failed: Error during WebSocket handshake: net::ERR_CONNECTION_RESET 在导航器控制台中。今天早上它在工作，但是今天下午，在关闭并重新打开 2 个服务器之后，它不工作了。我只是在这段时间启动了一个系统来将消息存储在数据库中。消费者：

from channels.generic.websocket import WebsocketConsumer
import json
from .models import Message

class ChatConsumer(WebsocketConsumer):
    async def connect(self):
        self.forum = self.scope["url_route"]["kwargs"]["forum"]

        # Join room group
        await self.channel_layer.group_add(
            self.forum,
            self.channel_name
        )
        print("connect func")
        self.accept()

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

    async def receive(self, text_data=None, bytes_data=None):
        text_data_json = json.loads(text_data)
        message = text_data_json['message']
        print(message)
        await self.channel_layer.group_send(
            self.forum,
            {
                'type': 'chat_message',
                'message': message
            }
        )

    async def chat_message(self, event):
        message = event['message']
        #await sync_to_async(Message.objects.create)(message=message["message"], )
        # Send message to WebSocket
        await self.send(text_data=json.dumps({
            'message': message
        }))

打开 WebSocket 客户端：

class Forum extends Component { 
    constructor(props) {
        super(props)
        ...
        this.URL = constants.BACKEND_WS + "/forums/" + this.state.forum + "/";
        this.ws = new WebSocket(this.URL)
    }
    componentDidMount() {
        console.log("didmount");
        this.ws.onopen = () => {
            console.log('connected')
        };

        this.ws.onmessage = evt => {
            const message = JSON.parse(evt.data);
            console.log(message);
            this.addMessage(message)
        };

        this.ws.onclose = () => {
            console.log('disconnected');
            this.setState({
                ws: new WebSocket(this.URL),
            })
        }
    }
}

django 服务器的日志：

WebSocket HANDSHAKING /forums/divers/ [127.0.0.1:52726]
WebSocket DISCONNECT /forums/divers/ [127.0.0.1:52726]

mysite/routings.py :

from channels.routing import ProtocolTypeRouter, URLRouter
from channels.auth import AuthMiddlewareStack
import forums.routing

application = ProtocolTypeRouter({
    'websocket': AuthMiddlewareStack(
        URLRouter(
            forums.routing.websocket_urlpatterns
        )
    ),
})

forums/routing.py:

from django.urls import re_path

from . import consumers

websocket_urlpatterns = [
    re_path(r'forums/(?P<forum>\w+)/$', consumers.ChatConsumer),
]

如果有人能向我解释如何解决这个问题，他真的会帮助我。

编辑： 当我删除 async 并将 await 替换为 async_to_sync 时，它起作用了。有人能解释一下为什么它是同步工作而不是异步工作吗？

Answer 1

我用 AsyncWebsocketConsumer 替换 WebsocketConsumer 解决了我的问题。

WebSocket 服务器拒绝 Django 通道中的所有连接

WebSocket server refusing all connections in Django Channels

python

django

websocket

reactjs

django-channels