python - ZeroMQ 管道模式

Question

我正在实现一个消息传递系统，其中称为代理的外部程序能够通过 ZeroMq 生产者进行通信。因此，每次发生感兴趣的事件时，代理都会向 ZeroMq 发送一条消息。

我有兴趣使用管道模式实现它。

我找到了一些例子(Ventilator-Worker-Results Manager)，但是 Ventilator 组件创建了一个端点来接受来自 worker 的连接，然后批量发送所有消息。

我的情况完全不同。每次需要发送事件时，“代理”都会连接——它不会等待工作人员的连接，所以我想知道这是否可能？此外，重要的事实是消息必须按发送顺序进行处理。

Answer 1

您应该混合模式来实现您的解决方案。我认为它应该是 specialized broker它为真正的 REQ 代理实例化 REP 代理收集器。那些代理收集器应该在与系统通信之前处理好订单。