ZeroMQ 在节点之间创建消息缓冲区

zeromq create messages buffer between nodes

本文关键字:消息 缓冲区 创建 之间 节点 ZeroMQ      更新时间:2023-10-16

我需要一种无代理模式来读取和写入节点之间的消息,而无需从队列中删除任何消息,直到某些监视系统接受删除消息。

我可以用 zeroMQ 做到这一点吗?,在 zmq 中,如果一个发布方节点死亡,网络上排队的消息也消失了? 如何将此队列保存在网络中!!

(我想发送一条消息,其中包含发布者和订阅者阅读消息,但在我的 Qos 监视器将其从阵列中删除之前,不要将其从队列中删除。如果我的发布者死亡消息队列用它创建,则不应删除。

我可以使用 zmq 中的当前模式实现这些功能吗?)

您必须在应用程序中构建该级别的冗余/可靠性,而不是依赖 ZMQ 来提供它。

这意味着您必须在发布方节点上跟踪所有消息,然后订阅者节点应该能够回传达它已收到消息,从而允许发布方节点删除其缓存。 这意味着很可能有多个套接字,除非您真的想尝试让 XPUB/XSUB 以这种方式进行通信,但这似乎不是理想的选择。

如果您需要在通信库中更直接地支持某些内容,那么 ZMQ 不会为您削减它......但我怀疑你也会找到其他东西。