(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211114286.7 (22)申请日 2022.09.14 (71)申请人 易纳购科技 （北京） 有限公司 地址 100012 北京市朝阳区来广营西路5号 院诚盈中心1号楼10层1004、 1005、 1006单元 (72)发明人 李一鸣　 (74)专利代理 机构 北京中强智尚知识产权代理 有限公司 1 1448 专利代理师 朱春元 (51)Int.Cl. G06F 16/242(2019.01) G06F 16/2453(2019.01) G06F 16/27(2019.01) (54)发明名称 分布式事务处理方法及事务管理器、 中间 件、 系统 (57)摘要 本发明公开了一种分布式事务处理方法及 事务管理器、 中间件、 系统， 涉及数据库分布式管 理技术领域， 主要目的在于解决基于中间件的分 布式事务处理方法， 开发效率较低的问题。 主要 包括响应于业务处理请求， 根据待处理业务的业 务信息、 业务类型确定开始事务语句、 目标事务 链接， 所述目标事务链接为中间件链接或非中间 件链接； 若所述目标事务链接为中间件链接， 则 通过所述目标事务链接将所述开始事务语句发 送至目标中间件， 并接收所述目标中间件发送的 分支事务执行状态； 根据所述分支事务执行状态 确定结束事务语句， 并通过所述目标事务链接将 所述结束事务语句发送至所述目标中间件。 主要 用于处理分布式事务。 权利要求书3页 说明书12页 附图2页 CN 115422225 A 2022.12.02 CN 115422225 A 1.一种分布式事务处 理方法， 其特 征在于， 所述方法应用于事务管理器， 包括： 响应于业务处理请求， 根据待处理业务的业务信息、 业务类型确定开始事务语句、 目标 事务链接， 所述目标事务链接为中间件链接或非中间件链接； 若所述目标事务链接为中间件链接， 则通过所述目标事务链接将所述开始事务语句发 送至目标中间件， 并接收所述目标中间件发送的分支事务执 行状态； 根据所述分支事务执行状态确定结束事务语句， 并通过所述目标事务链接将所述结束 事务语句发送至所述 目标中间件， 以使得中间件对所述开始事务语句、 结束事务语句进行 语法分析。 2.根据权利要求1所述的方法， 其特征在于， 所述根据待处理业务的业务信息、 业务类 型确定开始事务语句、 目标事务链接， 包括： 根据所述业务信 息解析得到目标资源管理器， 并为所述目标资源管理器配置对应的分 支事务； 根据所述分支事务生成开始事务语句， 并基于所述目标资源管理器对应的配置信 息配 置初始事务链接； 基于所述业务类型、 所述开始事务语句的事务语句类型从所述初始事务链接中确定出 目标事务链接 。 3.根据权利要求2所述的方法， 其特征在于， 所述基于所述业务类型、 所述开始事务语 句的事务语句类型从所述事务链接中确定出目标事务链接， 包括： 若所述事务语句类型为非分布式事务语句， 则确定目标事务链接为中间件链接； 若所述事务语句类型为分布式事务语句， 则从安全级别映射关系集中识别出与所述业 务类型匹配的目标安全级别； 若所述目标安全级别为第一 安全级别， 则将所述中间件链接确定为目标事务链接； 若所述目标安全级别为第二 安全级别， 则将所述非中间件链接确定为目标事务链接； 其中， 所述第一 安全级别大于所述第二 安全级别。 4.一种分布式事务处 理方法， 其特 征在于， 所述方法应用于中间件， 包括： 接收目标事务管理器发送的目标事务语句， 所述目标事务语句包括开始事务语句、 结 束事务语句中的一个； 通过对所述目标事务语句进行语法分析， 确定所述目标事务语句所对应的事务语句类 型； 若所述事务语句类型为分布式事务语句， 则将所述目标事务语句转发至目标资源管理 器， 以使所述目标资源管理器 基于所述目标事务语句进行事务处 理。 5.根据权利要求4所述的方法， 其特征在于， 通过对所述目标事务语句进行语法分析， 确定所述目标事务语句所对应的事务语句类型， 包括： 基于预先构建的语法分析器对所述目标事务语句进行语法分析， 得到所述目标事务语 句的语法分析 结果； 若所述语法分析结果与预设分布式事务语法规则匹配成功， 则确定所述目标事务语句 的事务语句类型为分布式事务语句； 若所述语法分析结果与预设分布式事务语法规则匹配失败， 则确定所述目标事务语句 的事务语句类型为非分布式事务语句。权　利　要　求　书 1/3 页 2 CN 115422225 A 26.根据权利要求4所述的方法， 其特征在于， 所述接收目标事务管理器发送的目标事务 语句之后， 所述方法还 包括： 在接收到所述结束事务语句之前， 若接收到非目标事务管理器发送的非目标事务语 句， 则生成用于指示资源已 占用的预警信息， 并将所述预警信息发生至所述非目标事务管 理器。 7.根据权利要求4所述的方法， 其特征在于， 所述目标事务语句为开始事务语句， 所述 将所述目标事务语句转发至目标资源管理器之后， 所述方法还 包括： 接收所述目标资源管理器反馈的分支事务执行状态， 并将所述分支事务执行状态发送 至所述目标事务管理器。 8.一种事务管理器， 其特 征在于， 包括： 确定模块， 用于响应于业务处理请求， 根据待处理业务的业务信 息、 业务类型确定开始 事务语句、 目标事务链接， 所述目标事务链接为中间件链接或非中间件链接； 第一发送模块， 用于若所述目标事务链接为中间件链接， 则通过所述目标事务链接将 所述开始事务语句发送至目标中间件， 并接收所述目标中间件发送的分支事务执 行状态； 第二发送模块， 用于根据所述分支事务执行状态确定结束事务语句， 并通过所述目标 事务链接将所述结束事务语句发送至所述目标中间件， 以使得中间件对所述开始事务语 句、 结束事务语句进行语法分析。 9.一种中间件， 其特 征在于， 包括： 接收模块， 用于接收目标事务管理器发送的目标事务语句， 所述目标事务语句包括开 始事务语句、 结束事务语句中的一个； 分析模块， 用于通过对所述目标事务语句进行语法分析， 确定所述目标事务语句所对 应的事务语句类型； 转发模块， 用于若所述事务语句类型为分布式事务语句， 则将所述目标事务语句转发 至目标资源管理器， 以使所述目标资源管理器 基于所述目标事务语句进行事务处 理。 10.一种分布式事务处 理系统， 其特 征在于， 包括： 事务管理器、 中间件、 资源管理器； 所述事务管理器， 用于响应于业务处理请求， 根据待处理业务的业务信息、 业务类型确 定开始事务语句、 目标事务链接， 所述目标事务链接为中间件链接或非中间件链接； 所述事务管理器， 还用于若所述目标事务链接为中间件链接， 则通过所述目标事务链 接将所述开始事务语句发送至目标中间件， 并接收所述目标中间件发送的分支事务执行状 态； 所述事务管理器， 还用于根据所述分支事务执行状态确定结束事务语句， 并通过所述 目标事务链接将所述结束事务语句发送至所述目标中间件， 以使得中间件对所述开始事务 语句、 结束事务语句进行语法分析； 所述中间件， 用于接收目标事务管理器发送的目标事务语句， 所述目标事务语句包括 开始事务语句、 结束事务语句中的一个； 所述中间件， 还用于通过对所述目标事务语句进行语法分析， 确定所述目标事务语句 所对应的事务语句类型； 所述中间件， 还用于若所述事务语句类型为分布式事务语句， 则将所述目标事务语句 转发至目标资源管理器， 以使所述目标资源管理器 基于所述目标事务语句进行事务处 理；权　利　要　求　书 2/3 页 3 CN 115422225 A 3