我正在实现一个消息系统,其中称为代理的外部程序能够通过ZeroMq生产者进行通信.因此,每次感兴趣的事件发生时,代理都会向ZeroMq发送消息.
我有兴趣使用管道模式实现它.
我找到了一些示例(Ventilator-Worker-Results Manager),但Ventilator组件创建了一个端点,用于接受来自worker的连接,然后批量发送所有消息.
我的情况完全不同.每次需要发送事件时,"代理"都会连接 - 它不会等待来自工作人员的连接,所以我想知道这是否可能？此外,重要的事实是必须按照发送消息的顺序处理消息.