2
jvm에 대한 경량 분산 단일 제작자 다중 소비자 메시지 서비스를 찾고 있습니다. 나는 서비스가 생산자와 같은 과정에서 운영 될 수 있기를 바란다. 그것은 단지 10s의 리더 (어쩌면 100 이하일 수도 있음), 을 지원할 필요가 있지만 높은 처리량을 가질 수 있어야합니다. 각 메시지는 정확하게 하나의 소비자에게 전달되어야하며 어느 메시지가 중요하지 않습니다. 제한된 버퍼 만 있어야하며 제작자는 버퍼가 가득 찬 것을 차단해야합니다. 메시지를 사용할 수없는 경우 소비자가 차단해야합니다. 생산자가 데이터 의 신호를 보내고 모든 소비자가 데이터 신호의 끝을 받으면 서비스를 종료하는 방법이 있어야합니다. RabbitMQ, ZeroMQ & 카프 카 (Kafka)와 같은 완전한 메시지 대기열은이 시나리오에 적절하지 않은 것으로 보이며 그 밖의 것을 찾지 못했습니다. 나는 스칼라 라이브러리를 선호하지만, JVM 언어는 괜찮다.JVM 용 경량 분산 단일 제작자 다중 소비자 메시지 서비스