我有一个分布式视频分析系统,它由以下部分组成:
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
我的问题是:如何进行特征提取块和多个检测器之间的通信,最好是实时的?我一直在研究事件总线,但它只针对一个进程,Hadoop 中的 ZooKeeper 会是更好的解决方案吗?
我正在使用 Java。欢迎任何建议。