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

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
        )
    ),
})

论坛/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

我通过将WebsocketConsumer 替换为AsyncWebsocketConsumer 解决了我的问题。