【踩坑指南】Django+channels WebSocket配置

本文介绍: 目前我搜到网上所有配置Django+channels的教程/博客中，都没有提及这一点。希望能帮助你。

目前我搜到网上所有配置Django+channels的教程/博客中，都没有提及这一点。希望能帮助你

踩的坑必须写在最前面：

根据文档的步骤去配置，每次到执行 python m ana g e.py 的时,使用的是默认的dev e lo pm ent server，而不是我们想要的Star t in g ASGI/Da p hne server

解决办法：在项目的settings.py中
INSTALLED_APPS = [
“d a p hne”, # 增加d a p hne这一项，而且必须在channels之前
‘channel s’,
]

出现原因：使用manage.py run server 命令，默认是执行WSGI的（即使你更新并删除了settings.py中的WSGI），我们必须注册 d a phne/其他的服务端也可以，这样执行manage.py run server 命令才会去更改默认的服务器，使用ASGI的。

问题 背景：

最近，想去做一个 ai 训练模型在网页上进行展示，具体实现想法就是，前端发送状态，后端接收，将状态传入已经训练好的基于 tensorflow 框架下的神经网络模型，返回一个得到的动作，前端执行该动作获得新的状态，前端发送新的状态，如此循环，直至触发停止条件。

对于这种需求
 使用 http 可以解决，但是每次新的状态都去发起请求，这对服务器的负荷是比较重的，
如果你也遇到了这个问题，可以考虑用webSoc ket去解决。

WebSoc ket 协议：

Django+Cha nnels,实现 webSoc ket 通信

step1：安装

pip install django>=3.0
pip install channels
pip install daphne

step2：创建 project

django-admin startproject WebSocketTest

step3: 创建 app

python manage.py startapp app01

step4：注册Chanels & daphne 这个daphe好多教程都不说，必须加!!!

webSoc ket / settings.py 中添加

INSTALLED_APPS = [
	 # 其他app
	 'daphne', # 必须在channels的上面
    'channels',
	# 其他app
]

step5：编写asgi.py

webSoc ket / asgi.py

import os

from channels.routing import ProtocolTypeRouter, URLRouter
from django.core.asgi import get_asgi_application

from webSocket import routing

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'webSocket.settings')

# application = get_asgi_application()
application = ProtocolTypeRouter({
    'http': get_asgi_application(),
    'websocket': URLRouter(routing.websocket_urlpatterns),
})

step6：增加ASGI配置

webSocket / settings.py 中添加

ASGI_APPLICATION = 'webSocket.asgi.application'

step7：增加routing

这routing的位置在哪个app里面都可以，这个我就将其放在 webSocket / routing.py

from  django.urls import path

from app01 import consumers

websocket_urlpatterns = [
    path('room/hony', consumers.ChatConsumer.as_asgi())
]

step8：编写consumers.py

这consumers.py的位置在哪个app里面都可以，这个我就将其放在 app01 / consumers.py

from channels.exceptions import StopConsumer
from channels.generic.websocket import WebsocketConsumer


class ChatConsumer(WebsocketConsumer):
    def websocket_connect(self, message):
        self.accept()

    def websocket_receive(self, message):
        print(message)
        self.send("不要")

    def websocket_disconnect(self, message):
        raise StopConsumer()