基于 ZeroMQ 的分布式系统

Question

在具有以下数据流的分布式系统中：

1. 客户端为分布式系统中的随机节点发送消息。
2. 节点检查操作是否可以由他执行。如果不是，则将消息发送到其他节点。然后这个过程一直持续到正确的节点。

所以系统有如下流程：

client -> nodeX -> nodeY -> nodeZ

如果我想向客户端（从 nodeX）发送 OK 信号，进程是否会使用 ZeroMQ 阻塞？

谢谢！

Answer 1

通常zmq_send不会阻塞，但也有可以阻塞的情况 请参阅概述 here ，这取决于您使用的套接字类型。

如果您要发送到的节点无法到达/读取缓慢/网络速度慢或传输等，消息将排队。您可以设置消息队列时发生的情况的阈值（消息尚未传递）达到一定大小，该阈值称为 ZMQ_HW。

ZMQ_HW消息排队时zmq_send()是阻塞还是丢弃消息，你可以在上面提到的zmq_socket文档中看到。