我正在为jvm寻找一个轻量级的分布式单 生产环境 者多消费者消息服务 . 我希望该服务能够在与 生产环境 者相同的过程中运行 . 它只需要支持10个读卡器（最多可能低100个），但它需要能够具有高吞吐量 . 每条消息都需要只发送给一个消费者，哪个消息无关紧要 . 应该只有一个有界缓冲区， 生产环境 者应该阻止缓冲区已满 . 如果没有可用消息，消费者应该阻止 . 一旦所有消费者都收到数据信号的结束， 生产环境 者应该有一种方法来发出数据结束信号并关闭服务 . 像RabbitMQ，ZeroMQ和Kafka这样的全面消息队列似乎不适合这种情况，我还没有找到其他任何东西 . 我更喜欢Scala库，但任何JVM语言都可以 .
3 回答
Akka应该能够支持--http://akka.io/ .
你也可以看看红隼 - https://github.com/robey/kestrel
你一定要看看Akka Streams . 它们使用背压以最优雅的方式支持有界缓冲区 .
您也可以使用Redisson lib尝试基于Redis的简单java PubSub系统