Django Channels异步WebSocket消费者无法获取模型数据、保存聊天消息问题求助

首先，你的核心问题有两个：一是错误地依赖前端传递的username查询用户（容易出现匹配错误或安全风险），二是异步环境下同步ORM操作的调用方式有误。下面一步步帮你解决：

1. 不要从前端传递用户信息，直接从Scope获取当前登录用户 #

Channels的scope对象已经包含了当前认证后的用户信息（只要配置了AuthMiddleware），完全不需要从前端传username。这不仅更安全，还能彻底避免你遇到的User.DoesNotExist问题（前端传递的username可能存在拼写、大小写等不一致）。

修改receive方法，直接通过self.scope['user']获取用户：

async def receive(self, text_data):
    text_data_json = json.loads(text_data)
    message = text_data_json["message"]
    roomId = text_data_json["roomId"]
    roomName = text_data_json["roomName"]
    
    # 直接从scope获取当前登录用户
    user = self.scope['user']
    if not user.is_authenticated:
        # 处理未认证用户，比如直接断开连接
        await self.close()
        return

    await self.save_message(user, message, roomId, roomName)

    # 广播消息时如果需要返回用户名，直接从user对象取
    await self.channel_layer.group_send(
        self.room_group_name,
        {
            'type': 'the_message',
            'message': message,
            'username': user.username
        }
    )

2. 正确使用sync_to_async包装同步ORM操作 #

你的save_message方法已经用@sync_to_async装饰，内部直接使用同步ORM查询即可，不需要再嵌套database_sync_to_async（装饰器已经把整个函数放到线程中执行）。修改后的方法如下：

@sync_to_async
def save_message(self, user, message, roomId, roomName):
    try:
        # 优先用roomId查询，比roomName更可靠
        the_room = ChatRoom.objects.get(id=roomId)
        new_message = ChatMessage(user=user, chatroom=the_room, message=message)
        new_message.save()
    except ChatRoom.DoesNotExist:
        # 处理房间不存在的异常，比如记录日志
        pass

3. 修复模型中的语法错误 #

你的ChatMessage模型__str__方法里用了self.writer，但模型字段是user，这会导致后续调用该方法时报错，需要修正：

# models.py中ChatMessage的__str__方法
def __str__(self):
    return f"{self.user.username} commented {self.message[:10]}"

4. 确保Channels的AuthMiddleware配置正确 #

要让scope['user']能正常获取用户，你的路由配置必须使用AuthMiddlewareStack，示例如下（routing.py）：

from django.urls import re_path
from channels.auth import AuthMiddlewareStack
from channels.routing import ProtocolTypeRouter, URLRouter
from chat import consumers

application = ProtocolTypeRouter({
    "websocket": AuthMiddlewareStack(
        URLRouter(
            [
                re_path(r"ws/chat/(?P<roomId>\d+)/$", consumers.ChatConsumer.as_asgi()),
            ]
        )
    ),
})

为什么之前的方法会出错？ #

• 在异步方法中直接调用User.objects.get()违反了Django的同步/异步隔离规则，所以触发SynchronousOnlyOperation错误；
• 前端传递的username存在不确定性：即使你确认用户已登录，前端传递的值可能存在大小写、空格等偏差，导致查询不到用户，触发User.DoesNotExist。

按照上面的步骤修改后，就能实现消息广播的同时保存到数据库，页面刷新后消息也不会丢失了。

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