之前项目中使用了 webscoket 进行实现消息实时通知,我们是另外单独运行了一个消息推送服务项目,使用了django-channels 实现websocket,项目使用的是asgi 协议,不是原先的wsgi协议。运行项目时,提示也和wsgi的不一样,如下图:

官方推荐的 asgi 服务器是 daphne 处理 websocket 请求,下面说下如何部署daphne和supervisor。

1.安装部署daphne

安装 django-channels 的时候 daphne 就已经连带一起安装了 在项目的根目录新建一个asgi.py文件,和 wsgi文件同级,内容如下:

import os
import django
from channels.routing import get_default_application
os.environ.setdefault("DJANGO_SETTINGS_MODULE", "项目名称.settings")
django.setup()
application = get_default_application()

2.测试 daphne 配置是否正确: 输入如下命令,看 asgi 服务是否正常启动:

daphne -b 0.0.0.0 -p 8008 项目名称.asgi:application

在websocket在线测试网站,测试websocket是否可以正确建立链接

3.配置supervisor

首先是在终端输入命令 pip install supervisor 安装 supervisor 执行 echo_supervisord_conf > /etc/supervisord.conf 生成supervisor的配置文件 编辑配置文件,输入如下内容:

[program:supervisor项目名称]
directory=/dqcy_message  #项目目录
command=daphne -b 0.0.0.0 -p 8008 代码项目名称.asgi:application #启动命令
autostart=true
autorestart=true
stdout_logfile=/tmp/websocket.log  #日志
redirect_stderr=true

启动supervisor命令:supervisord -c /etc/supervisord.conf 启动或者停止 supervisor 项目服务:

supervisorctl start supervisor项目名称
supervisorctl stop supervisor项目名称

4.配置nginx

使用nginx转发websocket,方面拓展后期的负载均衡。

server {
        listen 80;
        server_name 浏览器访问的ip地址;

        location /async {
            proxy_http_version 1.1;
            proxy_set_header Upgrade $http_upgrade;
            proxy_set_header Connection "upgrade";

            proxy_redirect off;
            proxy_set_header Host $host;
            proxy_set_header X-Real-IP $remote_addr;
            proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
            proxy_set_header X-Forwarded-Host $server_name;
            proxy_pass http://127.0.0.1:8008/async; # websocket启动端口号和路由前缀,要和项目中routing配置的路径保持一致
}