zeromq - 无丢失关闭ZeroMQ接收端

Question

我正在开发一个 (Python/pyzmq)) ZeroMQ 服务器，它通过一个 PULL 套接字接收传入的消息。

现在，有时我会彻底重启服务器以升级它。我的问题是； 我能否以某种方式停止接收传入消息(在我的 PULL 套接字上)，以便重新启动不会丢失任何消息？ 我正在考虑打电话之类的事情 close()没有 socket ，然后 recv()最后一条消息。可能将高水位标记设置为零会产生类似的结果。

如果上述解决方案都不起作用，我最好将我的套接字转换为 REP 套接字并逐个获取每条消息，每次都 ACK: ing 它们。由于这将是同步的，我想这会更慢。

Answer 1

是的，0mq 本身不会提供这种类型的可靠交付。您肯定应该使用带有 ACK 的方案。

见 Chapter Four - Reliable Request-Reply zguide的。