我正在尝试做一些看似简单的事情,但我不知道该怎么做......
我有一个通过 ZMQ PUB 套接字发布消息的应用程序。我想编写一个小型服务器来订阅这些更新并将它们广播到所有连接的 websocket 客户端。
这表面上看起来很简单,但是我不知道当通过订阅接收到数据时如何在扭曲反应器中触发事件。我知道 ZMQ 也有一个 ioloop,但它与扭曲的不一样......
解决这个问题的最佳方法是什么?我不必使用twisted,如果可以更好地处理这个问题,其他一些python框架会做(rpclib?)