Реактивное программирование

Реактивное программирование используется для конструирования событийно-ориентированных систем, обладающих масштабируемостью, отказоустойчивостью и быстрым временем отклика вне зависимости от загрузки и сбоев (Реактивный манифест).

Примеры потоковых данных:

• Протоколы работы систем;
• Информация о работе оборудования (в том числе интернет вещей);
• Вызовы сервисов;
• Клики пользователей;
• Твиты в социальных сетях.

Возможности обработки потоковых данных:

• Выделение интересующих событий из общего потока событий;
• Получение «сложных» событий (корреляция событий);
• Расчеты (например, количество падений оборудование в течение некого времени), показывающие, например, изменение состояния системы;
• Следование или не следование некому шаблону событий (закрытие сессии без её открытия и т.п.), что может свидетельствовать, например, о попытке взлома.

Сферы применения реактивного программирования:

• Финансы – алгоритмизация торговли и обнаружения мошенничества;
• Телекоммуникации – мониторинг сети и качества сервиса;
• Производство – мониторинг материалов (RFID), агрегирование данных от сенсоров и генерация тревоги в случае ошибок;
• Веб-приложения — анализ трафика сайта и обнаружение нежелательного поведения;
• Здравоохранение – анализ состояния здоровья пациента;
• Логистика – прогнозирование и отслеживание цепочки поставок и GPS-трэкинга;
• Охранные системы / Умный дом / Автомобильная телеметрия.

Используемые технологии

Платформа Lightbend Fast Data включает решения ведущих поставщиков для систем потоковой передачи данных и реактивных систем:

• Apache Kafka;
• Apache Spark;
• Mesosphere DC/OS;
• OpsClarity;
• Apache Flink;
• Lightbend Reactive Platform (Akka, Akka Streams, Play, Lagom Frameworks).