RabbitMQ - 주제 교환 - 두 명 이상의 소비자가 같은 주제

Question

AMQP에 nmew이고 RabbitMQ 시스템의 알림 아키텍처를 해결하려고합니다.

토픽 교환 (NotificationsExchange, 추측 해 봅시다)을 원합니다. 특히 토픽 교환과 함께 제공되는 라우팅 키 및 대기열과 향후 확장을위한 옵션에 대한 유연성이 필요하기 때문입니다. 왜냐하면 나는 틀릴 수도 있습니다. 왜냐하면 ...

두 명 이상의 소비자가 각 알림을 사용하기를 원합니다. 기준선으로 게시 된 각 알림을 데이터베이스에 저장하려고합니다. 또한 각 알림을 클라이언트 응용 프로그램 (예 : 웹 응용 프로그램이 DB 폴링없이 즉각적인 사용자 알림을 사용하고 소켓을 통해 밀어 넣을 수 있음)에 의해 소비되기를 원합니다.

이것은 실제로 다양한 아웃 (AMQP에 익숙하지 않고 내 감싸기를 시도하는 것 같아요.)라고 생각합니다. 머리 주위에).

두 명의 소비자가 같은 대기열에서 (일관되게) 알리도록 할 수 있습니까?

예를 들어

다음 NotificationExchange 통해

• 밀어 Notif.NotifGroup.User.ThisUser
• 가지고 dbListener 바인드 Notif.#에
• 또한 Notif.# 결합 (추가 사용자가 온라인인지 확인하고 소켓을 통해 다운 스트림 밀어) mvcClientListener 되세요

나는 올바른 길을 가고 있는지 잘 모르겠다. 이자형. 나는 "동일한 대기열에있는 여러 소비자가로드 로빈 방식으로 균형을 이룬다"는 것을 읽고 있으며 솔직히 말해서 그 의미가 무엇인지 알지 못합니다.

2 명의 소비자가 동일한 대기열 (예 : 동일한 라우팅 키)에서 동일한 메시지를 일관되게 읽을 수있는 주제 교환을 할 수 있습니까? 아니면이를 위해 팬 아웃 교환을해야합니까?

감사합니다.

Answer 1

두 명의 소비자가 같은 대기열에서 (일관되게) 알림을받을 수 있습니까?

예,하지만 원하는 것은 아닙니다.

하나의 큐에 여러 소비자가있는 경우 소비자는 라운드 로빈 부하가 분산됩니다. 소비자 1이 메시지 a를 수신하면 소비자 2는 대신

을받을 수 없으므로 각 소비자에 대해 경로 처리기를 추가하고 각 소비자가 자신의 대기열을 만들게하십시오.

예를 들어, NotificationEx은 에 대한 바인딩이 dbQueue으로 푸시 될 수 있습니다. 동일한 교환 프로그램은 에 대한 바인딩을 사용하여 메시지를 mvcQueue으로 푸시합니다.

데이터베이스 사용자가 dbQueue에서 소모되고 웹 응용 프로그램이 mvcQueue에서 소모됩니다.

이렇게하면 새 대기열을 추가하고 각 대기열과 교환기에 바인딩하는 것이 매우 쉽습니다.

---

FWIW에는 주어진 상황에 대해 "올바른"또는 "잘못된"교환 유형이 없습니다. 어떤 상황에서도 교환 유형을 사용할 수 있습니다. 그러나 일부 교환 유형을 사용하면 특정 상황을 쉽게 처리 할 수 ​​있습니다.

는 당신은 그들이 오히려 흥미로운 시나리오에서 어떻게 적용될 수 있는지, 교환 유형, 자신의 일반적으로 인정 된 "최고의 사용 사례"에 대한 자세한 내용은 RabbitMQ 내 전자 책을 확인 할 수 있습니다

: https://leanpub.com/b/rmq-layout-and-patterns