使用ZMQ的均匀分布

Question

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

Answer 1

我自己找到了方法。我们必须使用经纪人来解决这个问题，经纪人必须拥有两个用于前端和后端连接的套接字。然后在ZMQ中有几个类可用，如流媒体，队列和转发器。我们可以通过传递上下文，前端，后端作为构造函数的参数来为这个类创建对象。通过调用run方法让代理等待。

Answer 2

你可以更简单地做到这一点;如果一个Socket类型有一个传出策略（PUSH，REQ，DEALER），如果所有端点都已连接，则可以假定工作将均匀分配。如果你这样选择，你可以避免使用经纪人。