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

Question

我不了解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套接字，事情开始多次执行。知道我在这里缺少什么吗？

Answer 1

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

group_send的想法是调用与type值相对应的函数。在已订阅（group_add）该组的每个使用者实例上调用此函数。

如果您要完成的工作不依赖于单个连接（例如，每个连接的用户ID可能不同，则在发送group_send消息之前先进行此操作。

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

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