使用zmq(zeromq)检测慢速阅读器

Question

我正在尝试更换一个小的本土消息传递系统,并且正在玩zmq.我将需要检测慢速读取器,并启动/断开它们 - 慢速读取器几乎意味着特定的消费者队列大小超过某个阈值.

到目前为止,似乎zmq会阻止每个消费者,如果其中一个消费者有点慢(足够公平) - 但我找不到任何方法来检测潜在的慢消费者.任何人都有任何经验,如何使用zmq - 或者有任何其他无经纪人的消息传递系统来重新推荐？

Answer 1

从 Zeromq-2.0.7 开始，您可以ZMQ_HWM在ZMQ_PUB套接字上设置选项来控制订阅者可以排队的最大消息数。一旦达到高水位线，发往该订阅者的所有其他消息都将被丢弃，直到队列大小回落到高水位线以下。这限制了专用于所谓的慢速读取器的内存量。

但是，由于 ZeroMQ 库公开套接字而不是客户端，因此您无法在不修改库本身的情况下识别并强制断开不需要的客户端。