передачи сообщений и сигнализации в распределенной системе

Question

я распределенная система анализа видеоданных, в состав которого входят:

1. feature extraction: generated lots of features(20+) from each frame of the video 
2. multiple detectors(in different machine): 
    * Each of them will get a subset of feature 
    * Each of them needs the features from multiple frames. 
    * Eg. Detector 1 needs feature 1-5 from 3 frames to start processing; Detector 2 needs feature 2-8 from 8 frames to start processing 

Мой вопрос: как сделать связь между блоком выделения признаков и нескольких детекторов, предпочтительно в режиме реального времени -время? Я смотрю на автобус событий, но это только для одного процесса, будет ли ZooKeeper в Hadoop лучшим решением?

Я использую Java. Любое предложение приветствуется.

Answer 1

В Java вы можете рассмотреть возможность использования RabbitMQ сообщений. Существует библиотека с Java bindings.

RabbitMQ основан на проверенной платформе , предлагая исключительно высокую надежности, доступность и масштабируемость наряду с хорошими пропускной способностью и латентной производительностью, что является предсказуемыми и последовательным. Он имеет компактную, легко ремонтируемую базовую базу , позволяющую быстро настраивать и устанавливать . Есть обширные средства для управления, мониторинга, контроля и отладки, и он поддерживается полный спектр коммерческих услуг поддержку и активного сообщества разработки пакетов , расширяющих базовую систему.