【发布时间】:2012-01-02 23:13:10
【问题描述】:
我正在实现一个消息传递系统,其中称为代理的外部程序能够通过 ZeroMq 生产者进行通信。因此,每次发生感兴趣的事件时,代理都会向 ZeroMq 发送一条消息。
我有兴趣使用管道模式来实现它。
我找到了一些示例(Ventilator-Worker-Results Manager),但是 Ventilator 组件创建了一个端点来接受来自工作人员的连接,然后批量发送所有消息。
我的情况完全不同。每次需要发送事件时,“代理”都会连接 - 它不等待来自工作人员的连接,所以我想知道这是否可能?此外,重要的事实是消息必须按发送顺序进行处理。
【问题讨论】: