База знаний Антона Сидорова

База знаний по аналитике, ИТ архитектуре, API. Документирование. Тесты инструментов.

---

Project maintained by daemon110282 Hosted on GitHub Pages — Theme by mattgraham

RMQ Паттерны Интеграции

• RMQ Паттерны Интеграции
  • Task (Worker) Queue
  • Simple one-way messaging
  • Publish-subscribe Издатель-Подписчик
    • headers vs topic для событий
  • RPC (команды)
  • Direct Reply-To

Task (Worker) Queue

• Round-robin dispatching - циклическое распределение задач по консьюмерам
  • сервисы между собой делят Очередь задач
  • паттерн EIP Competing Consumers
  • Exchange type: direct
  • Several consumer listening to the same queue, reading the messages in a round-robin fashion if all are waiting
• Task Queue - распределение задач по загрузке Fair dispatching
  • QoS = 1, ack=1, autoack=0 если не подтверждено 1-е сообщение, 2-е пойдёт другому подписчику

Simple one-way messaging

• Exchange type: direct
• message sent to unnamed (default queue)

Publish-subscribe Издатель-Подписчик

• Exchange type: fanout - без фильтрации - события
  • Очередь ответов - даёт широковешательную рассылку ответов по всем ИС потребителям
• Exchange type: headers - с фильтрацией - события
  • даёт возможность делать фильтрацию трафика на уровне RMQ
  • подписчик
    • создаёт и связывает очередь к обменнику
    • указывает фильтрацию на основе заголовков - это решает задачу фильтрации лишнего трафика
    • Но не решает задачу изоляции: Подписчик может не указать фильтры и получит весь трафик: и свой и чужой

Минусы:

• единый контракт для подписчиков
• Не безопасно, кто угодно подписывается
• с ростом числа подписчиков, Брокер масштабировать необходимо

headers vs topic для событий

• headers более гибко т.к. key-value инвариантов может быть больше?
  • топик - фильтрация на основе строковой маски - поиска подстроки
  • headers - на основе полного равенства значения ключа (логическое И) или один из ключей (логическое ИЛИ)

Минусы:

• функционально разницы нет, по производительности topic в 3 раза медленнее headers

RPC (команды)

паттерн EIP

• Exchange type: direct
• message can be sent to default exchange with a specified routing key
• response is received on a specified unique response queue, owned by the client
• message Header correlation_id
• message Header reply_to куда отправить результат (ответ) команды

Пример реализации в EasyNetQ RPC

Direct Reply-To

• Consumer подписывается на специальную псевдоочередь amqp.rabbitmq.reply-to
• Producer отправляет сообщение с указанием этой очереди в качестве reply-to заголовка
• RMQ генерирует для нас уникальный routing_key, по которому будет должно быть опубликовано ответное сообщение в default exchange
• сервер получает наше сообщение и отправляет ответ по этому routing_key