一种队列消息一致性的实现方法、装置、计算系统

专利申请号：CN201811294150.2

公 开 号：CN109408203A

发 明 人：许广彬 谭瑞忠 濮天晖 王明星 

代 理 人：储振

代理机构：32351 苏州友佳知识产权代理事务所(普通合伙)

专利类型：发明申请

申 请 日：20190301

公 开 日：20181101

专利主分类号：G06F9/46(20060101)

关 键 词：事务管理模块 队列消息 消息管理模块 业务逻辑模块 消息中间件 计算系统 事务 设备宕机 事件执行 网络故障 消息管理 心跳机制 不一致 数据源 监听 回滚 调用 投递 外部 申请 进程 管理 

摘      要：本发明提供了一种实现队列消息一致性的装置、实现方法及计算系统，该装置包括：业务逻辑模块、事务管理模块及消息管理管理；业务逻辑模块，请求打开消息中间件的本地事务，并在执行事务前调用事务管理模块开启本地事务，并独立地通过消息管理模块对事务管理模块所开启的所述消息中间件的本地事务所产生的提交事件或回滚事件执行监听，事务管理模块与消息管理模块基于心跳机制确保彼此处于同一进程。在本申请所揭示的一种队列消息一致性的实现方法、装置及计算系统中，克服了队列消息在不同数据源之间因网络故障、设备宕机等外部因素所导致的队列消息投递不一致的缺陷。