ZeroMQ推流/拉流:没有拉流客户端时如何管理队列？

Question

当我的拉取客户端关闭时，有没有办法管理推送服务器上的队列堆积？

我想在这种情况下实现一个封顶的FIFO消息队列。

(我使用的是Node.js)

谢谢！

Answer 1

这基本上就是ZMQ套接字的工作方式，通过High Water Mark的方式。如果我没记错的话，默认设置为1000。您可以使用setsocketopt来管理它(详细信息在链接中，在节点ZMQ绑定文档和测试中非常简单)。

它会将消息排到高水位线，然后开始丢弃您试图添加到堆栈中的任何新消息。