使用ZMQ的均勻分佈

Question

我在我的Centos中使用Zmq。我的任務是使用ZMQ編寫一個java程序，它將有一個生產者和多個消費者。如果生產者發送100條消息並且有四個消費者，則所有消費者都必須共享25條消息。我怎樣才能做到這一點。

Answer 1

我自己找到了方法。我們必須使用經紀人來解決這個問題，經紀人必須擁有兩個用於前端和後端連接的套接字。然後在ZMQ中有幾個類可用，如流媒體，隊列和轉發器。我們可以通過傳遞上下文，前端，後端作爲構造函數的參數來爲這個類創建對象。通過調用run方法讓代理等待。

Answer 2

你可以更簡單地做到這一點;如果一個Socket類型有一個傳出策略（PUSH，REQ，DEALER），如果所有端點都已連接，則可以假定工作將均勻分配。如果你這樣選擇，你可以避免使用經紀人。