是否有某种规范或其他解释描述了正常情况,在这种情况下,对于每种通信类型,您可以预期ZeroMQ套接字上发送的消息不会被(所有)侦听进程接收？
例如,我有一个实验程序,它基本上假设PUB套接字的所有订阅者都接收在该套接字上发送的所有消息(在初始化握手之后).我想了解这种假设可能是错误的情况.谢谢,对不起,如果已经问过这个问题.
我已经看到了几个关于此的问题,但没有一个我得到满意的答案.这个问题,zeromq模式:具有保证传递的pub/sub是类似的,尽管我愿意使用任何其他zeromq机制来实现相同的效果.
我的问题是,有没有办法像ZeroMQ中的发布者订阅者一样以扇出模式发送消息,并确保消息将被传递？似乎一个零拷贝的经销商可以做到这一点,但它会比pub-sub更麻烦.有更好的选择吗？除了必须编写更多代码之外,这样做有什么缺点？
需要这个的原因:
我正在编写一个代码来分析来自仪器的数据.连接到仪器的模块需要能够将数据广播到其他模块以供它们分析.反过来,他们需要将分析的数据广播到输出模块.
乍一看,使用ZeroMQ的pub-sub看起来非常适合这项工作,但如果任何用户放慢速度并达到高水位,则消息会被丢弃.在该系统的情况下,由于事件的连续性,仅在一小部分模块上丢弃消息是不可接受的.所有模块都需要分析事件以使输出有意义.但是,如果没有模块收到事件的消息,那就没问题了.因此,如果其中一个分析模块达到了高水位,则可以阻止发布者(仪器模块).
我认为另一个替代方案是在事后处理错过的消息,但这只会浪费处理时间以后将被丢弃的事件.
编辑:我想进一步考虑这个,我目前期望发送消息=消息传递,因为我正在使用inproc并在线程之间进行通信.但是,如果我通过tcp发送消息,即使ZeroMQ没有故意丢弃它,也有可能丢失消息.这是否意味着即使我使用阻止发送,我可能还需要处理丢弃的消息？是否有关于使用inproc进行消息传递的保证？