passage de messages et de signalisation dans le système distribué

Question

J'ai un système d'analyse vidéo distribuée, qui est composé de:

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 

Ma question est la suivante: comment faire la communication entre le bloc fonction d'extraction et de multiples détecteurs, de préférence en temps réel -temps? J'ai regardé un bus d'événement, mais c'est seulement pour un processus, ZooKeeper dans Hadoop sera-t-il une meilleure solution?

J'utilise Java. Toute suggestion est la bienvenue.

Answer 1

En Java, vous pouvez utiliser le bus de messages RabbitMQ. Il y a une bibliothèque avec Java bindings.

RabbitMQ est basé sur une plate-forme éprouvée , offrant une grande fiabilité exceptionnelle , la disponibilité et l'évolutivité avec un bon débit et les performances de latence qui est prévisible et uniforme. Il a une base de code compacte et facilement maintenable permettant une personnalisation rapide et un déploiement à chaud . Il y a de vastes installations pour la gestion, le suivi, le contrôle et le débogage et il est pris en charge par une gamme complète de services de soutien commerciaux et une communauté contribuer activement au développement des paquets qui étendent le système de base.