storm流處理框架

bolt之間通信 參考鏈接 如上圖， Spout會分配兩個任務，對應sid1,sid2; 同時指定兩個Acker，對應stid1:1010,stid2:1011;這兩個數可以通過哈希找到對應的Acker，而且每次傳遞消息都會保存。 Acker存儲了自己的stid,對應的任務id是sid，同時還要存ack Value,初值被設置爲了stid Bolt接受消息，但是任務在這裏沒有處理完，就先發送一波t

>>阅读原文<<