我正在使用 ZeroMQ 发布-订阅套接字来连接两个进程。发布过程是一个传感器,刷新率比订阅过程快得多。我希望订阅过程仅使用队列中最新的消息,并完全忽略较旧的消息。
我尝试为订阅者设置高水位线,但似乎有所下降newer消息而不是旧消息。
是否有人可以指导我为此目的采用发布-订阅模式?
阅读有关合并功能的信息关于 ZeroMQ 的文档(这是一种新的),我认为这正是你想要的。
从文档中:
ZMQ_CONFLATE:仅保留最后一条消息
如果设置,套接字应仅保留
入站/出站队列中的一条消息,该消息是最后一条消息
收到的消息/要发送的最后一条消息。忽略“ZMQ_RCVHWM”并且
“ZMQ_SNDHWM”选项。不支持多部分消息,在
特别是,只有一部分保存在套接字内部队列中。
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)