我有一个龙卷风应用程序,它将通过 websocket 提供数据。我有一个单独的阻塞线程,它正在从另一个应用程序读取输入并将一个对象推送到队列中,另一个线程具有该队列的阻塞侦听器。
我想要的是阅读器线程在看到队列中的新项目时以某种方式向龙卷风发送消息,然后龙卷风可以通过 websocket 将其中继到侦听客户端。
我能想到的唯一方法是在阅读器线程中有一个 websocket 客户端,并通过 websocket 将信息推送到龙卷风。然而,似乎我应该能够在不使用 websocket 的情况下做到这一点,并且以某种方式让 tornado 监听非 websocket 异步事件,然后调用回调。
但我找不到任何描述如何做到这一点的东西。