我正在使用带有pubsub的高速公路网络套接字。
我有一个服务，可以获取数据并收集数据并将其放入 Redis 中的主题中
然后，我想收听新消息，然后通过高速公路发布到主题。当函数退出时它工作正常，但是当我将其放入 for 循环中时（不断侦听新的 redis 消息）它不会发布任何内容
我认为这是因为这阻止了反应堆实际发布数据。Iv尝试调查deferToThread，但这不起作用。
我想知道有没有人知道我基本上如何在一段时间内将数据发布到高速公路主题。
谢谢
你可以在
后台线程上的阻塞循环中连接到 Redis，deferToThread Twisted 中可以做到这一点的一种方法，但这只是故事的一半：另一半是使用 callFromThread 调用在主线程上运行的 Autobahn 发布/调度。
您可以在此处阅读更多内容：http://twistedmatrix.com/documents/13.2.0/core/howto/threading.html