Jstorm消費MQ保證每個bolt至少處理一次

Jstorm消費MQ保證每個bolt至少處理一次 我們在使用Jstorm做流計算的時候，可能會遇到一種情況：處理單元樹下有某一個bolt處理失敗，但是其他的子bolt處理成功了。我們還需要這個失敗的bolt重新處理一邊該數據，如下圖所示： 這裏我們的Spout在fail()方法中做消息重發處理，Bolt1中我們會存儲原數據到mongo表中作爲防止重複消費的去重表，下面Bolt2、Bolt3、Bol

>>阅读原文<<