如何在 JeroMQ 中实现一个主备队列作业处理系统？答案

【问题标题】：How to implement an active & standby queue job-processing system in JeroMQ?如何在 JeroMQ 中实现一个主备队列作业处理系统？
【发布时间】：2017-04-16 01:05:19
【问题描述】：

使用 ZeroMQ .Context 和 .Socket 实例，我可以推送/拉取消息
例如下面我的队列设置代码：

 ZMQ.Context context = ZMQ.context(1);

 //  Socket to send messages on
 ZMQ.Socket sender = context.socket(ZMQ.PUSH);
 sender.bind("tcp://*:5557");

 // Send messages
 sender.send("0", 0);

 ZMQ.Socket receiver = context.socket(ZMQ.PULL);
 receiver.connect("tcp://localhost:5557");

 // receive messages
 String string = new String(receiver.recv(0)).trim();

我的问题是：

Q1：如何在队列中实现主备模式？

我的意思是会有 2 个队列，为一个主机和端口创建，如果一个队列（活动）失败，另一个（即备用）队列将立即启动以侦听/拉取消息。

任何实施它的示例或指导都会更有帮助。

Q2：有没有内置的类来做这种类型的任务？

【问题讨论】：

标签： java sockets zeromq jeromq

【解决方案1】：

你可以实现某种binary start pattern。您的队列需要一个发现服务（在另一对套接字上）来了解彼此的状态。如果我没记错的话，没有标准功能可以制作这样的队列。

【讨论】：