jvm 用の軽量の分散単一プロデューサー、複数コンシューマー メッセージ サービスを探しています。プロデューサーと同じプロセスでサービスを実行できるようにしたいと考えています。数十のリーダー (せいぜい 100 未満) をサポートする必要があるだけですが、高いスループットを実現できる必要があります。各メッセージは正確に 1 つのコンシューマーに送信する必要があり、どのコンシューマーに送信するかは問題ではありません。制限されたバッファのみが存在し、プロデューサーはバッファがいっぱいになるとブロックする必要があります。利用可能なメッセージがない場合、コンシューマーはブロックする必要があります。プロデューサがデータの終わりを通知し、すべてのコンシューマがデータの終わりのシグナルを受信したらサービスをシャットダウンする方法が必要です。RabbitMQ、ZeroMQ、Kafka などの本格的なメッセージ キューは、このシナリオには適していないようで、他に適切なものは見つかりませんでした。私はScalaライブラリを好みますが、
質問する
802 次
3 に答える
2
Akka はそれをサポートできるはずです - http://akka.io/。
ケストレルもチェックできます - https://github.com/robey/kestrel
于 2013-10-31T07:56:01.680 に答える
0
Redisson libを使用して、Redis に基づく単純な Java PubSub システムを試すこともできます。
于 2015-11-17T15:23:27.217 に答える