Реактивное программирование используется для конструирования событийно-ориентированных систем, обладающих масштабируемостью, отказоустойчивостью и быстрым временем отклика вне зависимости от загрузки и сбоев (Реактивный манифест).
Примеры потоковых данных:
- Протоколы работы систем;
- Информация о работе оборудования (в том числе интернет вещей);
- Вызовы сервисов;
- Клики пользователей;
- Твиты в социальных сетях.
Возможности обработки потоковых данных:
- Выделение интересующих событий из общего потока событий;
- Получение «сложных» событий (корреляция событий);
- Расчеты (например, количество падений оборудование в течение некого времени), показывающие, например, изменение состояния системы;
- Следование или не следование некому шаблону событий (закрытие сессии без её открытия и т.п.), что может свидетельствовать, например, о попытке взлома.
Сферы применения реактивного программирования:
- Финансы – алгоритмизация торговли и обнаружения мошенничества;
- Телекоммуникации – мониторинг сети и качества сервиса;
- Производство – мониторинг материалов (RFID), агрегирование данных от сенсоров и генерация тревоги в случае ошибок;
- Веб-приложения — анализ трафика сайта и обнаружение нежелательного поведения;
- Здравоохранение – анализ состояния здоровья пациента;
- Логистика – прогнозирование и отслеживание цепочки поставок и GPS-трэкинга;
- Охранные системы / Умный дом / Автомобильная телеметрия.
Используемые технологии
Lightbend Fast Data Platform - полнофункциональная платформа приложений для перехода от классических архитектур Big Data к новым архитектурам Fast Data, где потоковая передача данных является основной абстракцией.

Платформа Lightbend Fast Data включает решения ведущих поставщиков для систем потоковой передачи данных и реактивных систем:
- Apache Kafka;
- Apache Spark;
- Mesosphere DC/OS;
- OpsClarity;
- Apache Flink;
- Lightbend Reactive Platform (Akka, Akka Streams, Play, Lagom Frameworks).
Клиенты также интересуются