本发明公开了一种基于 Storm 实时流计算框架的消息可靠处理 保障方法,包括:①预处理阶段,对环境做初始化工作;②集群计算 过程中对已经发射并正处于计算状态的数据进行跟踪;③发射任务在 监听到消息处理成功的信号时,清空缓存区中属于它的所有子元组的 跟踪信息;④发射任务在监听到消息处理失败的信号时,定位产生处 理失败的任务的位置和待恢复数据;⑤根据跟踪信息和 xml 文件构建 消息恢复程序,然后从缓存区读取待恢复数据