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