本發明公開了一種基于 Storm 實時流計算框架的消息可靠處理 保障方法,包括:①預處理階段,對環境做初始化工作;②集群計算 過程中對已經發射并正處于計算狀態的數據進行跟蹤;③發射任務在 監聽到消息處理成功的信號時,清空緩存區中屬于它的所有子元組的 跟蹤信息;④發射任務在監聽到消息處理失敗的信號時,定位產生處 理失敗的任務的位置和待恢復數據;⑤根據跟蹤信息和 xml 文件構建 消息恢復程序,然后從緩存區讀取待恢復數據