JVM的輕量級分佈式單生產者多消費者消息服務

Question

我正在尋找jvm的輕量級分佈式單生產者多消費者消息服務。我希望服務能夠像生產者一樣運行。它只需要支持10個讀取器（最多可能是100個）， ，但它需要能夠具有高吞吐量。每個消息都需要轉到一個消費者，而哪個消費者並不重要。 應該只有一個有界的緩衝區，生產者應該阻止緩衝區已滿。 如果沒有消息可用，消費者應該阻止。 生產者應該有一種方式告知數據結束 並在所有消費者收到數據信號結束後關閉服務。 像RabbitMQ，ZeroMQ &完全成熟的消息隊列似乎不適合這種情況下，我還沒有發現任何其他的東西。我更喜歡Scala庫，但是任何JVM語言都可以。

Answer 1

Akka應該能夠支持 - http://akka.io/。
您還可以檢查出紅隼 - https://github.com/robey/kestrel

Answer 2

您也可以嘗試基於Redis的與Redisson簡單的Java PubSub的系統庫

Answer 3

你一定要看看阿卡流。他們以最優雅的方式使用背壓來支持有界的緩衝區。