zmq_connect() 一个套接字，同时等待 zmq_send() 或 zmq_recv()

Question

我正在开发一个应用程序，我想使用 ZeroMQ 连接不同类型的节点，这些节点可以在系统运行时添加和删除。这意味着我想在节点来来去去时随时调用zmq_connect() 或zmq_disconnect()。

一些连接使用ZMQ_REQ 类型的套接字，当没有可用的对等点时阻塞。因此，可能会发生一个节点在 zmq_recv() 中被阻塞，而没有任何节点可用于处理请求。如果那时有一个新节点可用，我想使用 zmq_connect() 连接套接字。我能看到如何做到这一点的唯一方法是从不同的线程调用 zmq_connect() 。但是文档非常清楚地指出，zmq_socket 实例不能同时从多个线程中使用。

我该如何解决这个问题，在ZMQ_REQ 套接字上发送没有任何连接（或无法建立的连接）的消息，然后添加连接并处理等待的请求？

Answer 1

当没有消息准备好时，您不应使用zmq_recv()。这样你就可以避免阻塞你的线程。而是检查是否确实有要接收的消息。实现这一点的最简单方法是使用poller。由于您没有说明您使用的是哪种库或语言，我无法为您提供正确的示例，但我想 ZeroMQ 指南示例here 中的 C 示例可能有用。

根据我的经验，构建基于 ZeroMQ 的应用程序最有效的方法是构建一个线程节点来响应消息，并在必要时根据时间间隔运行方法。

对于像你所说的那样构建一个系统，我建议你看看很棒的ZeroMQ Guide 的Service Discovery 章节。