#django #websocket #django-channels
#django #websocket #django-каналы
Вопрос:
Я следую этой ссылке на учебные каналы
Моей целью было создать простой чат-сервер asgi. Но он показывает странное поведение. Сообщение, отправленное с одной вкладки .. должно печатать «ПРИВЕТ» на текущей вкладке .. а также «ПРИВЕТ» на вкладке, подключенной в той же комнате. но при печати обоих «ПРИВЕТ» на текущей вкладке сообщение не отображается на другой вкладке, подключенной в той же комнате.
мой consumers.py это просто, только из файла tutorials…
import json
from asgiref.sync import async_to_sync
from channels.generic.websocket import WebsocketConsumer
class ChatConsumer(WebsocketConsumer):
def connect(self):
self.room_name = self.scope['url_route']['kwargs']['room_name']
self.room_group_name = 'chat_%s' % self.room_name
# 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']
# Send message to room group
async_to_sync(self.channel_layer.group_send)(
self.room_group_name,
{
'type': 'chat_message',
'message': message
}
)
# Receive message from room group
def chat_message(self, event):
message = event['message']
# Send message to WebSocket
self.send(text_data=json.dumps({
'message': message
}))
мой файл настроек настроен на получение соединения redis в 127.0.0.1. Я использую изображение docker redis, как указано в руководстве.
ASGI_APPLICATION = 'mysite.asgi.application'
CHANNEL_LAYERS = {
'default': {
'BACKEND': 'channels_redis.core.RedisChannelLayer',
'CONFIG': {
"hosts": [('127.0.0.1', 6379)],
},
},
}
мой asgi.py файл … настроен так, как сказано в руководстве …>
# mysite/asgi.py
import os
from channels.auth import AuthMiddlewareStack
from channels.routing import ProtocolTypeRouter, URLRouter
from django.core.asgi import get_asgi_application
import chat.routing
os.environ.setdefault("DJANGO_SETTINGS_MODULE", "mysite.settings")
application = ProtocolTypeRouter({
"http": get_asgi_application(),
"websocket": AuthMiddlewareStack(
URLRouter(
chat.routing.websocket_urlpatterns
)
),
})