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