zeromq - 在ZeroMQ队列中检测已丢弃的消息

Question

由于似乎无法查询/检查基础ZeroMQ队列/缓冲区套接字以查看它们被利用了多少，因此有什么方法可以检测到何时由于发送/排队时发布者套接字中的缓冲区已满而导致消息被丢弃？

例如，如果发布者队列已满，则zmq_send操作将简单地删除消息。

基本上，我想实现的是一种检测队列压力和/或队列已满的情况的方法，以便能够(以后)调整解决方案以更好地工作。一种替代方法是在每个消息中添加序列号，并在订阅服务器中进行简单的计算，但是我永远不能确定由于发布服务器中的缓冲区已满而导致消息丢失。

Answer 1

在ZeroMQ指南中有一个示例(如果您想愉快地使用0MQ，则应阅读并摘录):http://zguide.zeromq.org/page:all#Slow-Subscriber-Detection-Suicidal-Snail-Pattern

该机制就像您自己回答时一样，在消息中添加序列号，并允许订户检测间隔并采取适当的措施。对于大多数pubsub方案，您可以将默认HWM(即1,000)提高到更高的水平。这取决于您的平均邮件大小。