J'ai un système d'analyse vidéo distribuée, qui est composé de:passage de messages et de signalisation dans le système distribué
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.
Combien de données y a-t-il dans une fonction? Comme 8 octets par fonctionnalité? Si vous avez vraiment peu de données, il y a beaucoup de choses simples que vous pouvez faire, comme la diffusion de toutes les fonctions à tous les détecteurs. –