我在Centos中使用Zmq。我的任务是使用ZMQ编写一个java程序，该程序将有一个生产者和多个消费者。如果一个生产者发送100条消息，并且有四个消费者，则所有消费者必须每个共享25条消息。我该怎么做。
我自己找到了路。我们必须使用代理来解决这个问题，并且代理必须有两个用于前端和后端连接的套接字。然后在ZMQ中有几个类可用，如拖缆、队列和转发器。我们可以通过传递上下文、前端和后端作为构造函数的参数来为此类创建对象。只需通过调用run方法让代理等待即可。
您可以更简单地做到这一点；如果一个Socket类型有一个舍入的传出策略（PUSH、REQ、DEALER），如果所有端点都连接了，则可以假设工作将均匀分布。如果你这样选择，你可以避免使用经纪人。