Spring AMQP에서 선택적으로 메시지를 소비하는 방법은 무엇입니까?

Question

대기열에서 10K 개체를 밀어 넣었습니다. 타임 스탬프는 객체의 속성 중 하나입니다. 그렇다면 spring amqp를 사용하여 소비자 코드를 작성하려면 어떻게해야합니까?

누구든지이 문제에 대해 도움을 줄 수 있습니다.

Answer 1

AMQP는 JMS와 달리 소비자를위한 메시지 선택 개념이 없습니다. 한 가지 해결책은 주제 교환을 사용하고 라우팅 키를 설정하는 것입니다. 소비자 1은 foo.bar으로 교환에 자신의 대기열을 바인드하고 두 번째 것은 foo.baz과 바인딩합니다. 세 번째는 foo.*으로 묶입니다. 세 번째는 모든 메시지를받습니다 (foo로 시작하는 라우팅 키 사용). 다른 사람들은 각각의 키를 가지고 메시지를받습니다.

직접 교환도 사용할 수 있습니다. 라우팅 키에 대한 완전한 일치가 필요합니다.

더 많은 질문을하기 전에 다른 교환 유형을 이해하기 위해 모든 RabbitMQ tutorials을 검토해야합니다.