java - 使用 ZMQ 均匀分布

Question

我在我的 Centos 中使用 Zmq。我的任务是使用 ZMQ 编写一个 Java 程序，该程序将有一个生产者和多个消费者。如果一个生产者发送 100 条消息，并且有四个消费者，那么所有消费者必须每人共享 25 条消息。我怎样才能做到这一点。

Answer 1

我自己已经找到了方法。我们必须使用代理来解决这个问题，并且代理必须有两个用于前端和后端连接的套接字。然后在 ZMQ 中有几个可用的类，如 streamer、queue 和 forwarder。我们可以通过将上下文、前端、后端作为构造函数的参数来为这个类创建对象。只需通过调用 run 方法让代理等待。

Answer 2

你可以更简单地做到这一点；如果 Socket 类型具有循环的传出策略（PUSH、REQ、DEALER），如果所有端点都连接，则可以假设工作将均匀分布。如果您这样选择，您可以避免使用经纪人。