storm流处理框架

bolt之间通信 参考链接 如上图, Spout会分配两个任务,对应sid1,sid2; 同时指定两个Acker,对应stid1:1010,stid2:1011;这两个数可以通过哈希找到对应的Acker,而且每次传递消息都会保存。 Acker存储了自己的stid,对应的任务id是sid,同时还要存ack Value,初值被设置为了stid Bolt接受消息,但是任务在这里没有处理完,就先发送一波t
相关文章
相关标签/搜索