Nachrichtenübermittlung und Signalisierung in verteilten Systemen

Question

Ich habe ein verteiltes Videoanalysesystem, das aus folgenden Komponenten besteht:

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

Meine Frage ist: Wie kann man die Kommunikation zwischen dem Feature-Extraktionsblock und mehreren Detektoren durchführen, vorzugsweise in Echtzeit? Ich habe mir einen Event-Bus angeschaut, aber der ist nur für einen Prozess. Wäre ZooKeeper in Hadoop eine bessere Lösung?

Ich verwende Java. Jede Anregung ist willkommen.

Answer 1

In Java könnten Sie die Verwendung von RabbitMQ Nachrichtenbus. Es gibt eine Bibliothek mit Java-Anbindungen .

RabbitMQ basiert auf einem bewährten Plattform, die eine außergewöhnlich hohe Zuverlässigkeit, Verfügbarkeit und Skalierbarkeit sowie eine gute Durchsatz- und Durchsatz- und Latenzleistung, die vorhersehbar und konsistent ist. Sie hat ein kompakte, leicht zu wartende Codebasis die eine schnelle Anpassung und sofortige Einsatz. Es gibt umfangreiche Einrichtungen für Verwaltung, Überwachung, Kontrolle und Fehlersuche und wird wird durch ein umfassendes Angebot an kommerziellen Unterstützungsdiensten und einer aktive Gemeinschaft, die Pakete entwickelt die das Kernsystem erweitern.