消息处理方法、装置、电子设备及存储介质与流程

1.本技术涉及分布式系统、大数据平台领域，尤其涉及一种消息处理方法、装置、电子设备及存储介质。


背景技术：

2.应用程序的执行需要依赖于后台的服务器集群，一般应用程序可以运行于用户的终端设备以采集用户在应用程序发起的消息处理请求。终端设备将消息处理请求发送至服务器集群，服务器集群可以从应用程序对应的数据库中调用该消息处理请求涉及到的数据并执行相应的数据处理。为了提高服务器集群的处理数量，可以将服务器集群采用单元化架构进行配置，以增加应用程序的业务处理量。
3.单元化架构是指将单元作为系统部署的基本单位，系统对应服务器集群中部署若干单元，将系统的数据按照维度划分后存储于不同的单元，单元中还部署实现系统功能所需要的所有应用。例如，将用户标识为001-200的用户数据部署到单元a，将用户标识201-400的用户数据部署到单元b。之后，标识区间001-200内的消息处理请求即被分配到单元a执行，标识区间201-400的消息处理请求被分配到单元b执行。从而使得单元间的数据处理不相互影响，实现消息的快速处理。
4.由上述描述可知，目前消息的处理过程中，一般是以用户标识作为消息所对应目标单元的分配对象。金融消息由于消息种类和消息来源较为多样化，用户标识的种类也较为复杂，直接使用用户标识为消息分配其所对应的单元时，较为困难，导致金融消息的在单元化架构系统的分配失败率较高。


技术实现要素：

5.本技术提供一种消息处理方法、装置、电子设备及存储介质，用以解决金融消息在单元化架构系统的分配失败率较高的问题。
6.第一方面，本技术提供一种消息处理方法，包括：
7.确定至少一个消息中间件对应的至少一条消费映射信息，所述消费映射信息包括消息中间件和与所述消息中间件对应的所述消费服务接口；
8.从至少一个所述消息中间件中的目标消息中间件获取目标消息以及所述目标消息的单元分片信息；
9.根据至少一条所述消费映射信息，确定所述目标消息中间件对应的目标消费映射信息；
10.根据目标消费映射信息和所述单元分片信息，将所述目标消息发送至目标单元对应的目标消费服务接口；
11.接收所述目标单元反馈的所述目标消费服务接口对所述目标消息的消费处理结果。
12.第二方面，本技术提供一种消息处理装置，包括：
13.信息确定单元，用于确定至少一个消息中间件对应的至少一条消费映射信息，所述消费映射信息包括消息中间件和与所述消息中间件对应的所述消费服务接口；
14.分片确定单元，用于从至少一个所述消息中间件中的目标消息中间件获取目标消息以及所述目标消息的单元分片信息；
15.目标确定单元，用于根据至少一条所述消费映射信息，确定所述目标消息中间件对应的目标消费映射信息；
16.信息发送单元，用于根据目标消费映射信息和所述单元分片信息，将所述目标消息发送至目标单元对应的目标消费服务接口；
17.结果接收单元，用于接收所述目标单元反馈的所述目标消费服务接口对所述目标消息的消费处理结果。
18.第三方面，本技术提供一种电子设备，包括：处理器，以及与所述处理器通信连接的存储器；
19.所述存储器存储计算机执行指令；
20.所述处理器执行所述存储器存储的计算机执行指令，以实现如第一方面以及第一方面各种可能所述的方法。
21.第四方面，本技术提供一种计算机可读存储介质，所述计算机可读存储介质中存储有计算机执行指令，所述计算机执行指令被处理器执行时用于实现如第一方面以及第一方面各种可能所述的方法。
22.第五方面，本技术提供一种计算机程序产品，包括计算机程序，该计算机程序被处理器执行时实现如第一方面以及第一方面各种可能涉及的方法的步骤。
23.本技术提供的技术方案，可以确定至少一个消息中间件对应的至少一条消费映射信息，消费映射信息可以包括消息中间件和与消息中间件对应的消费服务接口。消费服务接口可以为消费消息的应用程序的接口。从至少一个消息中间件中的目标消息中间件获取目标消息以及目标消息的单元分片信息。进而从目标消息中间件获取目标消息。单元分片信息可以为目标消息所需要发送的单元的信息。继而根据目标消费映射信息和单元分片信息，可以将目标消息发送至目标单元对应的目标消费服务接口，也即通过将消息所需要发送的单元的单元信息一并发送，可以准确确定信息所对应的目标单元。同时，可以根据消费映射信息快速确定消息所在单元的消费服务接口。通过单元分片信息的携带和消费映射信息的设置，可以将目标消息准确分发，获得目标消费服务接口对目标消息的消费处理结果。提高消息的消费准确性和效率，实现对不同消息中间件的单元发送，扩展消息的应用场景，实现跨单元化架构系统的消息分配。
附图说明
24.此处的附图被并入说明书中并构成本说明书的一部分，示出了符合本技术的实施例，并与说明书一起用于解释本技术的原理。
25.图1为本技术实施例提供的一种用于实现消息处理方法的系统架构图；
26.图2为本技术实施例提供的一种消息处理方法的一个实施例的流程图；
27.图3为本技术实施例提供的一种消息处理方法的又一个实施例的流程图；
28.图4为本技术实施例提供的一种消息处理装置的一个实施例的结构示意图；
29.图5为本技术实施例提供的一种用于实现消息处理方法的电子设备的框图。
30.通过上述附图，已示出本技术明确的实施例，后文中将有更详细的描述。这些附图和文字描述并不是为了通过任何方式限制本技术构思的范围，而是通过参考特定实施例为本领域技术人员说明本技术的概念。
具体实施方式
31.这里将详细地对示例性实施例进行说明，其示例表示在附图中。下面的描述涉及附图时，除非另有表示，不同附图中的相同数字表示相同或相似的要素。以下示例性实施例中所描述的实施方式并不代表与本技术相一致的所有实施方式。相反，它们仅是与如所附权利要求书中所详述的、本技术的一些方面相一致的装置和方法的例子。
32.需要说明的是，本技术所涉及的用户信息(包括但不限于用户设备信息、用户个人信息等)和数据(包括但不限于用于分析的数据、存储的数据、展示的数据等)，均为经用户授权或者经过各方充分授权的信息和数据，并且相关数据的收集、使用和处理需要遵守相关法律法规和标准，并提供有相应的操作入口，供用户选择授权或者拒绝。
33.需要说明的是，本技术提供的消息处理方法、装置、电子设备及存储介质，可用于分布式系统、大数据平台等领域，也可用于除分布式系统、大数据平台领域之外的任意领域，本技术消息处理方法、装置、电子设备及存储介质的应用领域不做限定。
34.相关技术中，单元化架构系统一般可以包括多个单元，单元可以为系统中能够完成所有业务操作的自包含集合。集合内包含了所有业务所需要的所有服务，也即部署系统所需要的全部应用，此外，集合内还可以包括单元的全部数据。数据是全量数据按照预设维度划分获得的部分数据。通常，一个系统使用一套数据分片标准，按照此数据分片标准将全量数据划分为若干分片字段，每个分片字段为部分全量数据。数据分片标准是指数据的字段长度以及数据的划分频率。各分片字段可以被存储至单元中。应用程序在执行消息处理时，可以将消息分配到对应的单元进行处理。目前的消息分配，一般是基于数据分片的结果进行分配，例如用户标识100-200被分为一个片段，存储至单元a中，则用户标识134对应的消息则被分配到单元a进行消费。同时，消息的分配一般通过消息中间件实现，消息中间件可以接收消息提供方发送的消息，并将消息发送至消息消费方。但是，不同系统采用不同的数据分片标准，导致不同系统间的消息不能传输。
35.为了解决上述问题，本技术的技术方案，考虑将消息的处理接口和消息中间件进行对应，进而明确每个消息中间件对应的消费服务接口。在从目标消息中间件获取目标消息时，可以同步传输目标消息的单元分片信息，单元分片信息是指目标消息所要传输的单元的信息，通过单元分片信息可以实现目标消息的传输定位。通过单元和消费服务接口的双重定位可以实现目标消息的针对性传输，提高消息的传输效率和准确性。
36.本技术实施例中，可以确定至少一个消息中间件对应的至少一条消费映射信息，消费映射信息可以包括消息中间件和与消息中间件对应的消费服务接口。通过消费服务接口可以实现消息中间件的消息消费方的确定，通过消费服务接口可以对消息中间件的消费方的快速关联。通过从至少一个消息中间件中的目标消息中间件获取目标消息和目标消息的单元分片信息，以在获取目标消息的同时，获取目标消息的单元分片信息，实现对消息接收单元的快速定位。进而通过至少一个消费映射信息，确定目标消息中间件对应的目标消
费映射信息，根据目标消费映射信息和单元分片信息，可以将目标消息发送至目标单元对应的目标消费服务接口，以接收目标单元反馈的目标消费服务接口对目标消息的消费处理结果。通过对传输的单元和消费服务接口的定位，可以实现目标消息的快速传输，提高消息的传输效率和准确率。
37.本技术提供的消息处理方法，旨在解决现有技术的如上技术问题。
38.下面以具体地实施例对本技术的技术方案以及本技术的技术方案如何解决上述技术问题进行详细说明。下面这几个具体的实施例可以相互结合，对于相同或相似的概念或过程可能在某些实施例中不再赘述。下面将结合附图，对本技术的实施例进行描述。
39.为了便于理解，如图1所示，为本技术实施例提供的一种用于实现消息处理方法的系统架构图。该系统可以包括电子设备11，与电子设备11存在通信连接的至少一个消息中间件12，以及与电子设备11连接的至少一个服务器集群13，各消息中间件可以来源于不同的服务器集群或客户端，例如服务器集群a、b、c，每个服务器集群包括至少一个单元130。消息中间件可以为服务器集群中的消息队列。例如服务器集群a的消息中间件可以为消息中间件ax，服务器集群b的消息中间件可以为消息中间件bx，以及服务器集群c的消息中间件可以为消息中间件cx。当然，在实际应用中，各服务器集群13可以分别提供相应的处理功能，各服务器集群的消息中间件可以为该服务器集群提供消息存储和转发功能。
40.其中，电子设备11可以提供前端页面，以检测用户输入的至少一条消费映射消息，并将至少一条消费映射消息存储至数据库14。消费映射消息可以包括消息中间件和与消息中间件对应的消费服务接口。
41.电子设备11可以从至少一个消息中间件12的目标消息中间件121中获取目标消息以及目标消息的单元分片信息。根据至少一条消费映射信息，可以确定目标消息中间件对应的目标消费映射信息，以实现对目标消息中间件对应的消费方的确定。进而根据目标消费映射信息和单元分片信息，可以将目标消息发送至目标单元对应的目标消费服务接口，目标单元例如为1301，以实现目标消息的针对性发送，电子设备11还可以接收目标单元1301反馈的目标消费服务接口对目标消息的消费处理结果。通过对传输的单元和消费服务接口的定位，可以实现目标消息的快速传输，提高消息的传输效率和准确率。
42.如图2所示，为本技术实施例提供的一种消息处理方法的一个实施例的流程图，该方法可以配置为一消息处理装置，消息处理装置可以位于电子设备中，消息处理方法可以包括下列步骤：
43.s201：确定至少一个消息中间件对应的至少一条消费映射信息，消费映射信息包括消息中间件和与消息中间件对应的消费服务接口。
44.可选地，电子设备可以与至少一个消息中间件连接。消息中间件可以为服务器集群的消息队列。同一服务器集群中的节点可以作为生产方向消息中间件发送消息，同时，该服务器集群中的节点可以作为消费方从消息中间件拉取消息并消费。具体地，消费方节点可以通过将从消息中间件拉取的消费推送至消费服务接口，消费服务接口对应的程序可以消费该消息。
45.目前，由于服务器集群一般采用分片方式存储数据，具体是指，将服务器集群内部的存储空间分割为多个分片，并配置每个分片均能执行全部的处理功能。但是，不同服务器集群的分片方式不同，而任一个服务器集群并不能获知其它服务器集群的分片方式，而服
务器集群中消息中间件的消息消费需要依赖于服务器集群的分片架构，因此，一个服务器集群中的节点并不能直接消费其它服务器集群的消息中间件的消息。
46.电子设备可以确定至少一条消费映射信息，各条消费映射消息可以设置获得。消费映射信息可以包括消息中间件和与消息中间件对应的消费服务接口。
47.其中，消费映射信息中的消费服务接口可以是能够消费该消费映射信息中的消息中间件中的消息的程序接口。消费映射信息中的消息中间件与消费服务接口具备消费关联。
48.s202：从至少一个消息中间件中的目标消息中间件获取目标消息以及目标消息的单元分片信息。
49.目标消息中间件可以为至少一个消息中间件中的任意消息中间件。
50.目标消息的单元分片信息是指消费目标消息的目标单元的单元信息，例如，单元名称、单元地址、单元标识等信息。单元分片信息可以唯一标识单元，通过单元分片信息可以访问到相应的单元。
51.单元是指一个能够完成系统中所有业务操作的自包含集合，在该自包含集合内部署了系统正常运行所需要的全部应用，以及分配给单元的数据。数据可以是系统的全量数据按照一定的划分策略划分后存储至该单元的数据。系统可以是指服务器集群的软件集合，可以维持服务器集群的运转和服务。
52.可选地，数据划分策略具体可以包括数据的分片标准以及具体的分配字段，数据分片是指划分至同一单元的数据集合。一个单元的数据可以是指分配至该单元的数据分片。
53.通过单元分片信息可以指示发送的目标消息具体所需要被发送的翻译，通过单元分片信息可以准确定位到目标单元。
54.s203：根据至少一条消费映射信息，确定目标消息中间件对应的目标消费映射信息。
55.可选地，目标消息中间件可以为消息来源方，通过消息来源方确定目标消费映射信息，实现消息映射。
56.s204：根据目标消费映射信息和单元分片信息，将目标消息发送至目标单元对应的目标消费服务接口。
57.可选地，目标消费映射信息可以包括消息中间件和与消息中间件对应的消费服务接口。可以确定目标消息的消费服务接口。
58.s205：接收目标单元反馈的目标消费服务接口对目标消息的消费处理结果。
59.进一步地，在上述实施例的基础上，步骤204，可以包括：
60.根据目标消息关联的单元分片信息，确定目标消息对应的目标单元。
61.将目标消息发送至目标单元对应的目标消费服务接口。
62.本实施例中，目标消息关联的单元分片信息可以为消费目标消息的单元所对应的信息，进而可以通过单元分片信息确定目标消息对应的目标单元，在目标单元和目标消费服务接口都确定的情况下，可以将目标消息发送至目标单元对应的目标消费服务接口。通过明确单元和消费服务接口的与消息的对应关系，可以实现目标消息的准确发送，避免因单元和/或消费服务接口的对应关系不明确导致的发送失败或者发送混乱现象。
63.进一步地，在上述任一实施例的基础上，单元分片信息包括单元键值，根据目标消息关联的单元分片信息，确定目标消息对应的目标单元，包括：
64.将目标消息关联的单元键值输入单元标识计算公式，计算获得目标消息对应的目标单元标识，以确定目标单元标识对应的目标单元。
65.可选地，单元标识计算公式可以为单元键值到单元标识的转换公式。将单元键值输入到单元标识计算公式，可以计算获得单元标识。
66.单元标识计算公式可以根据单元键值和单元标识之间的转换规则确定。例如，单元键值为“10001”，单元标识计算公式例如可以为单元键值加数值u，则可以将10001+u获得的数值作为单元标识。又例如，单元标识计算公式可以为与系数a相乘加常数b，则可以将a*10001+b获得的数据作为单元标识。当然，该方式仅是示例性的，并不应构成对单元标识计算公式的具体限定，单元标识计算公式的详细公式可以根据使用需求设置。
67.本技术实施例中，使用单元键值作为单元分片信息，也即以键值对的形式存储各单元的分片信息，进而通过键值对的形式存储的单元的分片信息可以便于管理和查询，提高单元的查询效率。此外，单元键值可以通过单元标识计算方式，转换为目标消息对应的目标单元标识，以确定目标单元标识对应的目标单元。通过单元标识计算公式，可以将便于存储的单元键值转换为目标单元的目标单元标识，实现对单元分片信息的高效且便捷的使用。
68.进一步地，在上述任一实施例的基础上，根据目标消息关联的单元分片信息，确定目标消息对应的目标单元，包括：
69.根据目标消息关联的单元分片信息，确定目标消息关联的目标分片策略；
70.根据目标分片策略对应的标识设置算法，将单元分片信息转换为目标单元标识，以确定目标单元标识对应的目标单元。
71.可选地，目标分片策略可以是指对服务器集群中的全量数据设置的数据分片策略和服务器集群中存储空间的空间分片策略。数据分片策略可以包括数据字段的划分长度和数量等参数。空间分片策略可以包括服务器集群的存储空间的划分单位和数量等参数。此外，目标分片策略还可以包括各个分片的命名规则。分片之后，可以利用分片的命名规则对分片的数据片段或存储空间进行命名。分片之后，还可以将分片获得的数据片段存储至对应的存储空间，并将存储空间配置服务器集群正常运行所需要的应用程序，以获得相应的单元。
72.可选地，单元组建成功之后，可以为单元确定单元分片信息。单元分片信息可以包括单元标识，例如单元的访问地址、单元名称、单元编号等至少一种信息，通过单元分片信息可以访问对应的单元，并将消息传输至该单元。
73.本公开实施例中，可以通过单元分片信息，确定该单元分片信息对应的目标分片策略，以利用目标分片策略对应的标识设置算法，将单元分片信息转换为目标单元标识。通过分片策略的方式确定对应的标识设置算法，利用标识设置算法实现从单元分片信息到目标单元标识的转换。通过单元分片信息到目标单元标识的转换，可以实现目标单元的准确确定。此外，单元分片信息通过转换来确定目标单元标识，可以实现不同分片规则下的单元标识的统一访问，打通不同服务器集群的单元访问壁垒，实现消息在不同服务器集群的传输，提高消息传输范围和效率。
74.如图3所示，为本技术实施例提供的一种消息处理方法的信令图。
75.s301：电子设备接收用户输入的至少一个消息中间件和与各消息中间件存在消费关系的消费服务接口。
76.可选地，消息中间件可以与至少一个消费服务接口存在消费关系。也即，每个消息中间件可以关联至少一个消费服务接口。每个消息中间件的消费服务接口可以用于消费该消息中间件中的消息。
77.s302：基于与各消息中间件存在消费关系的消费服务接口，生成各消息中间件对应的消费映射信息。
78.消费映射信息可以包括至少一个。每个消费映射信息可以包括消息中间件和与消息中间件对应的消费映射信息。可以将存在消费关系的消息中间件和消费服务接口作为一条消费映射信息。
79.s303：将各消息中间件对应的消费映射信息存储至数据库。消费映射信息包括消息中间件和与消息中间件对应的消费服务接口。
80.数据库中可以存储至少一条消费映射信息。
81.s304：从数据库中读取至少一个消息中间件对应的至少一条消费映射信息。
82.每条消费映射信息可以关联消息中间件和消费服务接口。
83.s305：从至少一个消息中间件中的目标消息中间件获取目标消息以及目标消息的单元分片信息。
84.s306：根据至少一条消费映射信息，确定目标消息中间件对应的目标消费映射信息。
85.可选地，目标消息中间件对应的消费映射信息可以包括至少一个，可以将与消息中间件存在消费关系的至少一条消费映射信息均作为目标消费映射信息。当然也可以从与消息中间件存在消费关系的至少一条消费映射信息分别对应的消费服务接口中，确定能够消费目标消息的目标消费映射信息。例如，可以将目标消息的消息类型，与该至少一条消费映射信息分别对应的消费服务接口进行消息类型比较，将与目标消息的消息类型相同的消费服务接口对应的消费映射信息作为目标消费映射信息。
86.s307：根据目标消费映射信息和单元分片信息，将目标消息发送至目标单元对应的目标消费服务接口。
87.s308：接收目标单元反馈的目标消费服务接口对目标消息的消费处理结果。
88.本实施例中，通过采集消费映射信息并将消费映射信息存储至数据库，完成消费映射信息的建立。电子设备可以从数据库读取至少一条消费映射信息，以在获得目标消息中间件的目标消息以及目标消息的单元分片信息之后，可以根据至少一条消费映射信息，确定目标消息中间件对应的目标消费映射信息。通过至少一条消费映射信息可以对目标消息中间件对应的目标消费映射信息的获取，以根据目标消费映射信息和单元分片信息，定位到目标消息的目标单元。进而将目标消息发送至目标单元对应的目标消费服务接口。目标消费服务接口即可以完成对目标消息的消费，实现目标消息的快速而准确的消息定位传输，提高消息消费准确性和效率。
89.进一步地，在上述任一实施例的基础上，对于任一消息中间件，确定与消息中间件存在消费关系的至少一个消费服务接口，包括：
90.响应于用户对显示消费订阅输入页面执行的输入操作，获得用户输入的消息中间件以及消息中间件存在消费关系的至少一个消费服务接口。
91.可选地，电子设备可以显示消费订阅输入页面，可以检测用户针对消费订阅输入页面执行的输入操作，获得用户输入的消息中间件和与消息中间件对应的消费服务接口。其中，消费订阅输入页面中可以显示消息中间件的输入窗口和消费服务接口的输入窗口，上述两个输入窗口可以建立关联，从而使得用户输入消息中间件的信息和消费服务接口的信息，从而建立消息中间件和消费服务接口的消费关系。
92.本实施例中，可以通过显示用户对显示消费的订阅输入页面执行的输入操作，可以获得用户输入的消息中间件以及消息中间件对应的至少一个消费服务接口。利用与用户交互可以获取消费映射信息，提高用户对消费映射信息的把控效率，提高消费映射信息的准确性。
93.进一步地，在上述任一实施例的基础上，将目标消息发送至目标单元对应的目标消费服务接口，包括：
94.将目标消息进行消息封装处理，获得目标报文；
95.将目标报文发送至目标单元对应的目标消费服务接口。
96.可选地，目标消息可以是指与目标消息中间件对应服务器集群的存储格式存储的消息。而在实际应用中，目标消息可能并不能直接传输至另一服务器集群的目标单元。因此，可以按照目标单元对应的报文格式，将目标消息封装为目标报文。目标报文可以为目标单元能够支持的报文格式。
97.本实施例中，可以利用消息封装处理，将目标消息封装为目标报文，使得目标消息能够以目标报文的格式发送至目标消费服务接口，实现目标消息到目标消费服务接口的正常传输，确保消息正常传输，提高消息传输效率和有效性。
98.进一步地，在上述任一实施例的基础上，将目标消息发送至目标单元对应的目标消费服务接口，之后，还包括：
99.根据目标消息的发送时间和反馈接收时长，确定消费处理结果的接收时段；
100.在接收时段内，接收目标单元反馈的目标消费服务接口对目标消息的消费处理结果。
101.可选地，目标消息的发送时间是指目标消息发送至目标消息中间件的时间，也即目标消息中间件接收目标消息的时间。目标消息的发送时间还可以是指发送目标消息的单元的发送时间，具体可以是指发送目标消息的单元在发送目标消息时的发送时间。目标消息可以关联时间戳，时间戳具体可以为目标消息的发送时间。
102.可选地，反馈接收时长可以为一条消息从发送到接收到反馈结果的平均时长，可以通过历史发送的消息的反馈时长进行均值计算获得。
103.消息处理结果的接收时段的起始时刻为目标消息的发送时间，终止时刻为目标消息的发送时间和反馈接收时长之和所对应的接收时间。
104.在接收时段内，接收目标单元反馈的目标消费服务接口对目标消息的消费处理结果，可以包括：在接收时段的起始时刻之后，以及终止时刻之前，接收目标单元反馈的目标消费服务接口对目标消息的消费处理结果。
105.可选地，若在接收时段的终止时刻之后，仍未接收到目标单元反馈的目标消费服
务接口对目标消息的消费处理结果，则可以确定目标消息的消费状态为消费失败。
106.本实施例中，可以利用目标消息的发送时间和反馈接收时长，确定消费处理结果的接收时段。利用接收时段对目标消息的消费处理结果进行接收时间的约束，避免无限制等待接收目标消息的消费处理结果，进而对整个消息处理的流程产生负面影响，提高消息的处理效率并保障消息的正常处理流程。
107.进一步地，在上述任一实施例的基础上，还包括：
108.若在接收时段内接收到消费处理结果，则确定目标消息的消费状态为消费成功；
109.若在接收时段内未接收到消费处理结果，则确定目标消息的消费状态为消费失败；
110.将消费状态为消费失败的目标消息重新发送至对应的目标单元的目标消费服务接口，直至目标消息满足终止发送条件。
111.可选地，终止发送条件可以指目标消息的发送次数大于或等于最大发送次数或者目标消息的消费状态变更为消费成功。
112.本实施例中，通过对接收时段内是否接收到消费处理结果来确定目标消息的消费状态，实现对目标消息的消费状态管理。并将消费状态为消费失败的目标消息重新发送，直至目标消息满足终止发送条件。通过目标消息的消费状态监控，可以控制目标消息多次发送，提高消息发送成功率。
113.进一步地，在上述任一实施例的基础上，还包括：
114.在目标消息满足终止发送条件的情况下，确定目标消息的消费状态；
115.将目标消息的消费状态进行存储；
116.获取已存储消费状态的目标消息，并将已存储消费状态的目标消息中消费状态为消费失败的目标消息退回至目标消息中间件。
117.可选地，可以将目标消息的消费状态存储至状态数据库中，以从状态数据库中读取至少一条已存储消费状态的目标消息，并将已存储消费状态的目标消息中消费状态为消费失败的目标消息退回至目标消息中间件。
118.可选地，目标消息中间件接收到退回的目标消息之后，可以重新获取目标消息，并重新上述步骤201-205，实现新获得的目标消息的重新发送。通过目标消息的重新发送可以提高消息处理效率和有效性。当然，目标消息中间件接收到退回的目标消息之后，可以输出消息消费失败的提示信息至目标消息的提供方，并删除目标消息以释放本地存储空间。
119.本实施例中，确定目标消息满足终止发送条件时，可以确定目标消息的消费状态，并将目标消息的消费状态进行存储。通过目标消息的消费状态，可以对消费失败的目标消息进行退回，使得目标消息中间件及时获知相应的消息，以提高目标消息的管理效率。
120.如图4所示，为本技术实施例提供的一种消息处理装置的一个实施例的结构示意图，该消息处理装置400，可以包括：
121.信息确定单元401：用于确定至少一个消息中间件对应的至少一条消费映射信息，消费映射信息包括消息中间件和与消息中间件对应的消费服务接口；
122.分片确定单元402：用于从至少一个消息中间件中的目标消息中间件获取目标消息以及目标消息的单元分片信息；
123.目标确定单元403：用于根据至少一条消费映射信息，确定目标消息中间件对应的
目标消费映射信息；
124.信息发送单元404：用于根据目标消费映射信息和单元分片信息，将目标消息发送至目标单元对应的目标消费服务接口；
125.结果接收单元405：用于接收目标单元反馈的目标消费服务接口对目标消息的消费处理结果。
126.作为一个实施例，信息发送单元，包括：
127.单元确定模块，用于根据目标消息关联的单元分片信息，确定目标消息对应的目标单元；
128.消息发送模块，用于将目标消息发送至目标单元对应的目标消费服务接口。
129.作为又一个实施例，单元分片信息包括单元键值，单元确定模块，包括：
130.标识转换子模块，用于将目标消息关联的单元键值输入单元标识计算公式，计算获得目标消息对应的目标单元标识，以确定目标单元标识对应的目标单元。
131.作为又一个实施例，单元确定模块，包括：
132.策略确定子模块，用于根据目标消息关联的单元分片信息，确定目标消息关联的目标分片策略；
133.单元确定子模块，用于根据目标分片策略对应的标识设置算法，将单元分片信息转换为目标单元标识，以确定目标单元标识对应的目标单元。
134.作为又一个实施例，信息确定单元，包括：
135.映射读取模块，用于从数据库中读取至少一个消息中间件对应的至少一条消费映射信息；
136.还包括：
137.信息接收单元，用于接收用户输入的至少一个消息中间件和与各消息中间件存在消费关系的消费服务接口；
138.映射建立单元，用于基于与各消息中间件存在消费关系的消费服务接口，生成各消息中间件对应的消费映射信息；
139.映射存储单元，用于将各消息中间件对应的消费映射信息存储至数据库中。
140.作为又一个实施例，信息接收单元，包括：
141.页面显示模块，用于显示消费订阅输入页面；
142.操作相应模块，用于响应于用户对消费订阅输入页面执行的输入操作，获得用户输入的至少一个消息中间件；
143.接口检测模块，用于检测用户针对各消息中间件输入的消费服务接口。
144.作为又一个实施例，信息发送单元，包括：
145.报文转换模块，用于将目标消息进行消息封装处理，获得目标报文；
146.报文转发模块，用于将目标报文发送至目标单元对应的目标消费服务接口。
147.作为又一个实施例，还包括：
148.时段确定单元，用于根据目标消息的发送时间和反馈接收时长，确定消费处理结果的接收时段；
149.处理结果单元，用于在接收时段内，接收目标单元反馈的目标消费服务接口对目标消息的消费处理结果。
150.作为又一个实施例，还包括：
151.第一确定单元，用于若在接收时段内接收到消费处理结果，则确定目标消息的消费状态为消费成功；
152.第二确定单元，用于若在接收时段内未接收到消费处理结果，则确定目标消息的消费状态为消费失败；
153.消息重发单元，用于将消费状态为消费失败的目标消息重新发送至对应的目标单元的目标消费服务接口，直至目标消息满足终止发送条件。
154.作为又一个实施例，还包括：
155.状态确定单元，用于在目标消息满足终止发送条件的情况下，确定目标消息的消费状态；
156.状态存储单元，用于将目标消息的消费状态进行存储；
157.消息退回单元，用于获取已存储消费状态的目标消息，并将已存储消费状态的目标消息中消费状态为消费失败的目标消息退回至目标消息中间件。
158.图5是根据一示例性实施例示出的一种终端设备的框图，该设备可以是移动电话，计算机，数字广播终端，消息收发设备，游戏控制台，平板设备，医疗设备，健身设备，个人数字助理等。
159.装置500可以包括以下一个或多个组件：处理组件502，存储器504，电源组件506，多媒体组件508，音频组件510，输入/输出(i/o)接口512，传感器组件514，以及通信组件516。
160.处理组件502通常控制装置500的整体操作，诸如与显示，电话呼叫，数据通信，相机操作和记录操作相关联的操作。处理组件502可以包括一个或多个处理器520来执行指令，以完成上述的方法的全部或部分步骤。此外，处理组件502可以包括一个或多个模块，便于处理组件502和其他组件之间的交互。例如，处理组件502可以包括多媒体模块，以方便多媒体组件508和处理组件502之间的交互。
161.存储器504被配置为存储各种类型的数据以支持在装置500的操作。这些数据的示例包括用于在装置500上操作的任何应用程序或方法的指令，联系人数据，电话簿数据，消息，图片，视频等。存储器504可以由任何类型的易失性或非易失性存储设备或者它们的组合实现，如静态随机存取存储器(sram)，电可擦除可编程只读存储器(eeprom)，可擦除可编程只读存储器(eprom)，可编程只读存储器(prom)，只读存储器(rom)，磁存储器，快闪存储器，磁盘或光盘。
162.电源组件506为装置500的各种组件提供电力。电源组件506可以包括电源管理系统，一个或多个电源，及其他与为装置500生成、管理和分配电力相关联的组件。
163.多媒体组件508包括在装置500和用户之间的提供一个输出接口的屏幕。在一些实施例中，屏幕可以包括液晶显示器(lcd)和触摸面板(tp)。如果屏幕包括触摸面板，屏幕可以被实现为触摸屏，以接收来自用户的输入信号。触摸面板包括一个或多个触摸传感器以感测触摸、滑动和触摸面板上的手势。触摸传感器可以不仅感测触摸或滑动动作的边界，而且还检测与触摸或滑动操作相关的持续时间和压力。在一些实施例中，多媒体组件508包括一个前置摄像头和/或后置摄像头。当装置500处于操作模式，如拍摄模式或视频模式时，前置摄像头和/或后置摄像头可以接收外部的多媒体数据。每个前置摄像头和后置摄像头可
以是一个固定的光学透镜系统或具有焦距和光学变焦能力。
164.音频组件510被配置为输出和/或输入音频信号。例如，音频组件510包括一个麦克风(mic)，当装置500处于操作模式，如呼叫模式、记录模式和语音识别模式时，麦克风被配置为接收外部音频信号。所接收的音频信号可以被进一步存储在存储器504或经由通信组件516发送。在一些实施例中，音频组件510还包括一个扬声器，用于输出音频信号。
165.i/o接口512为处理组件502和外围接口模块之间提供接口，上述外围接口模块可以是键盘，点击轮，按钮等。这些按钮可包括但不限于：主页按钮、音量按钮、启动按钮和锁定按钮。
166.传感器组件514包括一个或多个传感器，用于为装置500提供各个方面的状态确定。例如，传感器组件514可以检测到装置500的打开/关闭状态，组件的相对定位，例如组件为装置500的显示器和小键盘，传感器组件514还可以检测装置500或装置500一个组件的位置改变，用户与装置500接触的存在或不存在，装置500方位或加速/减速和装置500的温度变化。传感器组件514可以包括接近传感器，被配置用来在没有任何的物理接触时检测附近物体的存在。传感器组件514还可以包括光传感器，如cmos或ccd图像传感器，用于在成像应用中使用。在一些实施例中，该传感器组件514还可以包括加速度传感器，陀螺仪传感器，磁传感器，压力传感器或温度传感器。
167.通信组件516被配置为便于装置500和其他设备之间有线或无线方式的通信。装置500可以接入基于通信标准的无线网络，如wifi，2g或3g，或它们的组合。在一个示例性实施例中，通信组件516经由广播信道接收来自外部广播管理系统的广播信号或广播相关信息。在一个示例性实施例中，通信组件516还包括近场通信(nfc)模块，以促进短程通信。例如，在nfc模块可基于射频识别(rfid)技术，红外数据协会(irda)技术，超宽带(uwb)技术，蓝牙(bt)技术和其他技术来实现。
168.在示例性实施例中，装置500可以被一个或多个应用专用集成电路(asic)、数字信号处理器(dsp)、数字信号处理设备(dspd)、可编程逻辑器件(pld)、现场可编程门阵列(fpga)、控制器、微控制器、微处理器或其他电子元件实现，用于执行上述方法。
169.在示例性实施例中，还提供了一种包括指令的非临时性计算机可读存储介质，例如包括指令的存储器504，上述指令可由装置500的处理器520执行以完成上述方法。例如，非临时性计算机可读存储介质可以是rom、随机存取存储器(ram)、cd-rom、磁带、软盘和光数据存储设备等。
170.本技术提供一种电子设备，包括：处理器，以及与处理器通信连接的存储器；
171.存储器存储计算机执行指令；
172.处理器执行存储器存储的计算机执行指令，以实现如上述任一实施例可能的方法。
173.本技术提供一种计算机可读存储介质，计算机可读存储介质中存储有计算机执行指令，计算机执行指令被处理器执行时用于实现如任一实施例可能的方法。
174.本技术提供一种计算机程序产品，包括计算机程序，该计算机程序被处理器执行时实现如任一实施例可能的方法。
175.本领域技术人员在考虑说明书及实践这里公开的发明后，将容易想到本技术的其它实施方案。本技术旨在涵盖本技术的任何变型、用途或者适应性变化，这些变型、用途或
者适应性变化遵循本技术的一般性原理并包括本技术未公开的本技术领域中的公知常识或惯用技术手段。说明书和实施例仅被视为示例性的，本技术的真正范围和精神由下面的权利要求书指出。
176.应当理解的是，本技术并不局限于上面已经描述并在附图中示出的精确结构，并且可以在不脱离其范围进行各种修改和改变。本技术的范围仅由所附的权利要求书来限制。

技术特征：
1.一种消息处理方法，其特征在于，包括：确定至少一个消息中间件对应的至少一条消费映射信息，所述消费映射信息包括消息中间件和与所述消息中间件对应的所述消费服务接口；从至少一个所述消息中间件中的目标消息中间件获取目标消息以及所述目标消息的单元分片信息；根据至少一条所述消费映射信息，确定所述目标消息中间件对应的目标消费映射信息；根据目标消费映射信息和所述单元分片信息，将所述目标消息发送至目标单元对应的目标消费服务接口；接收所述目标单元反馈的所述目标消费服务接口对所述目标消息的消费处理结果。2.根据权利要求1所述的方法，其特征在于，所述根据目标消费映射信息和所述单元分片信息，将所述目标消息发送至目标单元对应的目标消费服务接口，包括：根据所述目标消息关联的单元分片信息，确定所述目标消息对应的目标单元；将所述目标消息发送至所述目标单元对应的所述目标消费服务接口。3.根据权利要求2所述的方法，其特征在于，所述单元分片信息包括单元键值，所述根据所述目标消息关联的单元分片信息，确定所述目标消息对应的目标单元，包括：将所述目标消息关联的单元键值输入单元标识计算公式，计算获得所述目标消息对应的目标单元标识，以确定所述目标单元标识对应的目标单元。4.根据权利要求2所述的方法，其特征在于，所述根据所述目标消息关联的单元分片信息，确定所述目标消息对应的目标单元，包括：根据所述目标消息关联的单元分片信息，确定所述目标消息关联的目标分片策略；根据所述目标分片策略对应的标识设置算法，将所述单元分片信息转换为目标单元标识，以确定所述目标单元标识对应的目标单元。5.根据权利要求1所述的方法，其特征在于，所述确定至少一个消息中间件对应的至少一条消费映射信息，包括：从数据库中读取至少一个所述消息中间件对应的至少一条所述消费映射信息；所述数据库的建立步骤包括：接收用户输入的至少一个消息中间件和与各消息中间件存在消费关系的消费服务接口；基于与各消息中间件存在消费关系的消费服务接口，生成各消息中间件对应的消费映射信息；将各消息中间件对应的所述消费映射信息存储至所述数据库中。6.根据权利要求5所述的方法，其特征在于，所述接收用户输入的至少一个消息中间件和与各消息中间件存在消费关系的消费服务接口，包括：显示消费订阅输入页面；响应于用户对所述消费订阅输入页面执行的输入操作，获得所述用户输入的至少一个消息中间件；检测所述用户针对各消息中间件输入的所述消费服务接口。7.根据权利要求1所述的方法，其特征在于，所述将所述目标消息发送至目标单元对应
的目标消费服务接口，包括：将所述目标消息进行消息封装处理，获得目标报文；将所述目标报文发送至所述目标单元对应的目标消费服务接口。8.根据权利要求1所述的方法，其特征在于，所述将所述目标消息发送至目标单元对应的目标消费服务接口，之后，还包括：根据所述目标消息的发送时间和反馈接收时长，确定所述消费处理结果的接收时段；在所述接收时段内，接收所述目标单元反馈的所述目标消费服务接口对所述目标消息的消费处理结果。9.根据权利要求8所述的方法，其特征在于，还包括：若在所述接收时段内接收到所述消费处理结果，则确定所述目标消息的消费状态为消费成功；若在所述接收时段内未接收到所述消费处理结果，则确定所述目标消息的消费状态为消费失败；将消费状态为消费失败的目标消息重新发送至对应的目标单元的目标消费服务接口，直至所述目标消息满足终止发送条件。10.根据权利要求9所述的方法，其特征在于，还包括：在所述目标消息满足终止发送条件的情况下，确定所述目标消息的消费状态；将所述目标消息的消费状态进行存储；获取已存储消费状态的目标消息，并将已存储消费状态的目标消息中消费状态为消费失败的目标消息退回至所述目标消息中间件。11.一种消息处理装置，其特征在于，包括：信息确定单元，用于确定至少一个消息中间件对应的至少一条消费映射信息，所述消费映射信息包括消息中间件和与所述消息中间件对应的所述消费服务接口；分片确定单元，用于从至少一个所述消息中间件中的目标消息中间件获取目标消息以及所述目标消息的单元分片信息；目标确定单元，用于根据至少一条所述消费映射信息，确定所述目标消息中间件对应的目标消费映射信息；信息发送单元，用于根据目标消费映射信息和所述单元分片信息，将所述目标消息发送至目标单元对应的目标消费服务接口；结果接收单元，用于接收所述目标单元反馈的所述目标消费服务接口对所述目标消息的消费处理结果。12.一种电子设备，其特征在于，包括：处理器，以及与所述处理器通信连接的存储器；所述存储器存储计算机执行指令；所述处理器执行所述存储器存储的计算机执行指令，以实现如权利要求1至10任一项所述的方法。13.一种计算机可读存储介质，其特征在于，所述计算机可读存储介质中存储有计算机执行指令，所述计算机执行指令被处理器执行时用于实现如权利要求1至10任一项所述的方法。

技术总结
本申请提供一种消息处理方法、装置、电子设备及存储介质，可用于分布式系统、大数据平台等领域。该方法包括：确定至少一个消息中间件对应的至少一条消费映射信息，所述消费映射信息包括消息中间件和与所述消息中间件对应的所述消费服务接口；从至少一个所述消息中间件中的目标消息中间件获取目标消息以及所述目标消息的单元分片信息；根据至少一条所述消费映射信息，确定所述目标消息中间件对应的目标消费映射信息；根据目标消费映射信息和所述单元分片信息，将所述目标消息发送至目标单元对应的目标消费服务接口；接收所述目标单元反馈的所述目标消费服务接口对所述目标消息的消费处理结果。本申请的方法，提高消息的传输效率和准确性。效率和准确性。效率和准确性。


技术研发人员：雷声 刘新兰 赵春晖 王艺羲 王婧 梁文婧 朱伟 杨涛 王丹
受保护的技术使用者：中国银行股份有限公司
技术研发日：2023.06.05
技术公布日：2023/8/21