Storm内部的通信机制原理
1,不同的supervisor之间通过网络进行通信,每个supervisor的工作环境中都会有一个输入和输出的缓存队列;
2,由于spout和bolt处理任务的数量不一致,因此在bolt的前面也会有一个消息队列对数据进行缓存,同理WordCountBolt也会有一个消息队列,对数据进行缓存
1,不同的supervisor之间通过网络进行通信,每个supervisor的工作环境中都会有一个输入和输出的缓存队列;
2,由于spout和bolt处理任务的数量不一致,因此在bolt的前面也会有一个消息队列对数据进行缓存,同理WordCountBolt也会有一个消息队列,对数据进行缓存