Temat JMS a kolejki

Zastanawiałem się, jaka jest różnica między kolejką JMS a tematem JMS.

Strona ActiveMQ mówi

Tematy

W JMS Temat implementuje semantykę publikowania i subskrybowania . Kiedy opublikujesz wiadomość, trafi ona do wszystkich zainteresowanych subskrybentów - więc zero dla wielu subskrybentów otrzyma kopię wiadomości. Tylko subskrybenci, którzy mieli aktywną subskrypcję w momencie otrzymania wiadomości przez brokera, otrzymają kopię wiadomości.

Kolejki

Kolejka JMS implementuje semantykę modułu równoważenia obciążenia . Pojedyncza wiadomość zostanie odebrana przez dokładnie jednego konsumenta. Jeśli w chwili wysłania wiadomości nie ma żadnych konsumentów, wiadomość będzie przechowywana do momentu, aż będzie dostępny konsument, który może przetworzyć wiadomość. Jeśli konsument otrzyma wiadomość i nie potwierdzi jej przed zamknięciem, wiadomość zostanie ponownie dostarczona innemu konsumentowi. Kolejka może mieć wielu klientów z równoważeniem obciążenia wiadomości wśród dostępnych klientów.

Chcę mieć „coś”, co wyśle ​​kopię wiadomości do każdego subskrybenta w tej samej kolejności, w jakiej wiadomość została odebrana przez brokera ActiveMQ.

jakieś pomysły?

Oznacza to, że temat jest odpowiedni. Kolejka oznacza, że ​​wiadomość trafia do jednego i tylko jednego możliwego subskrybenta. Temat trafia do każdego subskrybenta.

Tematy dotyczą modelu wydawca-subskrybent, a kolejki są punkt-punkt.

JMS temat jest rodzaj przeznaczenia w modelu 1 do wielu dystrybucji. Ta sama opublikowana wiadomość jest odbierana przez wszystkich abonentów . Możesz także nazwać to modelem „rozgłoszeniowym”. Temat można traktować jako odpowiednik tematu we wzorcu projektowym obserwatora dla przetwarzania rozproszonego. Niektórzy dostawcy JMS efektywnie wybierają implementację tego jako UDP zamiast TCP. W przypadku tematu dostarczenie wiadomości to „odpal i zapomnij” - jeśli nikt nie słucha, wiadomość po prostu znika. Jeśli nie tego chcesz, możesz skorzystać z „trwałych subskrypcji”.

Kolejki JMS jest miejscem 1-do-1 wiadomości. Wiadomość jest odbierana tylko przez jednego z odbiorców odbierających (uwaga: konsekwentne używanie subskrybentów dla klienta tematu i odbiorników dla klienta kolejki pozwala uniknąć zamieszania). Wiadomości wysyłane do kolejki są przechowywane na dysku lub w pamięci, dopóki ktoś jej nie odbierze lub nie wygaśnie. Więc kolejki (i trwałe subskrypcje) wymagają aktywnego zarządzania pamięcią masową, musisz pomyśleć o powolnych konsumentach.

Twierdziłbym, że w większości środowisk tematy są lepszym wyborem, ponieważ zawsze można dodawać dodatkowe komponenty bez konieczności zmiany architektury. Dodane komponenty mogą obejmować monitorowanie, rejestrowanie, analitykę itp. Na początku projektu nigdy nie wiadomo, jakie będą wymagania za 1 rok, 5 lat, 10 lat. Zmiana jest nieunikniona, obejmij ją :-)

To takie proste:

Kolejki = Wstaw> Wycofaj (wyślij do pojedynczego subskrybenta) 1: 1

Tematy = Wstaw> Transmisja (wysyłanie do wszystkich subskrybentów) 1: n

Jeśli chodzi o zachowanie zamówienia, zobacz tę stronę ActiveMQ . Krótko mówiąc: zamówienie jest zachowane dla pojedynczych konsumentów, ale w przypadku wielu konsumentów kolejność dostaw nie jest gwarantowana.

Kolejki

Plusy

• Prosty wzorzec wiadomości z przejrzystym przepływem komunikacji
• Wiadomości można odzyskać, umieszczając je z powrotem w kolejce

Cons

• Tylko jeden konsument może otrzymać wiadomość
• Implikuje powiązanie między producentem a konsumentem, ponieważ jest to relacja jeden do jednego

Tematy

Plusy

• Wielu konsumentów może otrzymać wiadomość
• Oddzielenie płatności od producenta i konsumenta (wzorzec publikowania i subskrybowania)

Cons

• Bardziej skomplikowany przepływ komunikacji
• Nie można odzyskać wiadomości dla jednego odbiornika

Jeśli masz N konsumentów, to:

Tematy JMS dostarczają wiadomości do N z N Kolejki JMS dostarczają wiadomości do 1 z N

Powiedziałeś, że „szukasz czegoś, co wyśle ​​kopię wiadomości do każdego subskrybenta w tej samej kolejności, w jakiej wiadomość została odebrana przez brokera ActiveMQ”.

Więc chcesz użyć tematu, aby wszyscy N subskrybenci otrzymali kopię wiadomości.

TEMAT :: temat to komunikacja od jednego do wielu ... (wielopunktowy lub opublikuj / subskrybuj) EX: - wyobraź sobie, że wydawca publikuje film w youtubie, wtedy wszyscy jego subskrybenci otrzymają powiadomienie .... QUEVE :: queve jest jeden do -jedna komunikacja ... Np .: -Gdy opublikujesz prośbę o doładowanie, trafi ona tylko do jednego qrecievera ... zawsze pamiętaj, że jeśli prośba dotarła do wszystkich qreceiverów, to nastąpiło wielokrotne ładowanie, więc opracowując analizę, która jest odpowiednia dla aplikacji

Kolejka to obiekt zarządzany przez JMS służący do przechowywania wiadomości oczekujących na zużycie przez subskrybentów. Gdy wszyscy subskrybenci wykorzystają wiadomość, wiadomość zostanie usunięta z kolejki.

Temat polega na tym, że wszyscy subskrybenci danego tematu otrzymują tę samą wiadomość po opublikowaniu wiadomości.