gpt4 book ai didi

java - JVM 的轻量级分布式单生产者多消费者消息服务

转载 作者:行者123 更新时间:2023-11-30 09:15:50 25 4
gpt4 key购买 nike

我正在寻找用于 jvm 的轻量级分布式单生产者多消费者消息服务。我希望该服务能够与生产者在同一进程中运行。它只需要支持 10 位读者(最多可能低 100 位),但它需要能够具有高吞吐量。每条消息都需要准确地发送给一个消费者,而哪个消费者并不重要。应该只有一个有界缓冲区,生产者应该阻止缓冲区已满。如果没有可用消息,消费者应该阻止。生产者应该有一种方法来发出数据结束信号并在所有消费者收到数据结束信号后关闭服务。完整的消息队列,如 RabbitMQ、ZeroMQ 和 Kafka 似乎不适合这种情况,我还没有发现其他任何适合的消息队列。我更喜欢 Scala 库,但任何 JVM 语言都可以。

最佳答案

Akka 应该能够支持 - http://akka.io/ .
您还可以查看红隼 - https://github.com/robey/kestrel

关于java - JVM 的轻量级分布式单生产者多消费者消息服务,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/19700833/

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com