"장고 실시간 채팅(Channels와 redis server 이용)"의 두 판 사이의 차이

2022년 10월 3일 (월) 12:18 판

1 개요

2 기초준비

2.1 채팅어플 만들기

패키지설치부터 진행하기엔 중간점검이 어려워 틀 만들기를 먼저 수행한다.

과정	설명	방법
어플리케이션생성	채팅을 위한 앱을 생성한다. 앱을 생성하고 __init__.py와 views.py를 제외한 모든 것들을 지운다.	django-admin startapp chat
앱 등록	settings.py에 추가.	INSTALLED_APPS = [ 'chat',
URL매핑	기본이 되는 urls.py 안에서 해당 앱으로 매핑을 시켜준다.	path('chat/', include('chat.urls')),
URL매핑2	그리고 앱 안의 urls.py 작성.	from dfango.urls import path from . import views urlpatterns = [ path('/', views.index, name='index'), ]
view 작성		from django.shortcuts import render def index(request): return render(request, 'chat/index.html', {})
탬플릿 준비	앱 하위에 templates>chat 디렉터리까지 만든다. index.html 이라는 이름으로 만들자.	<!-- chat/templates/chat/index.html --> <!DOCTYPE html> <html> <head> <meta charset="utf-8"/> <title>Chat Rooms</title> </head> <body> What chat room would you like to enter?<br/> <input id="room-name-input" type="text" size="100"/><br/> <input id="room-name-submit" type="button" value="Enter"/> <script> document.querySelector('#room-name-input').focus(); document.querySelector('#room-name-input').onkeyup = function(e) { if (e.keyCode === 13) { // enter, return document.querySelector('#room-name-submit').click(); } }; document.querySelector('#room-name-submit').onclick = function(e) { var roomName = document.querySelector('#room-name-input').value; window.location.pathname = '/chat/' + roomName + '/'; }; </script> </body> </html>

여기까지 하고 runserver 후 제대로 작동하는지 확인하자.

2.2 채팅룸 구현

과정

설명

방법

URL매핑

앱 내의 urls.py에 추가.

urlpatterns = [
    ...
    path('<str:room_name>/', views.room, name='room'),
    ...
]

뷰 작성

room 뷰 작성

mark_safe와 json을 가져온다.

from django.shortcuts import render
from django.utils.safestring import mark_safe
import json

def room(request, room_name):
    return render(request, 'chat/room.html', {
        'room_name_json': mark_safe(json.dumps(room_name))
    })

탬플릿 작성

/char/room.html을 만든다.

<!DOCTYPE html>
<html>
<head>
    <meta charset="utf-8"/>
    <title>Chat Room</title>
</head>

<body>
    <textarea id="chat-log" cols="100" rows="20"></textarea><br/>
    <input id="chat-message-input" type="text" size="100"/><br/>
    <input id="chat-message-submit" type="button" value="Send"/>
</body>

<script>
    var roomName = {{ room_name_json }};

    var chatSocket = new WebSocket(
        'ws://' + window.location.host +
        '/ws/chat/' + roomName + '/');

    chatSocket.onmessage = function(e) {
        var data = JSON.parse(e.data);
        var message = data['message'];
        document.querySelector('#chat-log').value += (message + '\n');
    };

    chatSocket.onclose = function(e) {
        console.error('Chat socket closed unexpectedly');
    };

    document.querySelector('#chat-message-input').focus();
    document.querySelector('#chat-message-input').onkeyup = function(e) {
        if (e.keyCode === 13) {  // enter, return
            document.querySelector('#chat-message-submit').click();
        }
    };

    document.querySelector('#chat-message-submit').onclick = function(e) {
        var messageInputDom = document.querySelector('#chat-message-input');
        var message = messageInputDom.value;
        chatSocket.send(JSON.stringify({
            'message': message
        }));

        messageInputDom.value = '';
    };
</script>

</html>

2.3 참가자 구현

과정

설명

방법

참가자 파일 작성

/chat/consumers.py 작성.

모든 요청을 받아들이는 비동기적인 웹소켓.

클라이언트로부터 메시지를 받아서 그대로 전달.

from channels.generic.websocket import WebsocketConsumer
import json

class ChatConsumer(WebsocketConsumer):
    def connect(self):
        self.accept()

    def disconnect(self, close_code):
        pass

    def receive(self, text_data):
        text_data_json = json.loads(text_data)
        message = text_data_json['message']

        self.send(text_data=json.dumps({
            'message': message
        }))

라우팅 작성

/chat/routing.py 작성

from django.conf.urls import url
from . import consumers

websocket_urlpatterns = [
    url(r'^ws/chat/(?P<room_name>[^/]+)/$', consumers.ChatConsumer),
]

라우팅 등록

/routing.py 수정

chat 안의 라우팅을 등록해준다.

그리고 임포트하는 모듈을 수정해준다.

from channels.auth import AuthMiddlewareStack
from channels.routing import ProtocolTypeRouter, URLRouter
import chat.routing

application = ProtocolTypeRouter({
    # (http->django views is added by default)
    'websocket': AuthMiddlewareStack(
        URLRouter(
            chat.routing.websocket_urlpatterns
        )
    ),
})

여기까지 하고 채팅을 쳐 보면... 채팅이 나와야 정상.

2.4 체널레이어 구현

과정

설명

방법

패키지 설치

Channels가 Redis인터페이스를 인식하도록.

pip install channels_redis

settings.py 설정

ASGI 아래 추가하자.

ASGI_APPLICATION = 'routing.application'  # routing.py 파일의 application을 불러온다.
CHANNEL_LAYERS = {
    'default': {
        'BACKEND': 'channels_redis.core.RedisChannelLayer',
        'CONFIG': {
            "hosts": [('127.0.0.1', 6379)],
        },
    },
}

3 개요

레디스 서버를 이용한 실시간 채팅 구현

3.1 사전설정

과정	설명	방법
서버 설치		apt-get install redis-server
서버 테스트	서버가 잘 설치되었는지 테스트. 서버 구동에 대한 메시지가 뜬다.	redis-server
채널 라이브러리 설치	장고에서 사용할 채널 라이브러리를 설치한다.	pip install -U channels
연동 라이브러리 설치	서버와 채널을 연동할 라이브러리를 설치한다.	pip install channels_redis
앱을 만든다.		django-admin startapp chat
앱 등록	settings.py에 추가.	INSTALLED_APPS 가장 위에 'channels', 'chat'을 맨 위에 추가해준다. 다른 서드파티 앱과 충돌할 수 있어 가장 처음에 둔다.
세팅	settings.py 안에 추가.	ASGI_APPLICATION = 'config.routhing.application' CHANNEL_LAYERS = { 'default':{ 'BACKEND': 'channels_redis.core.RedisChannelLayer', 'CONFIG': { "hosts": [('127.0.0.1', 6379)], } } } os.environ["DJANGO_ALLOW_ASYNC_UNDAFE"] = "true" 을 추가해준다.(대강 스테틱 설정 아래면 적당)

4 모델작성

chat 앱의 models.py 작성

from django.db import models
from django.conf import settings

class Room(models.Model):
    room_name = models.CharField(max_length=100, blank=True)
    users = models.ManyToManyfield(
        settings.AUTH_USER_MODEL,  # 유저모델과 연결한다.
        blank=True,
        related_name = 'rooms')  # 룸이라는 인덱스 지정.
    
    def __str__(self):
        return self.room_name
        
class Message(models.Model):
    user = models.ForeignKey(settings.AUTH_USER_MODEL, on_delete=models.CASCADE, default=1)
    room = models.ForeignKey(Room, related_name='messages', default=1, on_delete=models.CASCADE)
    content = models.TextField(blank=True)
    created_at = models.DateTimeField(auto_now_add=True)
    
    def __str__(self):
        return self.content

chat앱의 admin.py 작성

from django.contrib import admin
from .models import Room, Message

@admin.register(Room)
class RoomAdmin(admin.ModelAdmin):
    list_display = ['id', 'room_name']
    list_display_links = ['room_name']
    
@admin.register(Room)
class MessageAdmin(admin.ModelAdmin):
    list_display = ['user', 'room', 'content', 'created_at']
    list_display_links = ['user', 'room', 'content', 'created_at']

대화모델 작성(보통 친구모델 등에 작성된다.)(근데 그냥 chat 앱 안에 작성하면 안되나...?)

...
from .chat.models import Room, Message

class chat_connection(models.Model):
    target = models.ForeignKey(settings.AUTH_USER_MODEL, blank=True, on_delete=models.CASCADE)  # 상대방
    room = models.ForeignKey(Room, blank=True, on_delete=models.SET_NULL, null=True)  # null옵션이 있어야 하나..? 없어도 될듯, 강의에선 친구모델 위에 더하느라 붙인듯.
    user = models.ForeignKey(settings.AUTH_USER_MODEL, blank=True, on_delete=models.CASCADE)  # 나
    created_at = models.DateField(auto_now_add=True)
    
    def __str__(self):
        return self.user.username + "채팅"  # 사용자명을 반환한다.

5 뷰 작성

from django.shortcuts import render, get_object_or_404
forom django.contrib.auth import get_user_model
from chat.models import *
import logging

def start_chat(request):
    from_user =   # 본인의 유저모델 가져오기
    to_user = 유저모델.objects.get(pk=target_request_id)  # 상대의 유저모델 가져오기(이름이나 pk로 불러오게 하면 될듯)
    
    room_name = "{},{}".format(from_user.username, to_user.username)
    room = Room.objects.create(room_name=room_name)  # 룸을 만든다.
    
def chat_list(request):
    user = request.user
    user_profile = user.user_profile
    friends = user.friends.all()  # 모든 친구 불러오기...(채팅자 목록이라고 보면 됨.)
    
    context = {'user_profile': user_profile,
                'friends':friends,
    }
    
    return render(request, 'chat/chat_list.html', context)
    
def room(request, room_id):
    user = request.user
    user_profile = user.profile
    friends = user.friends.all()  # 모든 친구 불러오기...(채팅자 목록이라고 보면 됨.)
    
    room = Room.objects.get(pk=room_id)  # 룸 모델에서 해당 pk에 맞는 룸 불러오기
    friends_uer = room.users.all().exclude(pk=user.id).first()
    
    context = {'current_user': user,
        'user_profile': user_profile,
        'friends':friends,
        'room':room,
        'friends_user': friends_user,
    }
    
    return render(request, 'chat/room.html', context)

6 url 작성

config의 url을 넘김 처리하고..

chat앱 안의 urls.py를 작성한다.

from .views import *

app_name= 'chat'

urlpatterns = [
    path('', chat_list, name='chat_list'),
    paht('<str:room_id', room, name='room'),
]

7 탬플릿 작성

chat 앱 안의 templates 폴더를 만든 다음 넣는다.

<!--확장코드-->

<!--들어가야 할 것들-->
<script src="{% static 'js/messenger.js' %}"></script>

<div id="user_list">
    {% for friend in friends %}
        {% if friend.room %}
         <li name="{{ friend.room.id }}"><a href="/chat/{{ friend.room.id }}/"
         <div>{{ friend.user }}</div>
</div>

<div id="time_line">
    <div id="main_section">
        <div id="feed">
            <div id="text_field">
                <input type="text" id="txt">
                <button type="submit" id="btn">전송</button>
            </div>
        </div>
    </div>
</div>

@@ 1번째 줄: / 1번째 줄: @@
 == 개요 ==
-https://channels.readthedocs.io/en/latest/index.html<nowiki/>를 참고하였다.
-장고는 기본적으로 동기식으로, 채팅을 위해선 비동기식 처리가 필요하다.
-이를 위해 Django Channels가 마련되어 있다.
-ASGI(Async Server Gateway Interface)프로토콜은 WSGI를 계승하여 이와 잘 호환되도록 설계되어 있다.
-ASGI는 비동기 요청인 웹 소켓을 처리하는 이벤트로 connect, send, receive, disconnect가 있다.
 == 기초준비 ==
@@ 91번째 줄: / 82번째 줄: @@
 여기까지 하고 runserver 후 제대로 작동하는지 확인하자.
-=== 패키지 설치 ===
+=== 채팅룸 구현 ===
-{| class="wikitable"
-!과정
-!설명
-!방법
-|-
-|패키지 설치
-|Channels 패키지를 설치한다.
-|pip install -U channels
-|-
-|앱 등록
-|settings.py에 추가.
-channels는 runserver 명령을 제어하여 기존 서버를 대체한다.
-|INSTALLED_APPS 하위, 가장 처음에 <code>'channels'</code>넣는다.<syntaxhighlight lang="python">
-INSTALLED_APPS = [
-    'channels',  # 다른 서드파티 앱과 충돌할 수 있어 가장 처음에 둔다.
-    ...  # 공식 튜토리얼에선 'chat'을 상위로 올리지만, 아래에 있어도 상관 없다.
-    ...
-    'chat',
-</syntaxhighlight>
-|-
-|라우팅 설정 작성
-|가장 상위의 디렉터리에 routing.py를 다음과 같이 작성한다.
-(취향에 따라 달리 작성해도 된다.)
-|<syntaxhighlight lang="python">
-from channels.routing import ProtocolTypeRouter
-application = ProtocolTypeRouter({
-    # (http->django views is added by default)
-})
-</syntaxhighlight>
-|-
-|설정 추가
-|settings.py 안에 우측의 내용을 추가한다.
-라우팅파일의 위치만 잘 잡아주면 된다.
-|<syntaxhighlight lang="python">
-ASGI_APPLICATION = 'routing.application'  # routing.py 파일의 application을 불러온다.
-</syntaxhighlight>(라우팅 파일 안의 application을 가져온다.)
-|}
-== 채팅룸 구현 ==
 {| class="wikitable"
 !과정