Каналы Django Websocket Disconnect - PullRequest
Новая
       32

Каналы Django Websocket Disconnect

0 голосов
/ 04 января 2019

Я хочу, чтобы мое приложение Django 'popinion1' связывалось через текстовое сообщение с локальной машиной.

замораживание пунктов: 

asgi-redis==1.4.3
asgiref==2.3.2
async-timeout==3.0.1
autobahn==18.12.1
channels==2.1.3
daphne==2.2.4
Django==2.1.3
redis==2.10.6
Twisted==18.9.0

Когда я запускаю "manage.py runserver", кажется, что соединение установлено или, по крайней мере, нет ошибок

Однако, как только я обновляю браузер в терминале, я получаю:

  • ОШИБКА - ws_protocol - [Экземпляр сбоя: обратная связь: class'ValueError '>: не найден маршрут для пути' input / '[много строк] оканчивающийся: WebSocket DISCONNECT / input / [127.0.0.1:50506]

с приложением "/ input /". Отчеты инспектора Firefox:

Firefox не может установить соединение с сервером с помощью ws: //127.0.0.1: 8000

/ input / являясь моим приложением.

мой routing.py - 

from django.conf.urls import url
from channels.routing import ProtocolTypeRouter, URLRouter
from channels.auth import AuthMiddlewareStack
from channels.security.websocket import AllowedHostsOriginValidator, OriginValidator
from input.consumers import ChatConsumer


print('ChatConsumer: ', ChatConsumer.name)

application = ProtocolTypeRouter({
    'websocket': AllowedHostsOriginValidator(
        AuthMiddlewareStack(
            URLRouter(
                [
                    url(r'^input/(?P<username>[\w.@+-]+)/$', ChatConsumer),
                ]
            )
        )
    )
})

JavaScript в шаблоне HTML: 

<script>

    console.log(window.location)
    var loc = window.location
    var wsStart = 'ws://'
    if (loc.protocol == 'https:'){
        wsStart = 'wss://'
    }
    var endpoint = wsStart + loc.host + loc.pathname
    var socket = new WebSocket(endpoint)


    socket.onmessage = function(e){
        console.log("message", e)
    }
    socket.onopen= function(e){
        console.log("open", e)
    }
    socket.onerror= function(e){
        console.log("error", e)
    }
    socket.onclose= function(e){
        console.log("close", e)
    }
</script>

my consumer.py 

import asyncio
import json
from django.contrib.auth import get_user_model
from channels.consumer import AsyncConsumer
from channels.db import database_sync_to_async
from .models import Thread, ChatMessage

from asgiref.sync import async_to_sync

class ChatConsumer(AsyncConsumer):
    name = 'ChatConsumer'

    async def websocket_connect(self, event):
        print('connected! ', event)
        await self.send({
            "type": "websocket.accept"
        })

    async def websocket_receive(self, event):
        print('receive! ', event)


    async def websocket_disconnect(self, event):
        print('disconnected! ', event)

CHANNEL_LAYERS в settings.py 

CHANNEL_LAYERS = {
    'default': {
        'BACKEND': 'asgi_redis.core.RedisChannelLayer',
        'CONFIG': {
            'hosts': [('localhost', 6379)],
        },
        #'ROUTING': 'popinion_project.routing.channel_routing',
    }
}

так что это неверный адрес в routing.py? Также странным является последний импорт "ChatConsumer" в routing.py. Это «неразрешенная ссылка», но оператор print работает.

print ('ChatConsumer:', ChatConsumer.name)

Я следую этому уроку

https://www.youtube.com/watch?v=RVH05S1qab8

Я был бы рад узнать, как подключить веб-сокет. Надеюсь, предоставили всю необходимую информацию. Заранее спасибо

...