Какова модель работы RabbitMQ: какие сущности в ней присутствуют, какие существуют типы exchange и чем отличаются direct, fanout и headers-exchange?

Question

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

YeaHub · Accepted Answer

Модель работы RabbitMQСердро RabbitMQ — концепция маршрутизации сообщений через exchange.1. Основные сущности RabbitMQProducer — отправитель сообщенийExchange — маршрутизатор сообщенийQueue — очередь сообщений (FIFO)Binding — связь между exchange и очередьюConsumer — получатель сообщенийRouting key — ключ маршрутизацииОпределение: Exchange — точка, которая принимает сообщения от продюсеров и направляет в очереди согласно правилам.2. ВзаимодействиеПроцесс доставки сообщения:producer → отправляет сообщениеexchange → выбирает подходящие очередиqueue → хранит сообщениеconsumer → читает сообщениеПрямой отправки в очередь не происходит — только через exchange.3. Типы exchangeСуществует несколько типов обменников:directfanouttopicheadersВопрос фокусируется на первых трёх, кроме topic.Direct exchangeОпределение: Direct exchange — маршрутизатор, который направляет сообщения по точному совпадению routing key.Пример:php// binding: queueA ← ("key1")
// routing key: "key1" → попадёт в queueA
Используется, когда:нужно точное соответствие маршрутовразные типы задач идут в разные очередилогика проста и предсказуемаFanout exchangeОпределение: Fanout exchange — рассылает сообщение во все очереди, привязанные к exchange, независимо от ключей.Пример:очередь A ← получиточередь B ← получиточередь C ← получитПрименение:широковещательная рассылкаобновления кешанотификации всем воркерамсобытия pub/subHeaders 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 — для сложных правил фильтрации.