Сервер WebSocket отказывается от всех соединений в Django каналах - PullRequest
0 голосов
/ 15 марта 2020

Я разговаривал с django (бэкэнд) и реагировал (веб-интерфейс). Я использую Django Каналы для создания сервера WebSocket, но он не работает: при попытке соединения с React он выдает Forums.jsx:61 WebSocket connection to 'ws://localhost:8000/forums/divers/' failed: Error during WebSocket handshake: net::ERR_CONNECTION_RESET в консоли навигатора. Этим утром он работал, но сегодня днем, после закрытия и повторного открытия двух серверов, он не работает. Я только запустил систему для хранения сообщений в базе данных в течение этого времени. Потребитель:

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

Если бы кто-то мог объяснить мне, как решить эту проблему, он действительно помог бы мне.


EDIT: Когда я удаляю async и заменяю await на async_to_sync, это работает. Может кто-нибудь объяснить мне, почему он работает синхронно, а не асинхронно?

1 Ответ

0 голосов
/ 16 марта 2020

Я решил свою проблему, заменив WebsocketConsumer на AsyncWebsocketConsumer.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...