从消费者外部收听 Django 频道 channel_layer

Question

文档解释说可以从消费者外部发布到通道层：https : //channels.readthedocs.io/en/latest/topics/channel_layers.html#using-outside-of-consumers 我需要做相反。我有一个相当复杂的 python 脚本，它从 pubnub 读取实时数据，处理它，然后通过 channel_layer 上的组将它推送给消费者。这工作正常，但我需要消费者能够向此脚本宣布他们的存在，以便它可以向他们推送数据（它目前仅在从 pubnub 获取新数据时才推送到通道层，这可能是每 24 小时一次）。

我决定通过让消费者在连接时发布到“在线”频道来解决这个问题。我现在需要 pubnub 源脚本来收听这个频道。我已经尝试将以下内容添加到脚本中，它不再抛出错误，但实际上并没有响应消息。它成功地加入了通道层，但消息处理程序(receive_json)永远不会触发。

from channels.generic.websocket import JsonWebsocketConsumer


class channelConsumer(JsonWebsocketConsumer):

    def __init__(self):
        self.channel_name = 'source'
    def join(self):
        async_to_sync(channel_layer.group_add)('presence', self.channel_name)
    def receive_json(self, message):
        print("Presence Detected")
        # do some stuff

进一步在代码中：

global channel_layer
channel_layer = get_channel_layer()

global listener
listener = channelConsumer()
listener.join()

正如我所说，没有明确的错误，它似乎永远不会触发receive_json。肯定有数据包被发布到“存在”，所以问题肯定在下面的代码中。

Answer 1

为了让消费者接收消息，该消费者需要插入路由器。最常见的情况是使用 URLRouter，其中消费者将从连接（例如 Web 套接字）接收事件。

您可以使用 ChannelNameRouter 创建一个将侦听特定 Chanel 的使用者。例如，消费者可以是：

from channels.consumer import SyncConsumer
class ChannelConsumer(SyncConsumer):
    def __init__(self, *args, **kwargs):
        super().__init__(*args, **kwargs)

    def post_save(self, event):
        print("POSTSAVE", event)

然后在你的路由器定义上

from channels.routing import ProtocolTypeRouter, URLRouter,ChannelNameRouter
application = ProtocolTypeRouter({
    "websocket": TokenAuthMiddlewareStack(
        URLRouter([
            url(r"^.*$", RestConsumer),
        ]),
    ),
    "channel":ChannelNameRouter({
        "signals": ChannelConsumer,
    })

})

现在您可以向该消费者发送消息

from channels.layers import get_channel_layer
channel_layer = get_channel_layer()
async_to_sync(channel_layer.send)("signals", {"type": "post.save", "message":"Hello Consumer"})

针对您的情况，如果您希望多个通道接收消息，您还需要将“信号”通道添加到您要使用的组中。

请注意，如果您使用 ChannelNameRouter，则需要启动将处理它的工作程序。

./manage.py runworker signals