Что хотят услышать интервьюеры:

Нужно показать, что понятны базовые механизмы RabbitMQ: exchange, queue, binding и routing key. Важно уметь объяснить, чем отличается прямой, тематический и fanout-подходы к доставке сообщений. Хорошо, если есть практический опыт настройки маршрутизации под конкретную задачу, например разделение событий по типам или сервисам.

Определение:

Маршрутизация сообщений в RabbitMQ — это механизм, при котором сообщение из exchange попадает в нужную очередь не напрямую, а по правилам привязки. Ключевую роль играют тип exchange и binding: они определяют, какие очереди получат сообщение в зависимости от routing key или других условий. Это позволяет гибко разделять потоки сообщений между разными потребителями.

Пример использования:

Например, в системе заказов можно отправлять события в разные очереди: order.created, order.paid, order.cancelled. Для этого удобно использовать topic exchange, где очереди подписываются на нужные шаблоны.

import pika

connection = pika.BlockingConnection(pika.ConnectionParameters("localhost"))
channel = connection.channel()

channel.exchange_declare(exchange="orders", exchange_type="topic")

channel.queue_declare(queue="billing_queue")
channel.queue_declare(queue="notification_queue")

channel.queue_bind(
    exchange="orders",
    queue="billing_queue",
    routing_key="order.paid"
)

channel.queue_bind(
    exchange="orders",
    queue="notification_queue",
    routing_key="order.*"
)

channel.basic_publish(
    exchange="orders",
    routing_key="order.paid",
    body="Order #123 paid"
)

connection.close()

Пояснение кода:

Код показывает настройку topic exchange с двумя очередями. Очередь billing_queue получит только сообщения с ключом order.paid, а notification_queue — все события, которые подходят под шаблон order.*. При публикации сообщения в exchange RabbitMQ сам решает, в какую очередь его доставить, исходя из routing_key и правил binding.

Ключевые моменты:

Маршрутизация в RabbitMQ строится вокруг связки exchange -> binding -> queue.
routing_key используется для выбора очереди, но итог зависит от типа exchange.
direct подходит для точного совпадения ключа, topic — для шаблонов, fanout — для рассылки всем подписчикам.
Правильная маршрутизация помогает разделять бизнес-события по обработчикам и уменьшать связанность сервисов.
Если ни одно правило не подошло, сообщение может быть потеряно, если не настроены alternate exchange или return-механизмы.

Имели ли вы опыт настройки и использования маршрутизации сообщений в RabbitMQ?