Daphne WebSocket连接20-30秒后停止响应，寻求排查方案

项目依赖版本 #

• Django 3.2.4
• Channels 3.0.5
• Channel-redis 3.4.1
• Daphne 3.0.2

问题概述 #

基于上述依赖搭建的WebSocket聊天系统，页面加载初期通信正常，但20-30秒左右后数据收发完全中断，刷新页面可恢复连接。已排查consumers.py未发现问题，需要针对Daphne、Nginx及服务器层面的排查方案，目标是保持连接至少30分钟。

排查步骤 #

一、Nginx配置检查 #

• 强制设置长连接超时：Nginx默认的proxy_read_timeout、proxy_send_timeout通常较短，需手动设置为30分钟以上，同时确保WebSocket连接头正确传递。完整配置示例：

location /ws/ {
    proxy_pass http://localhost:8000;  # 对应你的Daphne监听地址
    proxy_http_version 1.1;
    proxy_set_header Upgrade $http_upgrade;
    proxy_set_header Connection "upgrade";
    proxy_set_header Host $host;
    proxy_read_timeout 1800s;  # 30分钟
    proxy_send_timeout 1800s;
}

• 检查keepalive_timeout参数，确保客户端与Nginx的连接超时足够长，避免Nginx主动断开连接。

二、Daphne与Channels配置检查 #

• 优化Redis通道层配置，添加连接健康检查与超时参数，避免Redis连接异常导致WebSocket中断：

CHANNEL_LAYERS = {
    "default": {
        "BACKEND": "channels_redis.core.RedisChannelLayer",
        "CONFIG": {
            "hosts": [("127.0.0.1", 6379)],
            "socket_timeout": 30,
            "socket_connect_timeout": 30,
            "health_check_interval": 30,  # 每30秒检查Redis连接健康
        },
    },
}

• 启用Daphne详细日志：启动Daphne时添加--verbosity 3参数，或者在Django配置中设置日志级别为DEBUG，查看连接断开时的具体错误信息（如Redis连接丢失、连接被主动关闭等）。
• 确认Daphne启动命令无超时限制参数，避免误加--timeout等导致连接提前终止。

三、Consumer逻辑优化与排查 #

• 添加WebSocket心跳机制：WebSocket协议本身无内置心跳，需自定义定时发送ping/pong帧保持连接活跃，示例代码：

import asyncio
from channels.generic.websocket import AsyncWebsocketConsumer

class ChatConsumer(AsyncWebsocketConsumer):
    async def connect(self):
        # 原有连接逻辑
        await self.accept()
        # 启动心跳任务
        self.heartbeat_task = asyncio.create_task(self.send_heartbeat())

    async def send_heartbeat(self):
        while True:
            await asyncio.sleep(10)  # 每10秒发送一次心跳
            await self.send(text_data='{"type": "heartbeat"}')

    async def disconnect(self, close_code):
        # 停止心跳任务
        self.heartbeat_task.cancel()
        # 原有断开逻辑

• 在Consumer的connect、receive等方法中添加异常捕获，打印详细错误日志，避免未处理的异常导致连接意外关闭：

async def receive(self, text_data):
    try:
        # 原有消息处理逻辑
    except Exception as e:
        print(f"Consumer error: {str(e)}")
        # 可选：记录到Django日志

• 确认前端页面处理心跳响应，避免浏览器因长时间无数据传输主动断开连接。

四、服务器与网络层面排查 #

• 检查防火墙/安全组规则：确认没有自动断开长时间TCP连接的超时策略。
• 优化TCP层心跳参数：调整系统tcp_keepalive相关配置，确保TCP层主动维持连接：

# 查看当前配置
sysctl net.ipv4.tcp_keepalive_time net.ipv4.tcp_keepalive_intvl net.ipv4.tcp_keepalive_probes
# 临时设置建议值（重启服务器后失效，需写入/etc/sysctl.conf持久化）
sysctl -w net.ipv4.tcp_keepalive_time=600
sysctl -w net.ipv4.tcp_keepalive_intvl=60
sysctl -w net.ipv4.tcp_keepalive_probes=10

• 检查Redis服务状态：查看Redis日志，确认无连接断开、内存不足等异常。

内容的提问来源于stack exchange，提问作者Decoder