ZeroMQ 推/拉演示

我正在第4章的最后一个项目中，演示了一个使用PUSH/PULL套接字（ZeroMQ）和Node.js集群技术的程序。任务是启动一个由3个工人组成的池，并在它们之间分配30个工作。整个程序可能不到100行代码。主进程应该：

  1. 创建一个PUSH套接字并将其绑定到IPC端点——该套接字用于向工作人员发送作业；

  2. 创建一个PULL套接字并绑定到不同的IPC端点——此端点将接收来自工作人员的消息；

  3. 保持就绪工人的数量（初始化为0）；

  4. 侦听PULL套接字上的消息，如果消息是ready消息，则增加ready计数器；

  5. 如果消息是结果消息，则输出到控制台；

  6. 启动三个工作进程；

  7. 当ready计数器达到3时，通过PUSH套接字发送30个job消息。

每个工作进程应该：

  1. 创建一个PULL套接字并将其连接到master的PUSH套接字；

  2. 接收任务并完成后通过PUSH套接字发送结果回主进程。

总结

该示例演示了如何使用ZeroMQ中的PUSH/PULL套接字模式与Node.js集群一起高效地分配和处理任务，帮助实现分布式工作负载管理。