Django Channels的Websocket无法工作，连接失败。

Question

你们好，厉害的人们！

我使用 django-channels 创建了一个聊天室。但是每当我试图通过 Websocket 连接到我的聊天室时，在生产环境中都会失败。而在本地却可以正常工作。

我的主机是在digitalocean上。

pip freeze：

channels==2.1.2
channels-redis==2.3.0
daphne==2.2.1
'''

我已经安装了 redis-server。

sudo apt-get install redis-server

这是我的设置。

INSTALLED_APPS = [
    # '''
   'channels',
    # '''
] 
CHANNEL_LAYERS = {
    'default': {
        'BACKEND': 'channels_redis.core.RedisChannelLayer',
        'CONFIG': {
            "hosts": [os.environ.get('REDIS_URL', 'redis://localhost:6379')],
        },
    },
}
ASGI_APPLICATION = "project_name.routing.application"

这是我的 asgi.py 和 wsgi.py 代码。

import os
import django
from channels.routing import get_default_application

from django.core.wsgi import get_wsgi_application

os.environ.setdefault("DJANGO_SETTINGS_MODULE", "project_name.settings")
django.setup()
application = get_default_application()

这里是我的project_folder.routing.py

。

application = ProtocolTypeRouter({
    'websocket':AllowedHostsOriginValidator(
        AuthMiddlewareStack(
            URLRouter([
                # my urls
            ])
        )
    )
})

我在火狐浏览器中经常会看到以下提示，其他浏览器也有类似的提示：

Firefox 无法建立与 wss://www.domain_name.com/url-to/1/XBvZjr2pqdf6fhy/ 的连接。

但是在本地却可以正常运行。

更新：

这是我的 js 代码：

var loc = window.location;
var wsStart = loc.protocol == "https:" ? "wss://" : "ws://"
var endpoint = wsStart + loc.host + loc.pathname
var socket = new ReconnectingWebSocket(endpoint);

socket.onmessage = function(e){
    // code
}

- Eu Chi

---

我已经尝试一个多月来弄清楚这个问题 /= 你在使用Ubuntu吗？ - Mint

嗨@Eu Chi...我看到你正在使用wss（安全websocket）连接...你已经保护它并为正确的端口进行了保护吗？如果将所有内容移动到常规旧ws上会发生什么？ - user9245558

端口6379是否已经打开并正常工作？ - user9245558

是的，该网站一直正常运行，并且我一直使用js DOM刷新来更新聊天室，直到我决定改用ws。 - Eu Chi

不确定这是否有帮助：https://github.com/django/channels/issues/514 - user9245558

Answer 1

我最终解决了这个问题，并使得 ws 可以在使用 wss:// 连接下工作。

对于那些遇到同样问题的人。

请注意，我使用：

• gunicorn 作为仅用于 http 请求的 web 服务器
• daphne 作为用于 ws web socket 的 web 服务器
• nginx 作为反向代理

asgi.py

import os
import django
from channels.routing import get_default_application

from django.core.wsgi import get_wsgi_application

os.environ.setdefault("DJANGO_SETTINGS_MODULE", "project.settings")
django.setup()
application = get_default_application()

settings.py

ASGI_APPLICATION = "project.routing.application"

CHANNEL_LAYERS = {
    'default': {
        'BACKEND': 'channels_redis.core.RedisChannelLayer',
        'CONFIG': {
            "hosts": [(os.environ.get('REDIS_HOST', 'localhost'),6379)],
        },
    },
}

在使用django设置asgi之后，我使用supervisorctl来保持daphne的运行。在/etc/supervior/conf.d/中创建一个名为daphne_asgi.conf的文件。

daphne_asgi.conf

[program:asgi_daphne]

directory=/path/to/your/project

command=/executable/path/to/daphne --bind 0.0.0.0 --port 8010 project.asgi:application
# 0.0.0.0 ip of your website
# I choose the port 8010 for daphne

stdout_logfile=/path/to/log/daphne.log

autostart=true

autorestart=true

redirect_stderr=true

运行以下命令以更新并启动守护进程

sudo supervisorctl reread
sudo supervisorctl update

这是nginx的配置信息。

map $http_upgrade $connection_upgrade {
    default upgrade;
    '' close;
}
upstream websocket {
    server 0.0.0.0:8010;
}

daphne使用的主机和端口... --bind 0.0.0.0 --port 8010

#redirection to a https
server {
    listen 80;
    server_name 0.0.0.0 example.com www.example.com;
    client_max_body_size 10M;
    return 301 https://www.example.com$request_uri;
}

server {
    listen 443 ssl default_server;
    server_name www.example.com;
    client_max_body_size 10M;

    # ssl configuration
    ...

    # normal http request, I use .sock
    location / {
        include proxy_params;
        proxy_pass http://unix:/path/to/project.sock;
    }

    # ws request /ws/
    location /ws/ {
        proxy_pass http://websocket;

         # this magic is needed for WebSocket
        proxy_http_version  1.1;
        proxy_set_header    Upgrade $http_upgrade;
        proxy_set_header    Connection $connection_upgrade;
        proxy_set_header    Host $http_host;
        proxy_set_header    X-Real-IP $remote_addr;
    }
}

请注意我在我的WS URL中添加了/ws/。

application = ProtocolTypeRouter({

    'websocket':AllowedHostsOriginValidator(
        AuthMiddlewareStack(
            URLRouter(
                [
                    url(r'^ws/$', HelloConsumer),
                ]
            )
        )
    )
})

- Eu Chi

---

你在supervisor中不需要执行python manage.py runworker channels -v2吗？ - Shift 'n Tab

Answer 2

最重要的是使用redis 5.0.9版本，否则会再次出现错误。

从github.com/tporadowski/redis/releases获取它。

- Santosh Rajkumar