在负载均衡器后面运行 daphne 的多个实例:django-channels

Piy*_*Das 5 python django nginx django-channels

我用来为我的应用程序django-channels添加HTTP2WebSocket支持。我找不到很多关于如何扩展通道的文档。下面是我的nginx配置,它对daphne在同一台计算机但不同端口上运行的多个实例进行负载平衡。这是正确的方法吗?

upstream socket {
    least_conn;
    server 127.0.0.1:9000;
    server 127.0.0.1:9001;
    server 127.0.0.1:9002;
    server 127.0.0.1:9003;
}

server {
    listen 80;
    server_name 127.0.0.1;

    location = /favicon.ico { access_log off; log_not_found off; }

    location /static/ {
        root /home/niscp/home-screen;
    }

    location /nicons/ {
        root /home/niscp/home-screen;
    }

    location / {
        include uwsgi_params;
        uwsgi_pass unix:/home/niscp/home-screen/home-screen.sock;
    }

    location /ws/ {
        proxy_http_version 1.1;
        proxy_set_header Upgrade $http_upgrade;
        proxy_set_header Connection "upgrade";
        proxy_pass http://socket;
    }
}
Run Code Online (Sandbox Code Playgroud)

除此之外,我还运行 的各个实例,以workers通过以下方式收听各个频道:

python manage.py runworker --only-channels=websocket.connect
python manage.py runworker --only-channels=websocket.receive
python manage.py runworker --only-channels=websocket.disconnect
Run Code Online (Sandbox Code Playgroud)

我必须以通常处理它们的uwsgi方式处理所有 http 请求django。所有daphne要做workers的就是处理WebSocket请求。这是一种可行的扩展方法django-channels,还是我可以做得更好?

kag*_*ick 1

这里有一些事情。首先,我认为在不同进程中运行不同类型的请求不会带来太多好处。您的断开连接处理程序可能会非常轻 - 除了清理之外不会做太多事情。连接可能也不会做太多事情,而接收将获得大部分负载。

您正在押注使用 --threads 参数并启动多个线程。您当前的设置只会为每种类型的处理程序运行一个线程。

runworker 的工作方式是通过通道层(例如 Redis)与 Daphne 进行通信。所有的工作人员都在监听队列。当请求到来时,一名工作人员将处理它。当该工作人员正在处理请求时,其他工作人员将等待后续请求并处理它们。一旦他们发送了响应,他们就会回去监听队列。如果没有指定 --only-channels ,每个进程都会拉出请求并尽快处理它们,并且没有一个进程会等待。

您可以通过运行多个进程和 --threads 参数来找到线程/工作线程的最佳平衡。您还可以为繁忙的频道保留工作人员,这样他们就不会破坏您的网站。

拥有多个 Daphne 实例会有所帮助。但由于它们所做的只是在您的服务器和工作人员之间发送消息,因此您可能看不到运行 4 个它们的好处。

这里所说的一切不适用于 Channels 2。这是针对旧版本的 Django Channels。