Модель работы RabbitMQ

Сердро RabbitMQ — концепция маршрутизации сообщений через exchange.

1. Основные сущности RabbitMQ

1. Producer — отправитель сообщений

2. Exchange — маршрутизатор сообщений

3. Queue — очередь сообщений (FIFO)

4. Binding — связь между exchange и очередью

5. Consumer — получатель сообщений

6. Routing key — ключ маршрутизации

Определение: Exchange — точка, которая принимает сообщения от продюсеров и направляет в очереди согласно правилам.

2. Взаимодействие

Процесс доставки сообщения:

1. producer → отправляет сообщение

2. exchange → выбирает подходящие очереди

3. queue → хранит сообщение

4. consumer → читает сообщение

Прямой отправки в очередь не происходит — только через exchange.

3. Типы exchange

Существует несколько типов обменников:

1. direct

2. fanout

3. topic

4. headers

Вопрос фокусируется на первых трёх, кроме topic.

Direct exchange

Определение: Direct exchange — маршрутизатор, который направляет сообщения по точному совпадению routing key.

Пример:

php

// binding: queueA ← ("key1")
// routing key: "key1" → попадёт в queueA

Используется, когда:

• нужно точное соответствие маршрутов

• разные типы задач идут в разные очереди

• логика проста и предсказуема

Fanout exchange

Определение: Fanout exchange — рассылает сообщение во все очереди, привязанные к exchange, независимо от ключей.

Пример:

• очередь A ← получит

• очередь B ← получит

• очередь C ← получит

Применение:

• широковещательная рассылка

• обновления кеша

• нотификации всем воркерам

• события pub/sub

Headers exchange

Определение: Headers exchange маршрутизирует сообщения на основе заголовков, а не ключей.

Пример:

Binding:

x-match = all  
type = "audit"  
env = "prod"

Сообщение попадёт в очередь, если оба заголовка совпадают.

Применение:

• сложные правила маршрутизации

• когда routing key недостаточно

• когда фильтрация происходит по множеству параметров

4. Сравнение типов exchange перечислением

• direct
  маршрутизация по точному ключу

• fanout
  широковещательная рассылка во все очереди

• headers
  маршрутизация по заголовкам сообщения (поддерживает AND/OR логику)

5. Вывод

RabbitMQ обеспечивает гибкую маршрутизацию сообщений через обменники. Direct подходит для точного распределения задач, fanout — для широковещательных рассылок, а headers — для сложных правил фильтрации.