Django Channels - 根据打开的 Web 套接字的数量多次调用接收器函数

Posted 2023-02-16

【中文标题】Django Channels - 根据打开的 Web 套接字的数量多次调用接收器函数

【英文标题】：Django Channels - receiver function called multiple times depending on number of open web sockets

【发布时间】：2020-05-08 07:30:45

【问题描述】：

我不明白 Django Channels 2.4.0 的行为。当多个 Web 套接字打开时，接收器函数的调用频率与 Web 套接字打开的频率一样。

这里是著名的频道文档聊天示例中的最小代码

    # Receive message from WebSocket
async def receive(self, text_data):
    text_data_json = json.loads(text_data)
    message = text_data_json['message']

    # Send message to room group
    await self.channel_layer.group_send(
        self.room_group_name,
        
            'type': 'chat_message',
            'message': message
        
    )

# Receive message from room group
async def chat_message(self, event):
    print(event) # this is called as often as sockets are open
    message = event['message']
    # Send message to WebSocket
    await self.send(text_data=json.dumps(
        'message': message
    ))

当我想在接收器函数触发的数据库中执行逻辑操作时，问题变得很严重。然后根据打开的 Web 套接字的数量开始多次执行操作。知道我在这里缺少什么吗？

【问题讨论】：

我无法理解！！！

【参考方案1】：

Django 频道为每个打开的 websocket 连接创建一个 Consumer 类的实例。

group_send 的想法是调用与您的 type 值对应的函数。在每个订阅 (group_add) 到该组的消费者实例上都会调用此函数。

如果您的工作不依赖于单个连接（例如，每个连接的用户 ID 可能不同），请在您发送 group_send 消息之前完成。

因此，如果您需要在group_send 之前查询您的数据库，然后将结果序列化并通过通道层将它们作为您的group_send 消息的一部分发送。

但是，如果您的数据库查询需要考虑订阅用户（也就是过滤掉他们不允许看到的信息），那么您需要在 chat_message 处理程序中执行此操作，并且它将为每个订阅连接调用。或者，您可以在 group_send 之前进行查询，以公开所需信息，以便在您的 chat_message 中，您只需检查消息以确定是否可以将其发送给用户。