Storm内部的通信机制原理

1,不同的supervisor之间通过网络进行通信,每个supervisor的工作环境中都会有一个输入和输出的缓存队列; 2,由于spout和bolt处理任务的数量不一致,因此在bolt的前面也会有一个消息队列对数据进行缓存,同理WordCountBolt也会有一个消息队列,对数据进行缓存
相关文章
相关标签/搜索