Как устроена маршрутизация сообщений через exchange в RabbitMQ

Exchange — это центральный элемент маршрутизации сообщений в RabbitMQ.

Определение

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

1) Общая схема маршрутизации

Последовательность выглядит так:

1. Продюсер отправляет сообщение в exchange.

2. Exchange анализирует routing key и тип.

3. Сообщение попадает в одну или несколько очередей.

Продюсер при этом не знает:

• сколько очередей получат сообщение;

• какие именно это очереди.

2) Типы exchange

Основные типы:

• direct — точное совпадение routing key;

• fanout — рассылает сообщения во все связанные очереди;

• topic — маршрутизация по шаблонам;

• headers — по заголовкам сообщения.

3) Пример direct exchange

# producer отправляет сообщение с routing_key="order.created"
# очередь привязана с таким же ключом

Результат:

• сообщение попадет только в соответствующую очередь.

4) Зачем это нужно

Exchange позволяет:

• легко добавлять новых потребителей;

• менять маршрутизацию без изменения кода продюсера;

• строить событийную архитектуру.

Вывод

Exchange отделяет отправку сообщений от их доставки. Это ключевой механизм гибкой маршрутизации в RabbitMQ.