1. chat/consumers.py

Let’s rewrite ChatConsumer to be asynchronous.

import json
from channels.generic.websocket import AsyncWebsocketConsumer

class ChatConsumer(AsyncWebsocketConsumer):
    async 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
        await self.channel_layer.group_add(
            self.room_group_name,
            self.channel_name
        )
        
        await self.accept()
        
    async def disconnect(self, code):
        # Leave room group
        await self.channel_layer.group_discard(
            self.room_group_name,
            self.channel_name
        )
        
    # Receive message from WebSocket
    async def receive(self, text_data=None, bytes_data=None):
        text_data_json = json.loads(text_data)
        message = text_data_json["message"]
        
        # Send message to room group
        await self.channel_layer.group_send(
            self.room_group_name,
            {
                "type" : "chat_message",
                "message" : message
            }
        )
        
    # Receive message from room group
    async def chat_message(self, event):
        message = event["message"]
        
        # Send message to WebSocket
        await self.send(text_data = json.dumps
        (
            {
                "message" : message
            }
        ))

Tutorial에서는 async_to_sync 를 통해서 django 의 동기식을 비동기식으로 수행하는 단계를 설명하지만

본인은 바로 async-native 라이브러리를 이용한 비동구방식으로 작성했다.

테스트 해보면..

동일한 chat room에 접속한 다른 브라우저에서 메시지가 broadcast되는 걸 확인할 수 있다.

끝.