我正在使用ZeroMQ发布 - 订阅套接字来连接两个进程.发布过程是一个传感器,刷新率比订阅过程快得多.我希望订阅过程只使用队列中的最新消息 - 并完全忽略旧消息.
我尝试在订阅者身上设置一个高水位标记,但这似乎会删除较新的消息而不是较旧的消息.
是否有人可以指导我为此目的的发布 - 订阅模式？
publish-subscribe zeromq
publish-subscribe ×1
zeromq ×1