我正在使用 ZeroMQ 发布-订阅套接字连接两个进程。发布过程是一个传感器，刷新率比订阅过程快得多。我希望订阅过程只使用队列中的最新消息，而完全忽略旧消息。
我尝试在订阅者上设置高水位标记，但这似乎会丢弃较新的消息而不是较旧的消息。
是否有人可以为此目的指导我采用发布-订阅模式？
【问题讨论】：
从documentation on zeromq 了解合并功能（这是一种新功能），我认为这正是您想要的。
来自文档：
ZMQ_CONFLATE：只保留最后一条消息 如果设置，套接字应仅保留 入站/出站队列中有一条消息，此消息是最后一条 收到的消息/要发送的最后一条消息。忽略“ZMQ_RCVHWM”和 'ZMQ_SNDHWM' 选项。不支持多部分消息，在 特别是，只有一部分保留在套接字内部队列中。
【讨论】：
好的，我找到了一个解决方案，但我不知道它是否是最好的 - 所以我暂时不会将其标记为正确。
zmq::message_t message;
int events = 0;
size_t events_size = sizeof(int);
// Priming read
subscriber.recv(&message);
// See if there are more messages to read
subscriber.getsockopt(ZMQ_EVENTS, static_cast<void*>(&events), &events_size);
while (events & ZMQ_POLLIN) {
// Receive the new (and perhaps most recent) message
subscriber.recv(&message);
// Poll again for additional messages
subscriber.getsockopt(ZMQ_EVENTS, static_cast<void*>(&events), &events_size);
}
// Now, message points to the most recent received data.
此策略的另一个优点是队列不应该填满。缺点是我的发布者发送的速度可能比订阅者中的这个循环运行的速度更快，然后它会无限循环。
这似乎不太可能，但我想让它变得不可能。我还不太清楚如何实现这个目标。
【讨论】：