(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210681969.4 (22)申请日 2022.06.15 (71)申请人 中银金融科技有限公司 地址 200120 上海市浦东 新区(上海)自由 贸易试验区银城中路20 0号4楼408室 (72)发明人 杜庆　刘喆　 (74)专利代理 机构 北京路浩知识产权代理有限 公司 11002 专利代理师 乔慧 (51)Int.Cl. G06F 9/54(2006.01) G06F 9/50(2006.01) H04L 69/18(2022.01) H04L 67/51(2022.01) (54)发明名称 支持多种类型消息的消息处理平台、 方法、 设备及介质 (57)摘要 本发明提供一种支持多种类型消息的消息 处理平台、 方法、 设备及介质， 所述平台包括 Spring底层框架及搭建于Spring底层框架的至 少一个消息处理框架， 各消息处理框架与 Spring 底层框架之间形成支持各消息处理框架对应的 消息处理协议的微服务架构系统； 在微服务架构 系统接收到消息处理协议适配的MQ消息请求的 情况下， 基于微服务架构系统建立的java线程池 中的线程， 并根据MQ消息请求的需求参数配置工 作流， 以通过工作流响应MQ消息请求， 由此通过 多个消息处理框架实现多种类型MQ消息的集成， 且通过各自微服务架构系统的java线程池中的 线程结合工作流达到高效的接收或发送MQ消息 的效果。 权利要求书2页 说明书8页 附图2页 CN 115269217 A 2022.11.01 CN 115269217 A 1.一种支持多种类型消息的消息处 理平台， 其特 征在于， 包括： Spring底层框架及搭建于所述Spri ng底层框架的至少一个消息处 理框架； 各所述消息处理框架与所述Spring底层框架之间形成支持各所述消息处理框架对应 的消息处 理协议的微 服务架构系统； 在所述微服务架构系统接收到所述消息处理协议适配的MQ消息请求的情况下， 基于所 述微服务架构系统建立的java线程池中的线程， 并根据所述MQ消息请求的需求参数配置工 作流， 以通过 所述工作流响应所述MQ消息请求。 2.根据权利要求1所述的支持多种类型消息的消息处理平台， 其特征在于， 所述微服务 架构系统包括消息生产模块、 消息消费模块、 消息持久化模块及工作流模块； 所述消息消费模块用于对所述消息生产模块 生产的至少一种协议的MQ消息进行消费； 所述消息持久化模块用于对所述消息消费模块的消费记录及所述消息生产模块的生 产记录的进行持久化存 储； 所述工作流模块用于基于所述MQ消息请求的需求参数， 通过工作流的java责任链模式 将所述消息生产模块、 消息消费模块、 消息持久化模块进行串联。 3.根据权利要求2所述的支持多种类型消息的消息处理平台， 其特征在于， 所述消息消 费模块还用于基于Dubbo分布式服务框架或Spr ing Cloud分布式服务框架调用所述消息生 产模块或所述消息持久化模块对消费后的消息内容进行消息持久 。 4.根据权利要求2所述的支持多种类型消息的消息处理平台， 其特征在于， 所述工作流 模块还用于通过java责任链将不同类型消息的消息生产和/或消息消费串 联为原子交易模 式的工作流。 5.根据权利要求2所述的支持多种类型消息的消息处理平台， 其特征在于， 所述消息持 久化模块还用于将所述消息消费模块的消费记录落地至所述消费记录的数据类型匹配的 数据库或文本文件中进行存 储； 以及， 所述消息持久化模块还用于将所述消息生产模块的生产记录落地至所述生产记录的 数据类型匹配的数据库或文本文件中进行存 储。 6.根据权利要求2所述的支持多种类型消息的消息处理平台， 其特征在于， 所述消息生 产模块还用于在所述生产的至少一种协议的MQ消息的数据来源为数据库中指定表的指定 范围内的数据的情况 下， 通过java责任链顺序调用所述消费者模块进行 数据处理； 或者， 所述消息生产模块还用于在所述生产的至少一种协议的MQ消息的数据来源为数据库 中指定表的指 定范围内的数据的情况下， 通过微服务模式调用所述消费者模块或所述消息 持久化模块进行 数据处理。 7.根据权利要求1至6任一项所述的支持多种类型消息的消息处理平台， 其特征在于， 所述消息处理框架包括 JMS类消息处理框架、 AMQP类消息处理框架及KAFKA类消息处理框架 中的至少一个。 8.一种应用于权利要求1 ‑7任一项所述的支持多种类型消息的消息处理平台的消息处 理方法， 其特 征在于， 包括： 在接收到携带消息报文的MQ消息请求的情况下， 对所述MQ消息请求进行解析， 并根据 解析结果将所述MQ消息请求下发至所述MQ消息请求匹配的所述 微服务架构系统；权　利　要　求　书 1/2 页 2 CN 115269217 A 2基于所述微服务架构系统的消息生产模块生产 所述MQ消息请求匹配的数据包， 并将所 述数据包发送至所述 微服务架构系统的消息消费模块； 基于所述消息消费模块对所述数据包进行消费， 并基于所述微服务架构系统的消息持 久化模块对所述消息生产模块的生产记录及所述消息消费模块的消费记录进行持久化存 储。 9.一种电子设备， 包括存储器、 处理器及存储在所述存储器上并可在所述处理器上运 行的计算机程序， 其特征在于， 所述处理器执行所述程序时实现如权利要求8所述消息处理 方法。 10.一种非暂态计算机可读存储介质， 其上存储有计算机程序， 其特征在于， 所述计算 机程序被处 理器执行时实现如权利要求8所述消息处 理方法。权　利　要　求　书 2/2 页 3 CN 115269217 A 3