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

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

---

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

Брокер сообщений Message Broker Bus

• Брокер сообщений Message Broker Bus
  • Зачем
  • Плюсы-минусы
  • Patterns
    • Middleware
    • Messaging Patterns
  • Технологии
    • Критерии выбора
      • RMQ vs Kafka
      • RMQ vs ActiveMQ Artemis

Зачем

• асинхронное взаимодействие
• 1 Издатель - Х подписчиков
• Буфер запросов
• Очередь задач

Плюсы-минусы

Плюсы:

• Масштабируемость
• Гарантированная доставка
• Буферизация
• Слабая связность ИС Low Coupling
• принцип “глупая шина (канал) умные клиенты”

Минусы:

• Дополнительный архитектурный слой
• Затраты на мониторинг, настройку, управление
• Влияет на общую надежность и безопасность системы

Patterns

Middleware

• Message-oriented persistent - Message Bus - Транспорт
  • RMQ
  • ActiveMQ
• Log-based message queue
  • Kafka
• Advanced transient messaging
  • ZeroMQ

Тип способа получения сообщений Consumer:

• Pull (по запросу) - RMQ (option), Kafka (only)
• Push (подписка) - RMQ (default)

Messaging Patterns

Messaging Patterns MS

• Pub\Sub События
• Task (Worker) Queue
• Очереди с приоритетом
• Content-Based Routing
• Filter message
• Dynamic Router
• Splitter
• Dead Leater Channel
• Message Translator
• Wire Tap - наблюдение за сообщениями
• Event Sourcing
• Как узнать когда сообщение в очередь добавлено - Timestamp

Технологии

• Транспорт
  • Kafka
  • RabbitMQ
  • Apache ActiveMQ Artemis
  • Azure service bus
  • MSMQ
  • SQL Server
  • Azure Queue Storage
  • Azure Service Bus
  • Amazon SQS
• Реализации шин сообщений (фреймворк)
  • .NET
    • NServiceBus
    • MassTransit или Brighter
    • EasyNetQ
    • abp.io
  • Python
    • Celery
  • PHP

Критерии выбора

RMQ vs Kafka

• RMQ
• Kafka
  • vs RMQ: - сообщения хранятся - повторная обработка одно и то же сообщение может быть обработано сколько угодно раз разными консьюмерами и в разных контекстах - выше производительность, Kafka легче масштабируется горизонтально - строгая последовательность сообщений (FIFO) - транзакции между несколькими топиками - Consumer модель Pull (запрос), а не Push (подписка) - Меньше гибкости в роутинге сообщений - нет приоритета сообщений - vendor lock: Kafka использует собственный двоичный протокол поверх TCP. Вы не сможете так просто удалить или заменить эту платформу

TODO

• https://habr.com/ru/company/itsumma/blog/416629/

RMQ vs ActiveMQ Artemis

• RMQ
• Artemis
  • vs RMQ
    • поддерживает более широкий спектр протоколов обмена сообщениями (+ JMS)
    • RMQ имеет наилучшую пропускную способность
    • Менее гибкая маршрутизация сообщений
      • Artemis Реализует концепцию “адреса” для маршрутизации сообщений и поддерживает различные типы маршрутизации, включая anycast и multicast
        • Паттерны: PUB-SUB
      • RMQ концепцию “обмена”. Exchange в RabbitMQ - это компонент маршрутизации сообщений, который определяет, как сообщения распределяются по очередям
        • Паттерны: Message Queue, PUB-SUB, RPC, Routing