Django Channels消费者connect方法执行数据库查询时WebSocket连接断开

问题根因与修复方案 #

你遇到的WebSocket握手后直接断开的问题，核心原因是connect异步方法中存在未捕获的异常，Channels在未收到显式accept调用且出现异常时会直接主动断开连接，默认日志不会打印这类隐式异常，按以下步骤排查修复即可：

1. 确认导入正确性
   必须导入Channels专属的database_sync_to_async，不要误用Django原生的sync_to_async，原生方法没有处理Django数据库连接的上下文管理，会直接抛出隐式异常：

# 正确导入路径
from channels.db import database_sync_to_async

2. 添加异常捕获定位具体错误
   给connect方法加全局异常捕获，打印完整堆栈信息，就能直接看到具体报错点：

import traceback

async def connect(self):
    try:
        print('connect (got here!)')
        self.room_name = self.scope['url_route']['kwargs']['room_name']
        self.room_group_name = 'chat_%s' % self.room_name
        print('self.room_name: ' + str(self.room_name))

        # 调用同步校验方法，实例方法显式指定thread_sensitive=True适配Django 4+
        valid_connection = await database_sync_to_async(self.verify_chat_room_key, thread_sensitive=True)()
        print('valid_connection: ' + str(valid_connection))

        # 验证通过后先接受连接
        await self.accept()
        # 异步消费者中直接await group_add，禁止使用async_to_sync，否则会卡死
        await self.channel_layer.group_add(
            self.room_group_name,
            self.channel_name
        )
    except Exception as e:
        print(f"连接建立失败：{e}")
        traceback.print_exc()
        # 出错时显式关闭连接
        await self.close()

def verify_chat_room_key(self):
    print('~~~in verify method...~~~')
    # 后续实际添加数据库查询逻辑即可
    return True

3. 修复异步方法调用规范
   你之前注释掉的group_add代码使用了async_to_sync，这是同步消费者的写法，在异步消费者中调用会导致事件循环卡死，直接引发连接断开，后续恢复加组逻辑时必须改成直接await的写法。

调整完成后先看控制台打印的异常信息，如果是数据库权限、查询逻辑的问题，对应修复即可。

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