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

Question

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

YeaHub · Accepted Answer

Exchange — это центральный элемент маршрутизации сообщений в RabbitMQ.ОпределениеExchange — компонент RabbitMQ, который принимает сообщения от продюсеров и направляет их в очереди согласно правилам маршрутизации.1) Общая схема маршрутизацииПоследовательность выглядит так:Продюсер отправляет сообщение в exchange.Exchange анализирует routing key и тип.Сообщение попадает в одну или несколько очередей.Продюсер при этом не знает:сколько очередей получат сообщение;какие именно это очереди.2) Типы exchangeОсновные типы:direct — точное совпадение routing key;fanout — рассылает сообщения во все связанные очереди;topic — маршрутизация по шаблонам;headers — по заголовкам сообщения.3) Пример direct exchange# producer отправляет сообщение с routing_key="order.created"
# очередь привязана с таким же ключом
Результат:сообщение попадет только в соответствующую очередь.4) Зачем это нужноExchange позволяет:легко добавлять новых потребителей;менять маршрутизацию без изменения кода продюсера;строить событийную архитектуру.ВыводExchange отделяет отправку сообщений от их доставки. Это ключевой механизм гибкой маршрутизации в RabbitMQ.