一种基于 Storm 实时流计算框架的消息可靠处理保障方法

新一代信息技术

本发明公开了一种基于 Storm 实时流计算框架的消息可靠处理

保障方法，包括：①预处理阶段，对环境做初始化工作；②集群计算

过程中对已经发射并正处于计算状态的数据进行跟踪；③发射任务在

监听到消息处理成功的信号时，清空缓存区中属于它的所有子元组的

跟踪信息；④发射任务在监听到消息处理失败的信号时，定位产生处

理失败的任务的位置和待恢复数据；⑤根据跟踪信息和 xml 文件构建

消息恢复程序，然后从缓存区读取待恢复数据

试用