Сессии, автоперенаправление и разделы

Разработка решений на основе событий и сообщений в Azure

Fiodar Sazanavets

Senior Software Engineer and Microsoft MVP

Обзор сессий

Разработка решений на основе событий и сообщений в Azure

Обзор сессий

  • Упорядочивание в рамках сессии
    • Реализуется через идентификатор сессии
    • Одна сессия на потребителя
    • Сообщения сохраняют порядок
  • Лёгкое состояние для:
    • Обработки перезапусков
    • Организации чистой очереди FIFO
    • Масштабирования при многих параллельных сессиях

Сессии Service Bus

Разработка решений на основе событий и сообщений в Azure

Недоставленные сообщения и автоперенаправление

Недоставленные сообщения

  • Сообщения с ошибками
  • Освобождают основной поток обработки

Автоперенаправление

  • Передаёт сообщения в отдельную очередь или топик
  • Используется в потоке диагностики
  • Используется для повторных попыток

Недоставленные сообщения

Автоперенаправление

Разработка решений на основе событий и сообщений в Azure

Обнаружение дублей

  • Сетевое соединение может прерываться
    • Это приводит к повторной отправке сообщений
    • Повторная обработка нежелательна
  • Обнаружение дублей:
    • Уникальный идентификатор сообщения
    • В сочетании с временным окном
    • Сообщения с совпадающим ID отбрасываются
  • Каждое сообщение обрабатывается только один раз

Схема обнаружения дублей

Разработка решений на основе событий и сообщений в Azure

Разделы для высокой пропускной способности

Разделы в Service Bus

  • Распределение по нескольким брокерам
    • Параллельная обработка сообщений
    • Повышает отказоустойчивость
  • Используется тот же API
    • Распределение управляется Service Bus
    • Та же строка подключения
Разработка решений на основе событий и сообщений в Azure

Всё вместе

Сводка по Service Bus

Разработка решений на основе событий и сообщений в Azure

Давайте потренируемся!

Разработка решений на основе событий и сообщений в Azure

Preparing Video For Download...