在 Django Channels 中重用现有的 websocket

Question

我正在半认真地使用 Python 来在受限访问系统和 GAE 应用程序之间创建一种网守服务器。我将从一个更一般的问题开始，然后可能会转到与代码相关的特定问题。

概述

受限访问系统设置有一个命令行 Python 应用程序，该应用程序打开一个与运行在中间服务器上的 Django Channels 应用程序的 WebSocket 连接，并开始发送常规的心跳帧，Django 应用程序对此进行确认。到目前为止，一切都很好。 时不时地，Django 应用程序会收到一个 HTTP 请求，它会验证它，如果它通过，它会向其他系统发送一条指令。现在，为了提高效率，我有了重新使用现有 WS 连接并在其上搭载指令框架的想法。

问题

Django 允许我轻松地接收套接字上的帧，并对所述帧进行操作。我遇到的问题是通过现有管道发送一条消息：我无法终生调用 WebsocketConsumer.send() 方法，即使是通过包装器，也不能从 not 在消费者，但在其他地方定义并接收消费者作为参数（到目前为止我能想到的最好的）。甚至可能（this question 指出它实际上不可能是可能的）？

提前感谢您的任何指点。如果需要，明天我可以用我的课程更新问题。

Answer 1

也许已经太晚了，但您需要做的是直接向应用程序正在收听的频道或组发送消息。通道会将您的消息路由到适当的消费者方法。

因此，假设您想在为您的其他应用程序提供服务的消费者中调用 send_message 方法（例如 channel1）：您应该这样做：

from channels.layers import get_channel_layer
from asgiref.sync import async_to_sync

channel_layer = get_channel_layer()
sync_to_async(channel_layer.send)("channel1", {
    "type": "send.message",
    "text": "Hello there!",
})

这可以在代码中的任何位置完成。

您链接的问题使用与 Django 频道完全不同的龙卷风 websockets。我不知道是否可以使用龙卷风，但绝对可以，使用频道