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

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 .

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