1.本发明涉及消息处理技术领域，尤其涉及一种支持多种类型消息的消息处理平台、方法、设备及介质。
背景技术：2.在不同系统、产品以及模块之间进行高效异步通讯的过程中，使用mq消息队列的方式是相对比较普遍，然而目前对于不同类型的mq消息，大多使用不同类型的mq消息系统分别对各类型的mq消息进行处理，导致在面临大规模各种类型的mq消息通讯场景无法进行高效的接收或发送。
技术实现要素：3.本发明提供一种支持多种类型消息的消息处理平台，用以解决现有技术中使用不同类型的mq消息系统分别对各类型的mq消息进行处理，导致在面临大规模各种类型的mq消息通讯场景无法进行高效的接收或发送的缺陷，实现了基于支持多种类型消息的消息处理平台集成多种类型mq消息，进而达到高效的接收或发送mq消息的效果。
4.本发明提供一种支持多种类型消息的消息处理平台，包括：
5.spring底层框架及搭建于所述spring底层框架的至少一个消息处理框架；
6.各所述消息处理框架与所述spring底层框架之间形成支持各所述消息处理框架对应的消息处理协议的微服务架构系统；
7.在所述微服务架构系统接收到所述消息处理协议适配的mq消息请求的情况下，基于所述微服务架构系统建立的java线程池中的线程，并根据所述mq消息请求的需求参数配置工作流，以通过所述工作流响应所述mq消息请求。
8.根据本发明提供的支持多种类型消息的消息处理平台，所述微服务架构系统包括消息生产模块、消息消费模块、消息持久化模块及工作流模块；
9.所述消息消费模块用于对所述消息生产模块生产的至少一种协议的mq消息进行消费；
10.所述消息持久化模块用于对所述消息消费模块的消费记录及所述消息生产模块的生产记录的进行持久化存储；
11.所述工作流模块用于基于所述mq消息请求的需求参数，通过工作流的java责任链模式将所述消息生产模块、消息消费模块、消息持久化模块进行串联。
12.根据本发明提供的支持多种类型消息的消息处理平台，所述消息消费模块还用于基于dubbo分布式服务框架或spring cloud分布式服务框架调用所述消息生产模块或所述消息持久化模块对消费后的消息内容进行消息持久。
13.根据本发明提供的支持多种类型消息的消息处理平台，所述工作流模块还用于通过java责任链将不同类型消息的消息生产和/或消息消费串联为原子交易模式的工作流。
14.根据本发明提供的支持多种类型消息的消息处理平台，所述消息持久化模块还用
于将所述消息消费模块的消费记录落地至所述消费记录的数据类型匹配的数据库或文本文件中进行存储；以及，
15.所述消息持久化模块还用于将所述消息生产模块的生产记录落地至所述生产记录的数据类型匹配的数据库或文本文件中进行存储。
16.根据本发明提供的支持多种类型消息的消息处理平台，所述消息生产模块还用于在所述生产的至少一种协议的mq消息的数据来源为数据库中指定表的指定范围内的数据的情况下，通过java责任链顺序调用所述消费者模块进行数据处理；
17.或者，
18.所述消息生产模块还用于在所述生产的至少一种协议的mq消息的数据来源为数据库中指定表的指定范围内的数据的情况下，通过微服务模式调用所述消费者模块或所述消息持久化模块进行数据处理。
19.根据本发明提供的支持多种类型消息的消息处理平台，所述消息处理框架包括jms类消息处理框架、amqp类消息处理框架及kafka类消息处理框架中的至少一个。
20.本发明还提供一种应用于所述支持多种类型消息的消息处理平台的消息处理方法，包括：
21.在接收到携带消息报文的mq消息请求的情况下，对所述mq消息请求进行解析，并根据解析结果将所述mq消息请求下发至所述mq消息请求匹配的所述微服务架构系统；
22.基于所述微服务架构系统的消息生产模块生产所述mq消息请求匹配的数据包，并将所述数据包发送至所述微服务架构系统的消息消费模块；
23.基于所述消息消费模块对所述数据包进行消费，并基于所述微服务架构系统的消息持久化模块对所述消息生产模块的生产记录及所述消息消费模块的消费记录进行持久化存储。
24.本发明还提供一种电子设备，包括存储器、处理器及存储在存储器上并可在处理器上运行的计算机程序，所述处理器执行所述程序时实现如上述任一种所述基于跨模态学习的数据检索方法。
25.本发明还提供一种非暂态计算机可读存储介质，其上存储有计算机程序，该计算机程序被处理器执行时实现如上述任一种所述消息处理方法。
26.本发明还提供一种计算机程序产品，包括计算机程序，所述计算机程序被处理器执行时实现如上述任一种所述消息处理方法。
27.本发明提供的支持多种类型消息的消息处理平台，包括spring底层框架及搭建于spring底层框架的至少一个消息处理框架，各消息处理框架与spring底层框架之间形成支持各消息处理框架对应的消息处理协议的微服务架构系统；在微服务架构系统接收到消息处理协议适配的mq消息请求的情况下，基于微服务架构系统建立的java线程池中的线程，并根据mq消息请求的需求参数配置工作流，以通过工作流响应mq消息请求，由此通过在spring底层框架多个消息处理框架实现多种类型mq消息的集成，且由于各消息处理框架对应的消息处理协议的微服务架构系统建立有各自的java线程池，进而通过各自的java线程池中的线程结合工作流达到高效的接收或发送mq消息的效果。
附图说明
28.为了更清楚地说明本发明或现有技术中的技术方案，下面将对实施例或现有技术描述中所需要使用的附图作一简单地介绍，显而易见地，下面描述中的附图是本发明的一些实施例，对于本领域普通技术人员来讲，在不付出创造性劳动的前提下，还可以根据这些附图获得其他的附图。
29.图1是本发明提供的支持多种类型消息的消息处理平台的功能框架示意图；
30.图2是本发明提供的安全漏洞管控方法的流程示意图之一；
31.图3是本发明提供的电子设备的结构示意图；
32.附图标记：
33.101：spring底层框架；102：消息处理框架。
具体实施方式
34.为使本发明的目的、技术方案和优点更加清楚，下面将结合本发明中的附图，对本发明中的技术方案进行清楚、完整地描述，显然，所描述的实施例是本发明一部分实施例，而不是全部的实施例。基于本发明中的实施例，本领域普通技术人员在没有作出创造性劳动前提下所获得的所有其他实施例，都属于本发明保护的范围。
35.下面结合图1描述本发明的一种支持多种类型消息的消息处理平台。
36.图1为本发明提供的支持多种类型消息的消息处理平台的功能框架示意图，如图1所示，支持多种类型消息的消息处理平台包括：spring底层框架101及搭建于spring底层框架的至少一个消息处理框架102。
37.具体地，消息处理框架102指代可处理mq消息队列的框架，其中，在消息处理框架102上可基于需求部署相应的功能模块，从而基于各类型功能模块以满足其所要求的功能。
38.需要说明的是，本实施例中，消息处理框架包括jms类消息处理框架、amqp类消息处理框架及kafka类消息处理框架中的至少一个。由于目前对于不同类型的mq消息，大多使用不同类型的mq消息系统分别对各类型的mq消息进行处理，因此本实施例中为了实现各类型的mq消息的集成，以spring框架作为核心底层框架，通过spring框架的接口注入jms类消息处理框架、amqp类消息处理框架及kafka类消息处理框架，将jms类消息处理框架、amqp类消息处理框架及kafka类消息处理框架等消息处理框架102集成至spring底层框架101上，从而实现平台支持active、ibm、rabbit等主流消息处理协议。
39.此外由于spring有依赖注入、切面编程等核心功能，因此以spring框架作为核心底层框架可实现在用户存在新的功能需求的情况下，通过将功能模块或功能框架依赖注入至spring底层框架101上，从而达到扩展平台功能的目的。
40.具体地，为了实现支持多种类型消息的消息处理平台可以进行各类型mq消息的高校接收和发送，各消息处理框架102与spring底层框架101之间形成支持各消息处理框架对应的消息处理协议的微服务架构系统。
41.需要说明的是，微服务架构系统用于将消息处理平台的功能分解到离散的各个服务当中，从而降低消息处理平台的耦合性，并提供更加灵活的服务支持。本技术中，通过将多个消息处理框架102分别部署于spring底层框架101上，实现将消息处理平台拆分成若干个支持微服务的微服务架构系统。
42.另外，由于微服务架构系统可在各自的架构上扩展单个组件，实现每个微服务架构系统单独服务，彼此之间互不影响，且微服务架构系统可围绕业务领域组件来创建应用，这些应用可独立地进行开发、管理和迭代，在分散的组件中使用云架构和平台式部署、管理和服务功能，使产品交付变得更加简单。
43.本实施例中，由于各个微服务架构系统独立运行，在此以其中一个微服务架构系统为代表进行说明。在微服务架构系统接收到消息处理协议适配的mq消息请求的情况下，基于微服务架构系统建立的java线程池中的线程，并根据mq消息请求的需求参数配置工作流，以使线程使用配置好的工作流响应mq消息请求。
44.具体地，各微服务架构系统启动后，建立各自独立的java线程池，java线程池中的每个单独线程使用消息处理框架中的连接池中的连接进行消息消费，例如使用pooledconnectionfactory进行连接池中的连接管理，java线程池中的每个单独线程还可以开启独立链接进行消息生产。
45.另外需要说明的是，需求参数指代请求类型，例如仅为消息消费、仅为消息生产、或相同消息协议的消息消费及消息生产结合，或者不同消息协议的消息消费及消息生产结合。而java责任链指代多个对象都有机会处理同一个请求，从而避免请求的发送者和接收者之间的耦合关系。java责任链的工作流将这些对象连成一条链，并沿着这条链传递该请求，直到有一个对象处理它为止。
46.在实际应用中，可以根据实际请求需求仅在工作流中串联一个消息消费节点，或者仅串联一个消息生产节点，还可以在工作流中串联处理不同消息处理协议的消息消费节点及消息生产节点进行组合部署运行。
47.在另一实施例中，本实施例中的消息处理平台的后端框架包括底层框架为spring框架及消息处理框架102，此外消息处理平台还包括vue前端框架，基于vue前端框架可以实现对各消息处理框架102适配的mq消息进行分流处理，具体地，在消息处理平台接收到用户基于前端框架的可视化操作界面创建或者调用的mq消息请求后，根据对mq消息请求进行协议消息解析，得到mq消息请求的协议消息类型，并基于该协议消息类型将mq消息请求传输至匹配的消息处理框架102组成的微服务架构系统中，以实现消息处理平台可以无误的处理各类型mq。
48.进一步地，本发明提供的支持多种类型消息的消息处理平台10为一个前后端分离架构的管控平台，由此增强支持多种类型消息的消息处理平台10的负载能力，此外基于前后端分离架构，在后端发生错误时，后端错误不会直接反映到前端的可视化界面，由此保障用户使用感。
49.此外，spring底层框架还可部署有对象存储组件、数据存储组件及限流负载组件。其中，对象存储组件用于将用户端输入的非结构化数据进行落地存储，并将非结构化数据转换为结构化数据；而数据存储组件用于将用户端输入的结构化数据进行落地存储。
50.进一步地，限流负载组件用于在监控到支持多种类型消息的消息处理平台负载超出预定负载的情况下，基于预设限流规则对多个mq消息请求进行限流管控。
51.其中，在进行限流管控中除了可从当前正在运行的多个mq消息请求选取部分mq消息请求进行任务暂停管控，还可暂时关闭支持多种类型消息的消息处理平台10的创建mq消息请求权限，以避免在支持多种类型消息的消息处理平台10出现负载过大时，支持多种类
型消息的消息处理平台10仍接收到源源不断地mq消息请求任务线程，从而避免当前解决负载过大状况后，取消部分mq消息请求任务暂停管控后，又出现负载过大情况。在实际应用中，可在监测到当前正在运行的多个mq消息请求任务均执行完毕后，再开启支持多种类型消息的消息处理平台10的创建漏洞任务权限。
52.基于上述实施例，微服务架构系统包括消息生产模块、消息消费模块、消息持久化模块及工作流模块。
53.具体地，消息消费模块用于对消息生产模块生产的至少一种协议的mq消息进行消费。其中，消息生产模块的消息生产的数据源包括数据库或mq消息请求。
54.换句话说，在mq消息请求中携带有mq消息的情况下，消息生产模块作为代发中心，消息生产模块用于将mq消息请求中携带的mq消息基于mq消息请求终端的消息协议及消息格式进行转码、组包处理后转发至mq消息请求终端。
55.在另一实施例中，消息生产模块还用于在生产的至少一种协议的mq消息的数据来源为数据库中指定表的指定范围内的数据的情况下，通过java责任链顺序调用所述消费者模块进行数据处理；或者，消息生产模块还用于在生产的至少一种协议的mq消息的数据来源为数据库中指定表的指定范围内的数据的情况下，通过微服务模式调用消费者模块或消息持久化模块进行数据处理。
56.其中，指定表的指定范围均由mq消息请求中携带的指定参数进行确定，换句或说，本发明中，生产者的生产数据来源不局限于外部消息中间件中的消息，同时可以是数据库中指定表的指定范围的数据均可作为生产者，通过责任链顺序调用消费者模块或通过代理微服务设计模式调用消费者或持久模块进行后续业务数据的操作。
57.此外，消息消费模块还用于基于dubbo分布式服务框架或spring cloud分布式服务框架调用消息生产模块或消息持久化模块对消费后的消息内容进行消息持久。
58.其中，dubbo分布式服务框架及spring cloud分布式服务框架为一个远程服务调用的分布式框架，在实际应用中，在消息为rpc协议消息的情况下，基于dubbo分布式服务框架进行调用，在消息为http请求协议的情况下，基于spring cloud分布式服务框架进行调用。
59.消息持久化模块用于对消息消费模块的消费记录及消息生产模块的生产记录的进行持久化存储；消息持久化模块还用于将消息消费模块的消费记录落地至消费记录的数据类型匹配的数据库或文本文件中进行存储；以及，消息持久化模块还用于将消息生产模块的生产记录落地至生产记录的数据类型匹配的数据库或文本文件中进行存储。
60.工作流模块用于根据mq消息请求的需求参数通过java责任链将消息生产模块、消息消费模块、消息持久化模块串联至工作流。
61.在实际应用中，工作流中的各模块的数据流向可基于实际需求自由设定，消息生产模块、消息消费模块及消息持久化模块基于java责任链可以进行自由排列组合，例如消息生产-消息消费-消息持久、消息消费-消息生产(消息持久)等。由此用户可以针对不同的业务需求及交易场景构建自己的业务交易系统，同时通过java责任链和微服务架构系统可以将生产者、消费者、持久化模块灵活组合。
62.此外，工作流模块还用于通过java责任链将不同类型消息的消息生产和/或消息消费串联为原子交易模式的工作流。
63.需要说明的是，原子交易模式指代对消息生产和/或消息消费的各操作线程之间的逻辑和规则进行加锁，进而使得在面临大规模mq消息通讯场景的情况下，若干个mq消息可以有次序进行处理，进行实现高效的接收或发送的目的，另外由于消息生产模块及消息消费模块基于java责任链可以进行自由排列组合串联至工作流中，因此在进行高效的接收或发送的同时，还可以实现消息中心的收发灵活组合。
64.在另一实施例中，工作流模块还用于将业务逻辑等加工代码配置化加入java责任链中进一步扩展微服务架构系统功能，例如将转码、格式化报文组包等加工代码配置化加入java责任链中，实现转码、组包等功能，达到低成本且快速开发的效果。
65.本发明提供的支持多种类型消息的消息处理平台，包括spring底层框架及搭建于spring底层框架的至少一个消息处理框架，各消息处理框架与spring底层框架之间形成支持各消息处理框架对应的消息处理协议的微服务架构系统；在微服务架构系统接收到消息处理协议适配的mq消息请求的情况下，基于微服务架构系统建立的java线程池中的线程，并根据mq消息请求的需求参数配置工作流，以通过工作流响应mq消息请求，由此通过在spring底层框架多个消息处理框架实现多种类型mq消息的集成，且由于各消息处理框架对应的消息处理协议的微服务架构系统建立有各自的java线程池，进而通过各自的java线程池中的线程结合工作流达到高效的接收或发送mq消息的效果。
66.此外，本发明中还提出一种应用于本发明提出的支持多种类型消息的消息处理平台的安全漏洞管控方法，图2为本发明提供的安全漏洞管控方法的流程示意图之一，如图2所示，所述安全漏洞管控方法包括：
67.步骤100，在接收到携带消息报文的mq消息请求的情况下，对所述mq消息请求进行解析，并根据解析结果将所述mq消息请求下发至所述mq消息请求匹配的所述微服务架构系统；
68.具体地，对mq消息请求进行消息协议解析，以根据解析后得到的消息协议将mq消息请求下发至可处理该消息协议的mq消息的微服务架构系统，由此实现多种类型消息的高效接收。
69.步骤200，基于所述微服务架构系统的消息生产模块生产所述mq消息请求匹配的数据包，并将所述数据包发送至所述微服务架构系统的消息消费模块；
70.其中，数据包中的数据来源可以为mq消息请求中携带的数据，还可以为数据库中落地存储的数据，本实施中在进行数据包的生产时，还基于消息协议对数据进行协议转换后再组包成数据包进行发送。
71.步骤300，基于所述消息消费模块对所述数据包进行消费，并基于所述微服务架构系统的消息持久化模块对所述消息生产模块的生产记录及所述消息消费模块的消费记录进行持久化存储。
72.需要说明的是，由于消息生产模块在进行消息生产的过程中产生的生产记录及消息消费模块进行消息消费的过程中产生的消费记录是暂时存储于内存中，是不能永久保存的，因此为了避免后续便于消息追溯，本实施例中将生产记录及消费记录持久化至数据库或文本文件中进行长久存储。
73.图3示例了一种电子设备的实体结构示意图，如图3所示，该电子设备可以包括：处理器(processor)310、通信接口(communications interface)320、存储器(memory)330和
通信总线340，其中，处理器310，通信接口320，存储器330通过通信总线340完成相互间的通信。处理器310可以调用存储器330中的逻辑指令，以执行安全漏洞管控方法，该方法包括：在接收到携带消息报文的mq消息请求的情况下，对所述mq消息请求进行解析，并根据解析结果将所述mq消息请求下发至所述mq消息请求匹配的所述微服务架构系统；基于所述微服务架构系统的消息生产模块生产所述mq消息请求匹配的数据包，并将所述数据包发送至所述微服务架构系统的消息消费模块；基于所述消息消费模块对所述数据包进行消费，并基于所述微服务架构系统的消息持久化模块对所述消息生产模块的生产记录及所述消息消费模块的消费记录进行持久化存储。
74.此外，上述的存储器330中的逻辑指令可以通过软件功能单元的形式实现并作为独立的产品销售或使用时，可以存储在一个计算机可读取存储介质中。基于这样的理解，本发明的技术方案本质上或者说对现有技术做出贡献的部分或者该技术方案的部分可以以软件产品的形式体现出来，该计算机软件产品存储在一个存储介质中，包括若干指令用以使得一台计算机设备(可以是个人计算机，服务器，或者网络设备等)执行本发明各个实施例所述方法的全部或部分步骤。而前述的存储介质包括：u盘、移动硬盘、只读存储器(rom，read-only memory)、随机存取存储器(ram，random access memory)、磁碟或者光盘等各种可以存储程序代码的介质。
75.另一方面，本发明还提供一种计算机程序产品，所述计算机程序产品包括计算机程序，计算机程序可存储在非暂态计算机可读存储介质上，所述计算机程序被处理器执行时，计算机能够执行上述各方法所提供的安全漏洞管控方法，该方法包括：在接收到携带消息报文的mq消息请求的情况下，对所述mq消息请求进行解析，并根据解析结果将所述mq消息请求下发至所述mq消息请求匹配的所述微服务架构系统；基于所述微服务架构系统的消息生产模块生产所述mq消息请求匹配的数据包，并将所述数据包发送至所述微服务架构系统的消息消费模块；基于所述消息消费模块对所述数据包进行消费，并基于所述微服务架构系统的消息持久化模块对所述消息生产模块的生产记录及所述消息消费模块的消费记录进行持久化存储。
76.又一方面，本发明还提供一种非暂态计算机可读存储介质，其上存储有计算机程序，该计算机程序被处理器执行时实现以执行上述各方法提供的安全漏洞管控方法，该方法包括在接收到携带消息报文的mq消息请求的情况下，对所述mq消息请求进行解析，并根据解析结果将所述mq消息请求下发至所述mq消息请求匹配的所述微服务架构系统；基于所述微服务架构系统的消息生产模块生产所述mq消息请求匹配的数据包，并将所述数据包发送至所述微服务架构系统的消息消费模块；基于所述消息消费模块对所述数据包进行消费，并基于所述微服务架构系统的消息持久化模块对所述消息生产模块的生产记录及所述消息消费模块的消费记录进行持久化存储。
77.以上所描述的装置实施例仅仅是示意性的，其中所述作为分离部件说明的单元可以是或者也可以不是物理上分开的，作为单元显示的部件可以是或者也可以不是物理单元，即可以位于一个地方，或者也可以分布到多个网络单元上。可以根据实际的需要选择其中的部分或者全部模块来实现本实施例方案的目的。本领域普通技术人员在不付出创造性的劳动的情况下，即可以理解并实施。
78.通过以上的实施方式的描述，本领域的技术人员可以清楚地了解到各实施方式可
借助软件加必需的通用硬件平台的方式来实现，当然也可以通过硬件。基于这样的理解，上述技术方案本质上或者说对现有技术做出贡献的部分可以以软件产品的形式体现出来，该计算机软件产品可以存储在计算机可读存储介质中，如rom/ram、磁碟、光盘等，包括若干指令用以使得一台计算机设备(可以是个人计算机，服务器，或者网络设备等)执行各个实施例或者实施例的某些部分所述的方法。
79.最后应说明的是：以上实施例仅用以说明本发明的技术方案，而非对其限制；尽管参照前述实施例对本发明进行了详细的说明，本领域的普通技术人员应当理解：其依然可以对前述各实施例所记载的技术方案进行修改，或者对其中部分技术特征进行等同替换；而这些修改或者替换，并不使相应技术方案的本质脱离本发明各实施例技术方案的精神和范围。
技术特征：1.一种支持多种类型消息的消息处理平台，其特征在于，包括：spring底层框架及搭建于所述spring底层框架的至少一个消息处理框架；各所述消息处理框架与所述spring底层框架之间形成支持各所述消息处理框架对应的消息处理协议的微服务架构系统；在所述微服务架构系统接收到所述消息处理协议适配的mq消息请求的情况下，基于所述微服务架构系统建立的java线程池中的线程，并根据所述mq消息请求的需求参数配置工作流，以通过所述工作流响应所述mq消息请求。2.根据权利要求1所述的支持多种类型消息的消息处理平台，其特征在于，所述微服务架构系统包括消息生产模块、消息消费模块、消息持久化模块及工作流模块；所述消息消费模块用于对所述消息生产模块生产的至少一种协议的mq消息进行消费；所述消息持久化模块用于对所述消息消费模块的消费记录及所述消息生产模块的生产记录的进行持久化存储；所述工作流模块用于基于所述mq消息请求的需求参数，通过工作流的java责任链模式将所述消息生产模块、消息消费模块、消息持久化模块进行串联。3.根据权利要求2所述的支持多种类型消息的消息处理平台，其特征在于，所述消息消费模块还用于基于dubbo分布式服务框架或spring cloud分布式服务框架调用所述消息生产模块或所述消息持久化模块对消费后的消息内容进行消息持久。4.根据权利要求2所述的支持多种类型消息的消息处理平台，其特征在于，所述工作流模块还用于通过java责任链将不同类型消息的消息生产和/或消息消费串联为原子交易模式的工作流。5.根据权利要求2所述的支持多种类型消息的消息处理平台，其特征在于，所述消息持久化模块还用于将所述消息消费模块的消费记录落地至所述消费记录的数据类型匹配的数据库或文本文件中进行存储；以及，所述消息持久化模块还用于将所述消息生产模块的生产记录落地至所述生产记录的数据类型匹配的数据库或文本文件中进行存储。6.根据权利要求2所述的支持多种类型消息的消息处理平台，其特征在于，所述消息生产模块还用于在所述生产的至少一种协议的mq消息的数据来源为数据库中指定表的指定范围内的数据的情况下，通过java责任链顺序调用所述消费者模块进行数据处理；或者，所述消息生产模块还用于在所述生产的至少一种协议的mq消息的数据来源为数据库中指定表的指定范围内的数据的情况下，通过微服务模式调用所述消费者模块或所述消息持久化模块进行数据处理。7.根据权利要求1至6任一项所述的支持多种类型消息的消息处理平台，其特征在于，所述消息处理框架包括jms类消息处理框架、amqp类消息处理框架及kafka类消息处理框架中的至少一个。8.一种应用于权利要求1-7任一项所述的支持多种类型消息的消息处理平台的消息处理方法，其特征在于，包括：在接收到携带消息报文的mq消息请求的情况下，对所述mq消息请求进行解析，并根据解析结果将所述mq消息请求下发至所述mq消息请求匹配的所述微服务架构系统；
基于所述微服务架构系统的消息生产模块生产所述mq消息请求匹配的数据包，并将所述数据包发送至所述微服务架构系统的消息消费模块；基于所述消息消费模块对所述数据包进行消费，并基于所述微服务架构系统的消息持久化模块对所述消息生产模块的生产记录及所述消息消费模块的消费记录进行持久化存储。9.一种电子设备，包括存储器、处理器及存储在所述存储器上并可在所述处理器上运行的计算机程序，其特征在于，所述处理器执行所述程序时实现如权利要求8所述消息处理方法。10.一种非暂态计算机可读存储介质，其上存储有计算机程序，其特征在于，所述计算机程序被处理器执行时实现如权利要求8所述消息处理方法。
技术总结本发明提供一种支持多种类型消息的消息处理平台、方法、设备及介质，所述平台包括Spring底层框架及搭建于Spring底层框架的至少一个消息处理框架，各消息处理框架与Spring底层框架之间形成支持各消息处理框架对应的消息处理协议的微服务架构系统；在微服务架构系统接收到消息处理协议适配的MQ消息请求的情况下，基于微服务架构系统建立的java线程池中的线程，并根据MQ消息请求的需求参数配置工作流，以通过工作流响应MQ消息请求，由此通过多个消息处理框架实现多种类型MQ消息的集成，且通过各自微服务架构系统的java线程池中的线程结合工作流达到高效的接收或发送MQ消息的效果。的效果。的效果。
技术研发人员：杜庆 刘喆
受保护的技术使用者：中银金融科技有限公司
技术研发日：2022.06.15
技术公布日：2022/11/1
