ZeroMQ 在节点之间创建消息缓冲区
zeromq create messages buffer between nodes
我需要一种无代理模式来读取和写入节点之间的消息,而无需从队列中删除任何消息,直到某些监视系统接受删除消息。
我可以用 zeroMQ 做到这一点吗?,在 zmq 中,如果一个发布方节点死亡,网络上排队的消息也消失了? 如何将此队列保存在网络中!!
(我想发送一条消息,其中包含发布者和订阅者阅读消息,但在我的 Qos 监视器将其从阵列中删除之前,不要将其从队列中删除。如果我的发布者死亡消息队列用它创建,则不应删除。
我可以使用 zmq 中的当前模式实现这些功能吗?)
您必须在应用程序中构建该级别的冗余/可靠性,而不是依赖 ZMQ 来提供它。
这意味着您必须在发布方节点上跟踪所有消息,然后订阅者节点应该能够回传达它已收到消息,从而允许发布方节点删除其缓存。 这意味着很可能有多个套接字,除非您真的想尝试让 XPUB/XSUB 以这种方式进行通信,但这似乎不是理想的选择。
如果您需要在通信库中更直接地支持某些内容,那么 ZMQ 不会为您削减它......但我怀疑你也会找到其他东西。
相关文章:
- 在 capnp FlatArrayMessageReader 的对齐内存缓冲区中接收 zmq 消息
- 协议缓冲区ParseFromString不检查消息结尾
- 应该如何读取堆缓冲区溢出错误消息?
- TCP 缓冲区中的多条消息
- 协议缓冲区#3将消息从c ++发送到c#
- 将二进制数据缓冲区存储在协议缓冲区消息中
- 如何将消息发送到缓冲区并反向打印前三个单词的消息
- Android如何确定logcat消息使用哪个缓冲区
- 如何将多个协议缓冲区的消息写入可附加的压缩文件中?
- C++中的Google协议缓冲区:从现有结构中创建消息
- 协议缓冲区-读取所有消息中通用的标头(嵌套消息)
- 解析来自固定大小字节缓冲区的连续块的protobuf消息序列
- 在调试模式下销毁协议缓冲区消息几乎比在发布模式下慢 500 倍
- 如何在套接字编程中发送长度大于缓冲区的消息
- ZeroMQ 在节点之间创建消息缓冲区
- 在 c++ 中使用消息结构读取/填充数据缓冲区的正确方法是什么?
- 在外部消息中包括预编码的协议缓冲区消息
- winsock,面向消息的网络,以及从recv中类型转换缓冲区
- 如何在协议缓冲区中设置嵌套消息的字段
- 是否可以使用 Varint32 大小前缀的协议缓冲区消息实现类似"FileInputStream::BackUp()"的功能?