c++ - 一段时间后 zmq 套接字不工作

Question

我有一个程序，在客户端有一个 ZMQ_SUB 套接字，在服务器端有一个 ZMQ_PUB 套接字，客户端订阅服务器:

非常简单的代码:

客户端:

zmq::socket_t subscriber(context, ZMQ_SUB);     
subscriber.connect("tcp://xxx:xxx");    
subscriber.setsockopt(ZMQ_SUBSCRIBE, "", 0);

服务器端:

zmq::socket_t publisher(zmqContext, ZMQ_PUB);
publisher->bind("tcp://*.xxx");

我在客户端和服务器之间使用了另一对 ZMQ_REQ、ZMQ_REP 套接字。每次客户端通过 ZMQ_REQ 套接字向服务器发送一些请求，服务器通过 ZMQ_REP 套接字接收它，做一些工作，通过 REP 套接字响应，同时生成一堆消息，并通过 ZMQ_PUB 发布它们 socket 。

大多数时候，客户端能够从 ZMQ_SUB 套接字接收消息，但我确实遇到过客户端无法接收到这些消息的情况。

消息保证在服务器端生成，并在生成后立即发布。

这正常吗？或者我的使用/设置有问题，导致这种不确定的行为。 (客户端 SUB 套接字有时收不到消息)

Answer 1

是否正常？

这样的问题很容易被问到，但在没有其他细节和上下文可用的情况下很难得到答案。

ZeroMQ 伟大的 Pieter HINTJENS 的书 “Code Connected Volume 1” 中的 “Missing Message Problem” 章节说了一些 关于这个主题的一般原则:

---

• 在SUB 套接字上，使用zmq_setsockopt() 和ZMQ_SUBSCRIBE 设置订阅，否则您将收不到消息。因为您是通过前缀订阅消息的，所以如果您订阅 ""(空订阅)，您将获得所有内容。

• 如果在 PUB 套接字开始发送后启动 SUB 套接字(即建立到 PUB 套接字的连接)数据，您将丢失在建立连接之前发布的所有内容。如果这是一个问题，请设置您的体系结构，以便 SUB 套接字首先启动，然后 PUB 套接字开始发布。

• 即使您同步SUB 和PUB 套接字，您仍然可能会丢失消息。这是因为在实际创建连接之前不会创建内部队列。如果您可以切换 bind/connect 方向，那么 SUB 套接字 bind-s 和 PUB socket connect-s，您可能会发现它的工作方式更符合您的预期。

• 如果您正在使用 REP 和 REQ 套接字，并且您没有坚持同步 send/recv /send/recv命令，ØMQ会报错，你可能会忽略。然后，看起来您正在丢失消息。如果您使用 REQ 或 REP，请坚持 send/recv 顺序，并且始终在实际代码中，检查 ØMQ 调用的错误。

• 如果您使用PUSH 套接字，您会发现第一个连接的PULL 套接字将获取不公平的消息份额。消息的准确轮换仅在所有 PULL 套接字都成功连接时发生，这可能需要几毫秒。作为 PUSH/PULL 的替代方案，对于较低的数据速率，请考虑使用 ROUTER/DEALER 和负载平衡模式。

• 如果您要跨线程共享套接字，不要。它会导致随机异常和崩溃。

• 如果您正在使用 inproc，请确保两个套接字都在相同的 context 中。否则连接方实际上会失败。另外，先bind，然后connect。 inproc 不是像 tcp 这样的断开连接的传输。

• 如果您使用ROUTER 套接字，很容易意外丢失消息，方法是发送格式错误的标识帧(或忘记发送 标识帧)。一般来说，在 ROUTER 套接字上设置 ZMQ_ROUTER_MANDATORY 选项是个好主意，但也要检查每个 send 调用的返回码。

• 最后，如果您真的无法找出问题所在，制作一个可重现问题的最小测试用例，并向 ØMQ 社区寻求帮助。