RabbitMQ

Czasami w projekcie musimy użyć narzędzia, które pomoże nam w dystrybucji komunikatów na kolejki, czyli w kolejkowaniu zadań. Często potrzebujemy takiego narzędzia, gdy chcemy stworzyć newsletter dla klientów, czy generowanie plików PDF lub innych operacji, które wymagają więcej czasu oczekiwania. RabbitMQ jest właśnie takim narzędziem, które pomoże nam w tym zadaniu.

RabbitMQ narzędzie do kolejkowania zadań

Jak na wstępie wspomniałem RabbitMQ jest narzędziem, które pozwoli nam kolejkować zadania. RabbitMQ przyjmuje i przekazuje zadania. Oficjalna dokumentacja projektu mówi nam, że możemy pomyśleć o RabbitMQ jako o placówce pocztowej. Umieszczając list w skrzynce pocztowej lub zostawiając taki list na poczcie, który chcemy nadać, jesteśmy pewni że listonosz w końcu dostarczy przesyłkę odbiorców. Może to zająć trochę, ale odbiorca otrzyma od nas list. W tej analogii RabbitMQ jest to skrzynka pocztowa, poczta i listonosz. Główna różnica jest taka, że RabbitMQ nie zajmuje się dostarczaniem w formie papierowej, zamiast tego przyjmuje, przechowuje i przekazuje binarne bloby danych. RabbitMQ używa pewnego żargonu:

• Producing - czyli wysyłanie, program wysyłający wiadomości do producent.
• Queue - to nazwa skrzynki pocztowej. Komunikaty, które przepływają przez RabbitMQ, mogą być przechowywane tylko w kolejce. Kolejka jest ograniczona tylko limitami pamięci i dysku hosta.
• Consuming - Ma podobne znaczenie jak Producing. Consuming to program, który w większości czeka na otrzymanie wiadomości.

Czy szukasz wykonawcy RabbitMQ ?

Sprawdź case studies

Podstawowe komponenty RabbitMQ: Exchange, Queue i Binding

RabbitMQ opiera się na trzech kluczowych komponentach: Exchange (wymiennik), Queue (kolejka) i Binding (powiązanie).

• Exchange – to punkt wejściowy dla wiadomości w RabbitMQ. Odbiera wiadomości od producentów i decyduje, do której kolejki mają trafić. Istnieją różne typy wymienników, takie jak direct, fanout, topic i headers, które pozwalają na różne sposoby routowania wiadomości.
• Queue – to miejsce przechowywania wiadomości do momentu, aż zostaną odebrane przez konsumenta. Kolejki mogą być trwałe (durable) lub ulotne (transient), co wpływa na sposób ich przechowywania i przetrwania restartu brokera.
• Binding – to powiązanie pomiędzy wymiennikiem a kolejką. Określa, jakie wiadomości trafią do danej kolejki na podstawie kluczy routingu lub wzorców.

Dzięki połączeniu tych trzech elementów RabbitMQ umożliwia elastyczne zarządzanie przepływem wiadomości i ich dystrybucją między różnymi usługami i aplikacjami.

Przewodnik po funkcjonalnościach RabbitMQ

Główną funkcjonalnością RabbitMQ jest kolejkowanie wiadomości, co pozwala na ich efektywne przetwarzanie oraz optymalne wykorzystanie zasobów systemowych. Oprócz tego, oferuje wiele innych funkcjonalności, które czynią go jednym z najlepszych narzędzi tego typu na rynku. Do najważniejszych funkcjonalności należą między innymi:

• Wieloprocesowość i skalowalność, pozwalające na obsługę dużej ilości użytkowników jednocześnie.
• Wsparcie dla różnych protokołów i formatów wiadomości, w tym między innymi AMQP, STOMP, MQTT i HTTP.
• Możliwość tworzenia kanałów i wymiany wiadomości między nimi, co ułatwia zarządzanie komunikacją w systemie.
• Mechanizmy routingu, pozwalające na przesyłanie wiadomości do odpowiednich kolejek na podstawie różnych kryteriów.
• Możliwość tworzenia kolejek typu fanout, direct oraz topic, co umożliwia elastyczne i skuteczne zarządzanie przepływem informacji.
• Bezpieczne przesyłanie i przechowywanie wiadomości, w tym między innymi szyfrowanie i autoryzację użytkowników.
• Wsparcie dla różnych języków programowania, co umożliwia łatwe integrowanie RabbitMQ z innymi systemami i aplikacjami.

Instalacja RabbitMQ

RabbitMQ wspiera wiele języków programowania, ja w tym artykule przedstawię instalacje dla języka Javascript, jeśli korzystasz z innego języka, zajrzyj do dokumentacji.

Instalujemy moduł amqp.node, który pozwoli nam na wysyłanie i otrzymywanie zadań:

npm install amqplib

Jeżeli chcemy mieć podgląd zobaczenia jakie kolejki ma RabbitMQ i ile wiadomości się w nich znajduje, musimy zainstalować narzędzie rabbitmqctl:

sudo rabbitmqctl list_queues

lub Windows:

rabbitmqctl.bat list_queues

RabbitMQ w architekturze mikroserwisowej

Współczesne systemy oparte na mikroserwisach wymagają efektywnej komunikacji między komponentami. RabbitMQ odgrywa kluczową rolę jako broker wiadomości, umożliwiając asynchroniczną wymianę danych między mikroserwisami. Dzięki niemu poszczególne usługi mogą komunikować się bez konieczności utrzymywania bezpośrednich połączeń, co zwiększa skalowalność, elastyczność i odporność na błędy.

Jak RabbitMQ wspiera mikroserwisy?

• Luźne powiązania między usługami – zamiast komunikacji synchronicznej (np. REST), RabbitMQ pozwala mikroserwisom wysyłać i odbierać wiadomości w sposób asynchroniczny, co zmniejsza obciążenie i poprawia responsywność systemu.
• Obsługa zdarzeń (event-driven architecture) – RabbitMQ ułatwia implementację wzorca publish/subscribe, w którym jeden mikroserwis może emitować zdarzenia, a wiele innych może na nie reagować. Dzięki temu można łatwo rozbudowywać system bez konieczności ingerencji w istniejące komponenty.
• Wspieranie wzorca CQRS (Command Query Responsibility Segregation) – RabbitMQ pomaga oddzielić operacje zapisu (komendy) od odczytu (zapytania), co poprawia wydajność i elastyczność systemu.
• Automatyczne skalowanie – dzięki kolejkowaniu zadań mikroserwisy mogą dynamicznie skalować liczbę konsumentów w zależności od obciążenia, co zapewnia optymalną wydajność.
• Redukcja awarii i niezawodność – mechanizmy trwałości wiadomości i potwierdzeń (acknowledgments) sprawiają, że RabbitMQ zapewnia bezpieczne dostarczanie komunikatów nawet w przypadku awarii mikroserwisów.

Przykłady zastosowań RabbitMQ w mikroserwisach

• Procesowanie zamówień w e-commerce – mikroserwisy obsługujące zamówienia, płatności i dostawy mogą komunikować się za pomocą kolejek RabbitMQ, zapewniając płynność całego procesu.
• Rejestrowanie zdarzeń i logowanie – RabbitMQ umożliwia zbieranie logów z różnych mikroserwisów i przesyłanie ich do centralnego systemu analizy.
• Powiadomienia w aplikacjach – mikroserwis obsługujący użytkowników może wysyłać wiadomości do kolejki RabbitMQ, a inny mikroserwis zajmujący się powiadomieniami może je odbierać i wysyłać e-maile, SMS-y lub notyfikacje push.