Я разрабатываю приложение, которое обрабатывает транзакции, которые содержат фрагменты сериализованных сообщений.Он считывает, группирует и объединяет и отправляет их подписчикам после их десериализации.
Различные задачи (чтение, группировка, десериализация) реализованы как выделенные компоненты, которые взаимодействуют друг с другом через BlockingQueue
.
Приложение является многопоточным, но не имеет распределенной архитектуры.
Вопрос Развертывается ли Apache Storm в таких нераспределенных системах, как эта?