ZeroMQ:我希望发布-订阅删除旧消息以支持新消息

标签 zeromq publish-subscribe

我正在使用 ZeroMQ 发布订阅套接字来连接两个进程。发布过程是一个传感器,刷新率比订阅过程快得多。我希望订阅过程只使用队列中的最新消息——并完全忽略旧消息。

我试过在订阅者上设置一个高水位标记,但这似乎会丢弃较新的消息而不是较旧的消息。

是否有人可以为此目的指导我使用发布 - 订阅模式?

最佳答案

documentation on zeromq 阅读有关合并功能的信息(这是一种新的),我认为这正是您想要的。

从文档:

ZMQ_CONFLATE: Keep only last message If set, a socket shall keep only one message in its inbound/outbound queue, this message being the last message received/the last message to be sent. Ignores 'ZMQ_RCVHWM' and 'ZMQ_SNDHWM' options. Does not support multi-part messages, in particular, only one part of it is kept in the socket internal queue.

关于ZeroMQ:我希望发布-订阅删除旧消息以支持新消息,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/25940962/

相关文章:

node.js - ZMQ安装失败

c++ - 是否可以在通过 UDP 发送数据时将数据流式传输到 ZeroMQ 消息中?

c++ - 如何对多个Server-Client对使用ZeroMQ?

RabbitMQ重新排序消息

python - 如何在 Python 中使用套接字创建 channel

python - 如何在 zmq 的推/拉模式中设置 hwm?

c# - Zeromq - bytearray(来自.net服务器)到java中的字符串

jquery - 如何使用 jQuery .subscribe()?

javascript - Meteor 文档中的消息计数示例如何工作?

jms - 我们可以在发布/订阅消息传递中使用请求/回复模型吗?