Doc*_*awk 2 publish-subscribe zeromq
我正在使用ZeroMQ发布 - 订阅套接字来连接两个进程.发布过程是一个传感器,刷新率比订阅过程快得多.我希望订阅过程只使用队列中的最新消息 - 并完全忽略旧消息.
我尝试在订阅者身上设置一个高水位标记,但这似乎会删除较新的消息而不是较旧的消息.
是否有人可以指导我为此目的的发布 - 订阅模式？
从zeromq的文档中了解conflate功能(这是一种新的),我认为这正是你想要的.
从文档:
ZMQ_CONFLATE:仅保留最后一条消息如果设置,套接字应在其入站/出站队列中只保留一条消息,此消息是最后一条消息/最后一条消息要发送.忽略'ZMQ_RCVHWM'和'ZMQ_SNDHWM'选项.不支持多部分消息,特别是,它只有一部分保留在套接字内部队列中.