消息管理方法、系统、电子设备、存储介质及程序产品与流程

1.本公开实施例涉及数据处理技术领域，具体涉及一种消息管理方法、系统、电子设备、存储介质及程序产品。

背景技术：

2.随着科学技术的发展，消息的生产和消费的应用越来越普遍。在消息生产和消费系统中，消息由消息生产者经消息管理装置发往消息消费者，在这个流程中，若想要衡量端至端之间的消息传输延时，或者当发生消息传输错误时对于传输错误点进行定位，需要对于传输的消息进行跟踪。现有技术中，通常借助traceid对于消息进行跟踪，但该方式需要对于整个消息生产和消费系统进行设置或改造，不仅操作复杂，还需要较高的时间成本。

技术实现要素：

3.本公开实施例提供一种消息管理方法、系统、电子设备、存储介质及程序产品。
4.第一方面，本公开实施例中提供了一种消息管理方法。
5.具体的，所述消息管理方法，包括：
6.消息生产者将生产的消息上传至消息管理装置存储，并生成相应的消息生产日志文件，其中，所述消息生产日志文件携带有消息上传请求标识信息和/或消息标识信息，所述消息上传请求标识信息与消息标识信息相对应；
7.所述消息管理装置将存储的消息下发至消息消费者，并生成相应的消息消费日志文件，其中，所述消息消费日志文件携带有消息标识信息；
8.响应于接收到消息管理请求，获取所述消息管理请求中携带的目标消息标识信息，并根据所述目标消息标识信息获取对应目标消息的轨迹数据。
9.结合第二方面，本公开实施例在第二方面的第一种实现方式中，所述消息生产者将生产的消息上传至消息管理装置存储，并生成相应的消息生产日志文件，包括：
10.消息生产者基于生产者标识信息生成建立消息上传通道请求，发送给消息管理装置；
11.所述消息管理装置响应于接收到所述建立消息上传通道请求，基于所述建立消息上传通道请求携带的生产者标识信息对于所述消息生产者进行身份鉴权，身份鉴权通过后，建立与所述消息生产者之间的消息上传通道，并向所述消息生产者发送消息上传通道已建立通知消息；
12.所述消息生产者响应于接收到消息上传通道已建立通知消息，使用建立的所述消息上传通道向所述消息管理装置发送消息上传请求，其中，所述消息上传请求携带有消息上传请求标识信息和消息本体，并在发送完成之后生成第一消息生产日志文件，其中，所述第一消息生产日志文件包含消息上传请求标识信息；
13.消息管理装置响应于接收到所述消息上传请求，为所述消息本体设置消息标识信息，生成第二消息生产日志文件，其中，所述第二消息生产日志文件包含所述消息标识信息
和消息上传请求标识信息；
14.所述消息管理装置对于所述消息上传请求携带的消息本体进行存储，并在存储完成之后向所述消息生产者发送消息存储成功通知消息，生成第三消息生产日志文件，其中，所述第三消息生产日志文件包含所述消息标识信息和消息上传请求标识信息；
15.所述消息生产者响应于接收到所述消息存储成功通知消息，生成第四消息生产日志文件，其中，所述第四消息生产日志文件包含所述消息标识信息和消息上传请求标识信息。
16.结合第二方面和第二方面的第一种实现方式，本公开实施例在第二方面的第二种实现方式中，所述消息生产者生成第一消息生产日志文件之后，还包括：
17.利用所述消息上传请求标识信息对于所述第一消息生产日志文件进行去重。
18.结合第二方面、第二方面的第一种实现方式和第二方面的第二种实现方式，本公开在第二方面的第三种实现方式中，所述消息管理装置将存储的消息下发至消息消费者，并生成相应的消息消费日志文件，包括：
19.消息消费者基于消费者标识信息生成建立消息消费通道请求，发送给消息管理装置；
20.所述消息管理装置响应于接收到所述建立消息消费通道请求，基于所述建立消息消费通道请求携带的消费者标识信息对于所述消息消费者进行身份鉴权，身份鉴权通过后，建立与所述消息消费者之间的消息消费通道，并向所述消息消费者发送消息消费通道已建立通知消息；
21.所述消息消费者响应于接收到消息消费通道已建立通知消息，使用建立的所述消息消费通道向所述消息管理装置发送消息消费请求，其中，所述消息消费请求中携带订阅消息属性信息；
22.所述消息管理装置接收到与所述订阅消息属性信息匹配的订阅消息后，将所述订阅消息即时或定时通过所述消息消费通道发送给所述消息消费者，生成第一消息消费日志文件，其中，所述第一消息消费日志文件包含订阅消息标识信息；
23.所述消息消费者响应于通过所述消息消费通道接收到所述订阅消息，生成第二消息消费日志文件，其中，所述第二消息消费日志文件包含订阅消息标识信息；并向所述消息管理装置发送订阅消息接收成功反馈消息，生成第三消息消费日志文件，其中，所述第三消息消费日志文件包含订阅消息标识信息；
24.所述消息管理装置响应于接收到所述订阅消息接收成功反馈消息，生成第四消息消费日志文件，其中，所述第四消息消费日志文件包含订阅消息标识信息。
25.结合第二方面、第二方面的第一种实现方式、第二方面的第二种实现方式和第二方面的第三种实现方式，本公开在第二方面的第四种实现方式中，所述消息管理装置将存储的消息下发至消息消费者，并生成相应的消息消费日志文件，包括：
26.消息消费者基于消费者标识信息生成建立消息消费通道请求，发送给消息管理装置；
27.所述消息管理装置响应于接收到所述建立消息消费通道请求，基于所述建立消息消费通道请求携带的消费者标识信息对于所述消息消费者进行身份鉴权，身份鉴权通过后，建立与所述消息消费者之间的消息消费通道，并向所述消息消费者发送消息消费通道
已建立通知消息；
28.所述消息消费者响应于接收到消息消费通道已建立通知消息，使用建立的所述消息消费通道即时或定时向所述消息管理装置发送消息消费请求，其中，所述消息消费请求中携带订阅消息属性信息；
29.所述消息管理装置将存储的、与所述订阅消息属性信息匹配的订阅消息，通过所述消息消费通道发送给所述消息消费者，生成第五消息消费日志文件，其中，所述第五消息消费日志文件包含订阅消息标识信息；
30.所述消息消费者响应于通过所述消息消费通道接收到所述订阅消息，生成第六消息消费日志文件，其中，所述第六消息消费日志文件包含订阅消息标识信息；并向所述消息管理装置发送订阅消息接收成功反馈消息，生成第七消息消费日志文件，其中，所述第七消息消费日志文件包含订阅消息标识信息；
31.所述消息管理装置响应于接收到所述订阅消息接收成功反馈消息，生成第八消息消费日志文件，其中，所述第八消息消费日志文件包含订阅消息标识信息。
32.结合第二方面、第二方面的第一种实现方式、第二方面的第二种实现方式、第二方面的第三种实现方式和第二方面的第四种实现方式，本公开在第二方面的第五种实现方式中，在所述消息消费者响应于接收到消息消费通道已建立通知消息，使用建立的所述消息消费通道即时或定时向所述消息管理装置发送消息消费请求之后，当所述消息管理装置确定当前存储的消息中并无与所述订阅消息属性信息匹配的消息时，通过所述消息消费通道向所述消息消费者发送无订阅消息通知消息。
33.结合第二方面、第二方面的第一种实现方式、第二方面的第二种实现方式、第二方面的第三种实现方式、第二方面的第四种实现方式和第二方面的第五种实现方式，本公开在第二方面的第六种实现方式中，所述根据所述目标消息标识信息获取对应目标消息的轨迹数据，包括：
34.根据所述目标消息标识信息查询所述消息生产日志文件和消息消费日志文件，获取包含所述目标消息标识信息，或者包括相应消息上传请求标识信息的消息生产日志文件和消息消费日志文件，其中，所述相应消息上传请求标识信息为与所述目标消息标识信息存在关联关系的消息上传请求标识信息；
35.根据所述消息生产日志文件和消息消费日志文件确定所述目标消息的轨迹数据。
36.第二方面，本公开实施例中提供了一种消息管理装置。
37.具体的，所述消息管理装置，包括：
38.消息生产者，被配置为将生产的消息上传至消息管理装置存储，并生成相应的消息生产日志文件，其中，所述消息生产日志文件携带有消息上传请求标识信息和/或消息标识信息，所述消息上传请求标识信息与消息标识信息相对应；
39.消息管理装置，被配置为将存储的消息下发至消息消费者，并生成相应的消息消费日志文件，其中，所述消息消费日志文件携带有消息标识信息；响应于接收到消息管理请求，获取所述消息管理请求中携带的目标消息标识信息，并根据所述目标消息标识信息获取对应目标消息的轨迹数据。
40.结合第二方面，本公开实施例在第二方面的第一种实现方式中，所述消息生产者将生产的消息上传至消息管理装置存储，并生成相应的消息生产日志文件的部分，被配置
为：
41.消息生产者基于生产者标识信息生成建立消息上传通道请求，发送给消息管理装置；
42.所述消息管理装置响应于接收到所述建立消息上传通道请求，基于所述建立消息上传通道请求携带的生产者标识信息对于所述消息生产者进行身份鉴权，身份鉴权通过后，建立与所述消息生产者之间的消息上传通道，并向所述消息生产者发送消息上传通道已建立通知消息；
43.所述消息生产者响应于接收到消息上传通道已建立通知消息，使用建立的所述消息上传通道向所述消息管理装置发送消息上传请求，其中，所述消息上传请求携带有消息上传请求标识信息和消息本体，并在发送完成之后生成第一消息生产日志文件，其中，所述第一消息生产日志文件包含消息上传请求标识信息；
44.消息管理装置响应于接收到所述消息上传请求，为所述消息本体设置消息标识信息，生成第二消息生产日志文件，其中，所述第二消息生产日志文件包含所述消息标识信息和消息上传请求标识信息；
45.所述消息管理装置对于所述消息上传请求携带的消息本体进行存储，并在存储完成之后向所述消息生产者发送消息存储成功通知消息，生成第三消息生产日志文件，其中，所述第三消息生产日志文件包含所述消息标识信息和消息上传请求标识信息；
46.所述消息生产者响应于接收到所述消息存储成功通知消息，生成第四消息生产日志文件，其中，所述第四消息生产日志文件包含所述消息标识信息和消息上传请求标识信息。
47.结合第二方面和第二方面的第一种实现方式，本公开实施例在第二方面的第二种实现方式中，所述消息生产者生成第一消息生产日志文件的部分之后，还被配置为：
48.利用所述消息上传请求标识信息对于所述第一消息生产日志文件进行去重。
49.结合第二方面、第二方面的第一种实现方式和第二方面的第二种实现方式，本公开在第二方面的第三种实现方式中，所述消息管理装置将存储的消息下发至消息消费者，并生成相应的消息消费日志文件的部分，被配置为：
50.消息消费者基于消费者标识信息生成建立消息消费通道请求，发送给消息管理装置；
51.所述消息管理装置响应于接收到所述建立消息消费通道请求，基于所述建立消息消费通道请求携带的消费者标识信息对于所述消息消费者进行身份鉴权，身份鉴权通过后，建立与所述消息消费者之间的消息消费通道，并向所述消息消费者发送消息消费通道已建立通知消息；
52.所述消息消费者响应于接收到消息消费通道已建立通知消息，使用建立的所述消息消费通道向所述消息管理装置发送消息消费请求，其中，所述消息消费请求中携带订阅消息属性信息；
53.所述消息管理装置接收到与所述订阅消息属性信息匹配的订阅消息后，将所述订阅消息即时或定时通过所述消息消费通道发送给所述消息消费者，生成第一消息消费日志文件，其中，所述第一消息消费日志文件包含订阅消息标识信息；
54.所述消息消费者响应于通过所述消息消费通道接收到所述订阅消息，生成第二消
息消费日志文件，其中，所述第二消息消费日志文件包含订阅消息标识信息；并向所述消息管理装置发送订阅消息接收成功反馈消息，生成第三消息消费日志文件，其中，所述第三消息消费日志文件包含订阅消息标识信息；
55.所述消息管理装置响应于接收到所述订阅消息接收成功反馈消息，生成第四消息消费日志文件，其中，所述第四消息消费日志文件包含订阅消息标识信息。
56.结合第二方面、第二方面的第一种实现方式、第二方面的第二种实现方式和第二方面的第三种实现方式，本公开在第二方面的第四种实现方式中，所述消息管理装置将存储的消息下发至消息消费者，并生成相应的消息消费日志文件的部分，被配置为：
57.消息消费者基于消费者标识信息生成建立消息消费通道请求，发送给消息管理装置；
58.所述消息管理装置响应于接收到所述建立消息消费通道请求，基于所述建立消息消费通道请求携带的消费者标识信息对于所述消息消费者进行身份鉴权，身份鉴权通过后，建立与所述消息消费者之间的消息消费通道，并向所述消息消费者发送消息消费通道已建立通知消息；
59.所述消息消费者响应于接收到消息消费通道已建立通知消息，使用建立的所述消息消费通道即时或定时向所述消息管理装置发送消息消费请求，其中，所述消息消费请求中携带订阅消息属性信息；
60.所述消息管理装置将存储的、与所述订阅消息属性信息匹配的订阅消息，通过所述消息消费通道发送给所述消息消费者，生成第五消息消费日志文件，其中，所述第五消息消费日志文件包含订阅消息标识信息；
61.所述消息消费者响应于通过所述消息消费通道接收到所述订阅消息，生成第六消息消费日志文件，其中，所述第六消息消费日志文件包含订阅消息标识信息；并向所述消息管理装置发送订阅消息接收成功反馈消息，生成第七消息消费日志文件，其中，所述第七消息消费日志文件包含订阅消息标识信息；
62.所述消息管理装置响应于接收到所述订阅消息接收成功反馈消息，生成第八消息消费日志文件，其中，所述第八消息消费日志文件包含订阅消息标识信息。
63.结合第二方面、第二方面的第一种实现方式、第二方面的第二种实现方式、第二方面的第三种实现方式和第二方面的第四种实现方式，本公开在第二方面的第五种实现方式中，所述消息消费者响应于接收到消息消费通道已建立通知消息，使用建立的所述消息消费通道即时或定时向所述消息管理装置发送消息消费请求的部分之后，所述消息消费者还被配置为：
64.当所述消息管理装置确定当前存储的消息中并无与所述订阅消息属性信息匹配的消息时，通过所述消息消费通道向所述消息消费者发送无订阅消息通知消息。
65.结合第二方面、第二方面的第一种实现方式、第二方面的第二种实现方式、第二方面的第三种实现方式、第二方面的第四种实现方式和第二方面的第五种实现方式，本公开在第二方面的第六种实现方式中，所述根据所述目标消息标识信息获取对应目标消息的轨迹数据的部分，被配置为：
66.根据所述目标消息标识信息查询所述消息生产日志文件和消息消费日志文件，获取包含所述目标消息标识信息，或者包括相应消息上传请求标识信息的消息生产日志文件
和消息消费日志文件，其中，所述相应消息上传请求标识信息为与所述目标消息标识信息存在关联关系的消息上传请求标识信息；
67.根据所述消息生产日志文件和消息消费日志文件确定所述目标消息的轨迹数据。
68.第三方面，本公开实施例提供了一种电子设备，包括存储器和处理器，所述存储器用于存储一条或多条支持消息管理装置执行上述消息管理方法的计算机指令，所述处理器被配置为用于执行所述存储器中存储的计算机指令。所述消息管理装置还可以包括通信接口，用于消息管理装置与其他设备或通信网络通信。
69.第四方面，本公开实施例提供了一种计算机可读存储介质，用于存储消息管理装置所用的计算机指令，其包含用于执行上述消息管理方法为消息管理装置所涉及的计算机指令。
70.第五方面，本公开实施例提供了一种计算机程序产品，包括计算机程序/指令，该计算机程序/指令被处理器执行时实现上述消息管理方法的步骤。
71.本公开实施例提供的技术方案可包括以下有益效果：
72.上述技术方案通过在消息生产和消费过程中生成相应的日志文件，并在日志文件中嵌入消息上传请求标识信息和/或消息标识信息，以借助上传请求标识信息和/或消息标识信息实现对于消息传输的跟踪。该技术方案实现简单，时间成本低，操作方便，能够有效衡量端至端之间的消息传输延时，当发生消息传输错误时能够对于传输错误点进行定位。
73.应当理解的是，以上的一般描述和后文的细节描述仅是示例性和解释性的，并不能限制本公开实施例。
附图说明
74.结合附图，通过以下非限制性实施方式的详细描述，本公开实施例的其它特征、目的和优点将变得更加明显。在附图中：
75.图1示出根据本公开一实施方式的消息管理方法的流程图；
76.图2示出根据本公开一实施方式的消息管理系统的系统框图；
77.图3示出根据本公开一实施方式的电子设备的结构框图；
78.图4是适于用来实现根据本公开一实施方式的消息管理方法的计算机系统的结构示意图。
具体实施方式
79.下文中，将参考附图详细描述本公开实施例的示例性实施方式，以使本领域技术人员可容易地实现它们。此外，为了清楚起见，在附图中省略了与描述示例性实施方式无关的部分。
80.在本公开实施例中，应理解，诸如“包括”或“具有”等的术语旨在指示本说明书中所公开的特征、数字、步骤、行为、部件、部分或其组合的存在，并且不欲排除一个或多个其他特征、数字、步骤、行为、部件、部分或其组合存在或被添加的可能性。
81.另外还需要说明的是，在不冲突的情况下，本公开中的实施例及实施例中的特征可以相互组合。下面将参考附图并结合实施例来详细说明本公开实施例。
82.本公开实施例提供的技术方案通过在消息生产和消费过程中生成相应的日志文
件，并在日志文件中嵌入消息上传请求标识信息和/或消息标识信息，以借助上传请求标识信息和/或消息标识信息实现对于消息传输的跟踪。该技术方案实现简单，时间成本低，操作方便，能够有效衡量端至端之间的消息传输延时，当发生消息传输错误时能够对于传输错误点进行定位。
83.图1示出根据本公开一实施方式的消息管理方法的流程图，如图1所示，所述消息管理方法包括以下步骤s101-s103：
84.在步骤s101中，消息生产者将生产的消息上传至消息管理装置存储，并生成相应的消息生产日志文件，其中，所述消息生产日志文件携带有消息上传请求标识信息和/或消息标识信息，所述消息上传请求标识信息与消息标识信息相对应；
85.在步骤s102中，所述消息管理装置将存储的消息下发至消息消费者，并生成相应的消息消费日志文件，其中，所述消息消费日志文件携带有消息标识信息；
86.在步骤s103中，响应于接收到消息管理请求，获取所述消息管理请求中携带的目标消息标识信息，并根据所述目标消息标识信息获取对应目标消息的轨迹数据。
87.上文提及，随着科学技术的发展，消息的生产和消费的应用越来越普遍。在消息生产和消费系统中，消息由消息生产者经消息管理装置发往消息消费者，在这个流程中，若想要衡量端至端之间的消息传输延时，或者当发生消息传输错误时对于传输错误点进行定位，需要对于传输的消息进行跟踪。现有技术中，通常借助traceid对于消息进行跟踪，但该方式需要对于整个消息生产和消费系统进行设置或改造，不仅操作复杂，还需要较高的时间成本。
88.考虑到上述问题，在该实施方式中，提出一种消息管理方法，该方法通过在消息生产和消费过程中生成相应的日志文件，并在日志文件中嵌入消息上传请求标识信息和/或消息标识信息，以借助上传请求标识信息和/或消息标识信息实现对于消息传输的跟踪。该技术方案实现简单，时间成本低，操作方便，能够有效衡量端至端之间的消息传输延时，当发生消息传输错误时能够对于传输错误点进行定位。
89.在本公开一实施方式中，所述消息管理方法可适用于对于消息进行管理的，包括消息生产者、消息管理装置和消息消费者的消息管理系统。根据本公开一实施方式的消息管理系统的系统框图如图2所示。
90.在本公开一实施方式中，所述消息生产日志文件指的是在消息生产者生产出消息，并将消息上传至消息管理装置处进行存储的过程中生成的、用于对于消息的生产和传输状态，比如生产时间、传输时间、传输端，进行日志记录的文件。其中，为了对于消息的上传和消息本身进行识别，所述消息生产日志文件中需携带有消息上传请求标识信息和/或消息标识信息，且所述消息上传请求标识信息与消息标识信息存在对应关系，以借助消息标识信息确定相应的消息上传请求标识信息，借助消息上传请求标识信息确定相应的消息标识信息，便于后续对于消息的跟踪。
91.在本公开一实施方式中，所述消息消费日志文件指的是在消息管理装置将消息消费者订阅的消息发送给消息消费者，消息消费者接收到订阅消息的过程中生成的、用于对于消息的消费和传输状态，比如消费时间、传输时间、传输端进行日志记录的文件。其中，为了对于消息的消费和消息本身进行识别，所述消息消费日志文件中需携带有消息标识信息，以借助消息标识信息实现对于消息的跟踪。
92.在上述实施方式中，消息生产者将生产的消息上传至消息管理装置进行存储，并在消息上传和存储的过程中生成相应的、携带有具有对应关系的消息上传请求标识信息和/或消息标识信息的消息生产日志文件；后续在消息管理装置将存储的消息下发至消息消费者的过程中，还生成相应的、携带有消息标识信息的消息消费日志文件；这样，在接受到消息管理请求后，就可根据所述消息管理请求中携带的目标消息标识信息，获取对应目标消息的轨迹数据，实现对于目标消息的跟踪。
93.在本公开一实施方式中，所述步骤s101，即消息生产者将生产的消息上传至消息管理装置存储，并生成相应的消息生产日志文件的步骤，可包括以下步骤：
94.消息生产者基于生产者标识信息生成建立消息上传通道请求，发送给消息管理装置；
95.所述消息管理装置响应于接收到所述建立消息上传通道请求，基于所述建立消息上传通道请求携带的生产者标识信息对于所述消息生产者进行身份鉴权，身份鉴权通过后，建立与所述消息生产者之间的消息上传通道，并向所述消息生产者发送消息上传通道已建立通知消息；
96.所述消息生产者响应于接收到消息上传通道已建立通知消息，使用建立的所述消息上传通道向所述消息管理装置发送消息上传请求，其中，所述消息上传请求携带有消息上传请求标识信息和消息本体，并在发送完成之后生成第一消息生产日志文件，其中，所述第一消息生产日志文件包含消息上传请求标识信息；
97.消息管理装置响应于接收到所述消息上传请求，为所述消息本体设置消息标识信息，生成第二消息生产日志文件，其中，所述第二消息生产日志文件包含所述消息标识信息和消息上传请求标识信息；
98.所述消息管理装置对于所述消息上传请求携带的消息本体进行存储，并在存储完成之后向所述消息生产者发送消息存储成功通知消息，生成第三消息生产日志文件，其中，所述第三消息生产日志文件包含所述消息标识信息和消息上传请求标识信息；
99.所述消息生产者响应于接收到所述消息存储成功通知消息，生成第四消息生产日志文件，其中，所述第四消息生产日志文件包含所述消息标识信息和消息上传请求标识信息。
100.在该实施方式中，为了实现对于消息的跟踪，在消息上传和存储的过程中生成相应的、携带有具有对应关系的消息上传请求标识信息和/或消息标识信息的消息生产日志文件。具体地：
101.首先，消息生产者基于其生产者标识信息生成建立消息上传通道请求，并将所述建立消息上传通道请求发送给消息管理装置。其中，所述生产者标识信息指的是用于对于消息生产者进行区别性标识的标识信息，比如消息生产者id等等。其中，所述建立消息上传通道请求指的是用于建立消息上传通道的请求，所述建立消息上传通道请求携带有所述生产者标识信息，以使所述消息管理装置根据所述生产者标识信息建立对应的消息生产者专属的消息上传通道。
102.然后，当所述消息管理装置接收到所述建立消息上传通道请求后，基于所述建立消息上传通道请求携带的生产者标识信息对于所述消息生产者进行身份鉴权，身份鉴权通过后，建立与所述消息生产者之间的专属的消息上传通道，并向所述消息生产者发送消息
上传通道已建立通知消息，通知所述消息生产者消息上传通道已建立，其中，所述身份鉴权指的是根据所述生产者标识信息进行的、对于所述消息生产者身份的合法性进行鉴定的操作。
103.所述消息生产者在接收到所述消息上传通道已建立通知消息之后，使用建立的所述消息上传通道向所述消息管理装置发送携带有消息上传请求标识信息和消息本体的消息上传请求，并在发送完成之后生成第一消息生产日志文件，以标志消息已发送完成，其中，所述第一消息生产日志文件包含消息上传请求标识信息。
104.所述消息管理装置在接收到所述消息上传请求之后，为所述消息上传请求携带的消息本体设置消息标识信息，之后，生成第二消息生产日志文件，以标志消息管理装置已接收到所述消息生产者上传的消息，其中，所述第二消息生产日志文件既包含所述消息标识信息，也包含与所述消息标识信息对应的消息上传请求标识信息，以便于后续借助所述消息标识信息确定相应的消息上传请求标识信息，或者借助所述消息上传请求标识信息确定相应的消息标识信息。
105.然后，所述消息管理装置对于所述消息上传请求携带的消息本体进行存储，存储完成之后向所述消息生产者发送消息存储成功通知消息，以通知所述消息生产者消息已存储成功，并生成第三消息生产日志文件，以标志消息管理装置已成功存储所述消息生产者上传的消息，其中，所述第三消息生产日志文件也既包含所述消息标识信息，也包含与所述消息标识信息对应的消息上传请求标识信息。
106.所述消息生产者在接收到所述消息存储成功通知消息之后，生成第四消息生产日志文件，以标志所述消息生产者已了解所述消息存储成功，其中，所述第四消息生产日志文件也既包含所述消息标识信息，也包含与所述消息标识信息对应的消息上传请求标识信息。
107.在本公开一实施方式中，所述消息生产者生成第一消息生产日志文件的步骤之后，还可包括以下步骤：
108.利用所述消息上传请求标识信息对于所述第一消息生产日志文件进行去重。
109.考虑到由于网络传输质量不佳有可能导致消息生产者生产的消息重复发送，进而生成多个包括相同的消息上传请求标识信息的第一消息生产日志文件的情况，因此，在该实施方式中，在消息生产者生成第一消息生产日志文件之后，还可利用所述消息上传请求标识信息对于所述第一消息生产日志文件进行去重，去除包括相同的消息上传请求标识信息的多余的第一消息生产日志文件。
110.在本公开一实施方式中，所述步骤s102，即消息管理装置将存储的消息下发至消息消费者，并生成相应的消息消费日志文件的步骤，可包括以下步骤：
111.消息消费者基于消费者标识信息生成建立消息消费通道请求，发送给消息管理装置；
112.所述消息管理装置响应于接收到所述建立消息消费通道请求，基于所述建立消息消费通道请求携带的消费者标识信息对于所述消息消费者进行身份鉴权，身份鉴权通过后，建立与所述消息消费者之间的消息消费通道，并向所述消息消费者发送消息消费通道已建立通知消息；
113.所述消息消费者响应于接收到消息消费通道已建立通知消息，使用建立的所述消
息消费通道向所述消息管理装置发送消息消费请求，其中，所述消息消费请求中携带订阅消息属性信息；
114.所述消息管理装置接收到与所述订阅消息属性信息匹配的订阅消息后，将所述订阅消息即时或定时通过所述消息消费通道发送给所述消息消费者，生成第一消息消费日志文件，其中，所述第一消息消费日志文件包含订阅消息标识信息；
115.所述消息消费者响应于通过所述消息消费通道接收到所述订阅消息，生成第二消息消费日志文件，其中，所述第二消息消费日志文件包含订阅消息标识信息；并向所述消息管理装置发送订阅消息接收成功反馈消息，生成第三消息消费日志文件，其中，所述第三消息消费日志文件包含订阅消息标识信息；
116.所述消息管理装置响应于接收到所述订阅消息接收成功反馈消息，生成第四消息消费日志文件，其中，所述第四消息消费日志文件包含订阅消息标识信息。
117.在该实施方式中，为了实现对于消息的跟踪，在消息消费的过程中也生成相应的、携带有消息标识信息的消息消费日志文件。具体地：
118.首先，消息消费者基于其消费者标识信息生成建立消息消费通道请求，并将所述建立消息消费通道请求发送给消息管理装置。其中，所述消费者标识信息指的是用于对于消息消费者进行区别性标识的标识信息，比如消息消费者id等等。其中，所述建立消息消费通道请求指的是用于建立消息消费通道的请求，所述建立消息消费通道请求携带有所述消费者标识信息，以使所述消息管理装置根据所述消费者标识信息建立对应的消息消费者专属的消息消费通道。
119.然后，当所述消息管理装置接收到所述建立消息消费通道请求后，基于所述建立消息消费通道请求携带的消费者标识信息对于所述消息消费者进行身份鉴权，身份鉴权通过后，建立与所述消息消费者之间的专属的消息消费通道，并向所述消息消费者发送消息消费通道已建立通知消息，通知所述消息消费者消息消费通道已建立，其中，所述身份鉴权指的是根据所述消费者标识信息进行的、对于所述消息消费者身份的合法性进行鉴定的操作。
120.所述消息消费者在接收到所述消息消费通道已建立通知消息之后，使用建立的所述消息消费通道向所述消息管理装置发送携带有订阅消息属性信息的消息消费请求，其中，所述订阅消息属性信息指的是用于表征所述消息消费者想要订阅什么消息的信息，比如，所述订阅消息属性信息可以为订阅消息类别信息、订阅消息id等标识信息等等。
121.后续所述消息管理装置在接收到与所述订阅消息属性信息相匹配的订阅消息后，就可将所述订阅消息即时或定时通过所述消息消费通道发送给所述消息消费者，并生成第一消息消费日志文件，以标志消息管理装置已发送订阅消息，其中，所述第一消息消费日志文件包含订阅消息标识信息。
122.所述消息消费者通过所述消息消费通道接收到所述订阅消息之后，生成第二消息消费日志文件，以标志所述消息消费者已成功接收到其订阅的消息，其中，所述第二消息消费日志文件亦包含所述订阅消息标识信息；之后，所述消息消费者还向所述消息管理装置发送订阅消息接收成功反馈消息，以通知所述消息管理装置所述消息消费者已成功接收到其订阅的消息，生成第三消息消费日志文件，以标志所述消息消费者已向所述消息管理装置反馈其成功接收到订阅的消息，其中，所述第三消息消费日志文件亦包含订阅消息标识
信息。
123.所述消息管理装置在接收到所述订阅消息接收成功反馈消息之后，生成第四消息消费日志文件，以标志所述消息管理装置已了解所述消息消费者已成功接收到其订阅的消息，其中，所述第四消息消费日志文件亦包含订阅消息标识信息。
124.在上述实施方式中，所述消息管理装置是以定时推送的方式向所述消息消费者发送其订阅的消息的，在本公开另一实施方式中，还可基于所述消息消费者请求的方式向其发送其订阅的消息。
125.即在本公开另一实施方式中，所述步骤s102，即消息管理装置将存储的消息下发至消息消费者，并生成相应的消息消费日志文件的步骤，可包括以下步骤：
126.消息消费者基于消费者标识信息生成建立消息消费通道请求，发送给消息管理装置；
127.所述消息管理装置响应于接收到所述建立消息消费通道请求，基于所述建立消息消费通道请求携带的消费者标识信息对于所述消息消费者进行身份鉴权，身份鉴权通过后，建立与所述消息消费者之间的消息消费通道，并向所述消息消费者发送消息消费通道已建立通知消息；
128.所述消息消费者响应于接收到消息消费通道已建立通知消息，使用建立的所述消息消费通道即时或定时向所述消息管理装置发送消息消费请求，其中，所述消息消费请求中携带订阅消息属性信息；
129.所述消息管理装置将存储的、与所述订阅消息属性信息匹配的订阅消息，通过所述消息消费通道发送给所述消息消费者，生成第五消息消费日志文件，其中，所述第五消息消费日志文件包含订阅消息标识信息；
130.所述消息消费者响应于通过所述消息消费通道接收到所述订阅消息，生成第六消息消费日志文件，其中，所述第六消息消费日志文件包含订阅消息标识信息；并向所述消息管理装置发送订阅消息接收成功反馈消息，生成第七消息消费日志文件，其中，所述第七消息消费日志文件包含订阅消息标识信息；
131.所述消息管理装置响应于接收到所述订阅消息接收成功反馈消息，生成第八消息消费日志文件，其中，所述第八消息消费日志文件包含订阅消息标识信息。
132.在该实施方式中，在所述消息消费者向所述消息管理装置发送消息消费请求后，若所述消息管理装置确定当前存储的消息中并无与所述订阅消息属性信息匹配的消息，则可通过所述消息消费通道向所述消息消费者发送无订阅消息通知消息。
133.本公开一实施方式中，所述步骤s103，即根据所述目标消息标识信息获取对应目标消息的轨迹数据的步骤，可包括以下步骤：
134.根据所述目标消息标识信息查询所述消息生产日志文件和消息消费日志文件，获取包含所述目标消息标识信息，或者包括相应消息上传请求标识信息的消息生产日志文件和消息消费日志文件，其中，所述相应消息上传请求标识信息为与所述目标消息标识信息存在关联关系的消息上传请求标识信息；
135.根据所述消息生产日志文件和消息消费日志文件确定所述目标消息的轨迹数据。
136.上文提及，所述消息生产日志文件和消息消费日志文件中包括消息标识信息和/或与其对应的消息上传请求标识信息，因此，在该实施方式中，可根据所述目标消息标识信
息来获取对应目标消息的轨迹数据，具体地：首先可根据所述目标消息标识信息查询所述消息生产日志文件和消息消费日志文件，获取包含所述目标消息标识信息的，或者包括与所述目标消息标识信息对应的消息上传请求标识信息的消息生产日志文件和消息消费日志文件，由于所述消息生产日志文件和消息消费日志文件记录有消息生产、消费、传输的时间以及传输端，因此，根据所述消息生产日志文件和消息消费日志文件即可确定所述目标消息的传输轨迹数据，即可实现对于所述目标消息的跟踪和定位，进而实现端至端之间消息传输延时的确定，以及消息传输错误时对于传输错误点的定位。
137.下述为本公开装置实施例，可以用于执行本公开方法实施例。
138.图2示出根据本公开一实施方式的消息管理系统的结构框图，该系统可以通过软件、硬件或者两者的结合实现成为电子设备的部分或者全部。如图2所示，所述消息管理系统包括：
139.消息生产者，被配置为将生产的消息上传至消息管理装置存储，并生成相应的消息生产日志文件，其中，所述消息生产日志文件携带有消息上传请求标识信息和/或消息标识信息，所述消息上传请求标识信息与消息标识信息相对应；
140.消息管理装置，被配置为将存储的消息下发至消息消费者，并生成相应的消息消费日志文件，其中，所述消息消费日志文件携带有消息标识信息；响应于接收到消息管理请求，获取所述消息管理请求中携带的目标消息标识信息，并根据所述目标消息标识信息获取对应目标消息的轨迹数据。
141.上文提及，随着科学技术的发展，消息的生产和消费的应用越来越普遍。在消息生产和消费系统中，消息由消息生产者经消息管理装置发往消息消费者，在这个流程中，若想要衡量端至端之间的消息传输延时，或者当发生消息传输错误时对于传输错误点进行定位，需要对于传输的消息进行跟踪。现有技术中，通常借助traceid对于消息进行跟踪，但该方式需要对于整个消息生产和消费系统进行设置或改造，不仅操作复杂，还需要较高的时间成本。
142.考虑到上述问题，在该实施方式中，提出一种消息管理系统，该系统通过在消息生产和消费过程中生成相应的日志文件，并在日志文件中嵌入消息上传请求标识信息和/或消息标识信息，以借助上传请求标识信息和/或消息标识信息实现对于消息传输的跟踪。该技术方案实现简单，时间成本低，操作方便，能够有效衡量端至端之间的消息传输延时，当发生消息传输错误时能够对于传输错误点进行定位。
143.在本公开一实施方式中，所述消息管理系统可适用于对于消息进行管理的，包括消息生产者、消息管理装置和消息消费者的消息管理系统。
144.在本公开一实施方式中，所述消息生产日志文件指的是在消息生产者生产出消息，并将消息上传至消息管理装置处进行存储的过程中生成的、用于对于消息的生产和传输状态，比如生产时间、传输时间、传输端，进行日志记录的文件。其中，为了对于消息的上传和消息本身进行识别，所述消息生产日志文件中需携带有消息上传请求标识信息和/或消息标识信息，且所述消息上传请求标识信息与消息标识信息存在对应关系，以借助消息标识信息确定相应的消息上传请求标识信息，借助消息上传请求标识信息确定相应的消息标识信息，便于后续对于消息的跟踪。
145.在本公开一实施方式中，所述消息消费日志文件指的是在消息管理装置将消息消
费者订阅的消息发送给消息消费者，消息消费者接收到订阅消息的过程中生成的、用于对于消息的消费和传输状态，比如消费时间、传输时间、传输端进行日志记录的文件。其中，为了对于消息的消费和消息本身进行识别，所述消息消费日志文件中需携带有消息标识信息，以借助消息标识信息实现对于消息的跟踪。
146.在上述实施方式中，消息生产者将生产的消息上传至消息管理装置进行存储，并在消息上传和存储的过程中生成相应的、携带有具有对应关系的消息上传请求标识信息和/或消息标识信息的消息生产日志文件；后续在消息管理装置将存储的消息下发至消息消费者的过程中，还生成相应的、携带有消息标识信息的消息消费日志文件；这样，在接受到消息管理请求后，就可根据所述消息管理请求中携带的目标消息标识信息，获取对应目标消息的轨迹数据，实现对于目标消息的跟踪。
147.在本公开一实施方式中，所述消息生产者将生产的消息上传至消息管理装置存储，并生成相应的消息生产日志文件的部分，可被配置为：
148.消息生产者基于生产者标识信息生成建立消息上传通道请求，发送给消息管理装置；
149.所述消息管理装置响应于接收到所述建立消息上传通道请求，基于所述建立消息上传通道请求携带的生产者标识信息对于所述消息生产者进行身份鉴权，身份鉴权通过后，建立与所述消息生产者之间的消息上传通道，并向所述消息生产者发送消息上传通道已建立通知消息；
150.所述消息生产者响应于接收到消息上传通道已建立通知消息，使用建立的所述消息上传通道向所述消息管理装置发送消息上传请求，其中，所述消息上传请求携带有消息上传请求标识信息和消息本体，并在发送完成之后生成第一消息生产日志文件，其中，所述第一消息生产日志文件包含消息上传请求标识信息；
151.消息管理装置响应于接收到所述消息上传请求，为所述消息本体设置消息标识信息，生成第二消息生产日志文件，其中，所述第二消息生产日志文件包含所述消息标识信息和消息上传请求标识信息；
152.所述消息管理装置对于所述消息上传请求携带的消息本体进行存储，并在存储完成之后向所述消息生产者发送消息存储成功通知消息，生成第三消息生产日志文件，其中，所述第三消息生产日志文件包含所述消息标识信息和消息上传请求标识信息；
153.所述消息生产者响应于接收到所述消息存储成功通知消息，生成第四消息生产日志文件，其中，所述第四消息生产日志文件包含所述消息标识信息和消息上传请求标识信息。
154.在该实施方式中，为了实现对于消息的跟踪，在消息上传和存储的过程中生成相应的、携带有具有对应关系的消息上传请求标识信息和/或消息标识信息的消息生产日志文件。具体地：
155.首先，消息生产者基于其生产者标识信息生成建立消息上传通道请求，并将所述建立消息上传通道请求发送给消息管理装置。其中，所述生产者标识信息指的是用于对于消息生产者进行区别性标识的标识信息，比如消息生产者id等等。其中，所述建立消息上传通道请求指的是用于建立消息上传通道的请求，所述建立消息上传通道请求携带有所述生产者标识信息，以使所述消息管理装置根据所述生产者标识信息建立对应的消息生产者专
属的消息上传通道。
156.然后，当所述消息管理装置接收到所述建立消息上传通道请求后，基于所述建立消息上传通道请求携带的生产者标识信息对于所述消息生产者进行身份鉴权，身份鉴权通过后，建立与所述消息生产者之间的专属的消息上传通道，并向所述消息生产者发送消息上传通道已建立通知消息，通知所述消息生产者消息上传通道已建立，其中，所述身份鉴权指的是根据所述生产者标识信息进行的、对于所述消息生产者身份的合法性进行鉴定的操作。
157.所述消息生产者在接收到所述消息上传通道已建立通知消息之后，使用建立的所述消息上传通道向所述消息管理装置发送携带有消息上传请求标识信息和消息本体的消息上传请求，并在发送完成之后生成第一消息生产日志文件，以标志消息已发送完成，其中，所述第一消息生产日志文件包含消息上传请求标识信息。
158.所述消息管理装置在接收到所述消息上传请求之后，为所述消息上传请求携带的消息本体设置消息标识信息，之后，生成第二消息生产日志文件，以标志消息管理装置已接收到所述消息生产者上传的消息，其中，所述第二消息生产日志文件既包含所述消息标识信息，也包含与所述消息标识信息对应的消息上传请求标识信息，以便于后续借助所述消息标识信息确定相应的消息上传请求标识信息，或者借助所述消息上传请求标识信息确定相应的消息标识信息。
159.然后，所述消息管理装置对于所述消息上传请求携带的消息本体进行存储，存储完成之后向所述消息生产者发送消息存储成功通知消息，以通知所述消息生产者消息已存储成功，并生成第三消息生产日志文件，以标志消息管理装置已成功存储所述消息生产者上传的消息，其中，所述第三消息生产日志文件也既包含所述消息标识信息，也包含与所述消息标识信息对应的消息上传请求标识信息。
160.所述消息生产者在接收到所述消息存储成功通知消息之后，生成第四消息生产日志文件，以标志所述消息生产者已了解所述消息存储成功，其中，所述第四消息生产日志文件也既包含所述消息标识信息，也包含与所述消息标识信息对应的消息上传请求标识信息。
161.在本公开一实施方式中，所述消息生产者生成第一消息生产日志文件的部分之后，还可被配置为：
162.利用所述消息上传请求标识信息对于所述第一消息生产日志文件进行去重。
163.考虑到由于网络传输质量不佳有可能导致消息生产者生产的消息重复发送，进而生成多个包括相同的消息上传请求标识信息的第一消息生产日志文件的情况，因此，在该实施方式中，在消息生产者生成第一消息生产日志文件之后，还可利用所述消息上传请求标识信息对于所述第一消息生产日志文件进行去重，去除包括相同的消息上传请求标识信息的多余的第一消息生产日志文件。
164.在本公开一实施方式中，所述消息管理装置将存储的消息下发至消息消费者，并生成相应的消息消费日志文件的部分，可被配置为：
165.消息消费者基于消费者标识信息生成建立消息消费通道请求，发送给消息管理装置；
166.所述消息管理装置响应于接收到所述建立消息消费通道请求，基于所述建立消息
消费通道请求携带的消费者标识信息对于所述消息消费者进行身份鉴权，身份鉴权通过后，建立与所述消息消费者之间的消息消费通道，并向所述消息消费者发送消息消费通道已建立通知消息；
167.所述消息消费者响应于接收到消息消费通道已建立通知消息，使用建立的所述消息消费通道向所述消息管理装置发送消息消费请求，其中，所述消息消费请求中携带订阅消息属性信息；
168.所述消息管理装置接收到与所述订阅消息属性信息匹配的订阅消息后，将所述订阅消息即时或定时通过所述消息消费通道发送给所述消息消费者，生成第一消息消费日志文件，其中，所述第一消息消费日志文件包含订阅消息标识信息；
169.所述消息消费者响应于通过所述消息消费通道接收到所述订阅消息，生成第二消息消费日志文件，其中，所述第二消息消费日志文件包含订阅消息标识信息；并向所述消息管理装置发送订阅消息接收成功反馈消息，生成第三消息消费日志文件，其中，所述第三消息消费日志文件包含订阅消息标识信息；
170.所述消息管理装置响应于接收到所述订阅消息接收成功反馈消息，生成第四消息消费日志文件，其中，所述第四消息消费日志文件包含订阅消息标识信息。
171.在该实施方式中，为了实现对于消息的跟踪，在消息消费的过程中也生成相应的、携带有消息标识信息的消息消费日志文件。具体地：
172.首先，消息消费者基于其消费者标识信息生成建立消息消费通道请求，并将所述建立消息消费通道请求发送给消息管理装置。其中，所述消费者标识信息指的是用于对于消息消费者进行区别性标识的标识信息，比如消息消费者id等等。其中，所述建立消息消费通道请求指的是用于建立消息消费通道的请求，所述建立消息消费通道请求携带有所述消费者标识信息，以使所述消息管理装置根据所述消费者标识信息建立对应的消息消费者专属的消息消费通道。
173.然后，当所述消息管理装置接收到所述建立消息消费通道请求后，基于所述建立消息消费通道请求携带的消费者标识信息对于所述消息消费者进行身份鉴权，身份鉴权通过后，建立与所述消息消费者之间的专属的消息消费通道，并向所述消息消费者发送消息消费通道已建立通知消息，通知所述消息消费者消息消费通道已建立，其中，所述身份鉴权指的是根据所述消费者标识信息进行的、对于所述消息消费者身份的合法性进行鉴定的操作。
174.所述消息消费者在接收到所述消息消费通道已建立通知消息之后，使用建立的所述消息消费通道向所述消息管理装置发送携带有订阅消息属性信息的消息消费请求，其中，所述订阅消息属性信息指的是用于表征所述消息消费者想要订阅什么消息的信息，比如，所述订阅消息属性信息可以为订阅消息类别信息、订阅消息id等标识信息等等。
175.后续所述消息管理装置在接收到与所述订阅消息属性信息相匹配的订阅消息后，就可将所述订阅消息即时或定时通过所述消息消费通道发送给所述消息消费者，并生成第一消息消费日志文件，以标志消息管理装置已发送订阅消息，其中，所述第一消息消费日志文件包含订阅消息标识信息。
176.所述消息消费者通过所述消息消费通道接收到所述订阅消息之后，生成第二消息消费日志文件，以标志所述消息消费者已成功接收到其订阅的消息，其中，所述第二消息消
费日志文件亦包含所述订阅消息标识信息；之后，所述消息消费者还向所述消息管理装置发送订阅消息接收成功反馈消息，以通知所述消息管理装置所述消息消费者已成功接收到其订阅的消息，生成第三消息消费日志文件，以标志所述消息消费者已向所述消息管理装置反馈其成功接收到订阅的消息，其中，所述第三消息消费日志文件亦包含订阅消息标识信息。
177.所述消息管理装置在接收到所述订阅消息接收成功反馈消息之后，生成第四消息消费日志文件，以标志所述消息管理装置已了解所述消息消费者已成功接收到其订阅的消息，其中，所述第四消息消费日志文件亦包含订阅消息标识信息。
178.在上述实施方式中，所述消息管理装置是以定时推送的方式向所述消息消费者发送其订阅的消息的，在本公开另一实施方式中，还可基于所述消息消费者请求的方式向其发送其订阅的消息。
179.即在本公开另一实施方式中，所述消息管理装置将存储的消息下发至消息消费者，并生成相应的消息消费日志文件的部分，还可被配置为：
180.消息消费者基于消费者标识信息生成建立消息消费通道请求，发送给消息管理装置；
181.所述消息管理装置响应于接收到所述建立消息消费通道请求，基于所述建立消息消费通道请求携带的消费者标识信息对于所述消息消费者进行身份鉴权，身份鉴权通过后，建立与所述消息消费者之间的消息消费通道，并向所述消息消费者发送消息消费通道已建立通知消息；
182.所述消息消费者响应于接收到消息消费通道已建立通知消息，使用建立的所述消息消费通道即时或定时向所述消息管理装置发送消息消费请求，其中，所述消息消费请求中携带订阅消息属性信息；
183.所述消息管理装置将存储的、与所述订阅消息属性信息匹配的订阅消息，通过所述消息消费通道发送给所述消息消费者，生成第五消息消费日志文件，其中，所述第五消息消费日志文件包含订阅消息标识信息；
184.所述消息消费者响应于通过所述消息消费通道接收到所述订阅消息，生成第六消息消费日志文件，其中，所述第六消息消费日志文件包含订阅消息标识信息；并向所述消息管理装置发送订阅消息接收成功反馈消息，生成第七消息消费日志文件，其中，所述第七消息消费日志文件包含订阅消息标识信息；
185.所述消息管理装置响应于接收到所述订阅消息接收成功反馈消息，生成第八消息消费日志文件，其中，所述第八消息消费日志文件包含订阅消息标识信息。
186.在该实施方式中，在所述消息消费者向所述消息管理装置发送消息消费请求后，若所述消息管理装置确定当前存储的消息中并无与所述订阅消息属性信息匹配的消息，则可通过所述消息消费通道向所述消息消费者发送无订阅消息通知消息。
187.本公开一实施方式中，所述根据所述目标消息标识信息获取对应目标消息的轨迹数据的部分，可被配置为：
188.根据所述目标消息标识信息查询所述消息生产日志文件和消息消费日志文件，获取包含所述目标消息标识信息，或者包括相应消息上传请求标识信息的消息生产日志文件和消息消费日志文件，其中，所述相应消息上传请求标识信息为与所述目标消息标识信息
存在关联关系的消息上传请求标识信息；
189.根据所述消息生产日志文件和消息消费日志文件确定所述目标消息的轨迹数据。
190.上文提及，所述消息生产日志文件和消息消费日志文件中包括消息标识信息和/或与其对应的消息上传请求标识信息，因此，在该实施方式中，可根据所述目标消息标识信息来获取对应目标消息的轨迹数据，具体地：首先可根据所述目标消息标识信息查询所述消息生产日志文件和消息消费日志文件，获取包含所述目标消息标识信息的，或者包括与所述目标消息标识信息对应的消息上传请求标识信息的消息生产日志文件和消息消费日志文件，由于所述消息生产日志文件和消息消费日志文件记录有消息生产、消费、传输的时间以及传输端，因此，根据所述消息生产日志文件和消息消费日志文件即可确定所述目标消息的传输轨迹数据，即可实现对于所述目标消息的跟踪和定位，进而实现端至端之间消息传输延时的确定，以及消息传输错误时对于传输错误点的定位。
191.本公开还公开了一种电子设备，图3示出根据本公开一实施方式的电子设备的结构框图，如图3所示，所述电子设备300包括存储器301和处理器302；其中，
192.所述存储器301用于存储一条或多条计算机指令，其中，所述一条或多条计算机指令被所述处理器302执行以实现上述方法步骤。
193.图4是适于用来实现根据本公开一实施方式的消息管理方法的计算机系统的结构示意图。
194.如图4所示，计算机系统400包括处理单元401，其可以根据存储在只读存储器(rom)402中的程序或者从存储部分408加载到随机访问存储器(ram)403中的程序而执行上述实施方式中的各种处理。在ram403中，还存储有计算机系统400操作所需的各种程序和数据。处理单元401、rom402以及ram403通过总线404彼此相连。输入/输出(i/o)接口405也连接至总线404。
195.以下部件连接至i/o接口405：包括键盘、鼠标等的输入部分406；包括诸如阴极射线管(crt)、液晶显示器(lcd)等以及扬声器等的输出部分407；包括硬盘等的存储部分408；以及包括诸如lan卡、调制解调器等的网络接口卡的通信部分409。通信部分409经由诸如因特网的网络执行通信处理。驱动器410也根据需要连接至i/o接口405。可拆卸介质411，诸如磁盘、光盘、磁光盘、半导体存储器等等，根据需要安装在驱动器410上，以便于从其上读出的计算机程序根据需要被安装入存储部分408。其中，所述处理单元401可实现为cpu、gpu、tpu、fpga、npu等处理单元。
196.特别地，根据本公开的实施方式，上文描述的方法可以被实现为计算机软件程序。例如，本公开的实施方式包括一种计算机程序产品，其包括有形地包含在及其可读介质上的计算机程序，所述计算机程序包含用于执行所述消息管理方法的程序代码。在这样的实施方式中，该计算机程序可以通过通信部分409从网络上被下载和安装，和/或从可拆卸介质411被安装。
197.本公开实施例还公开了一种计算机程序产品，所述计算机程序产品包括计算机程序/指令，该计算机程序/指令被处理器执行时实现上述任一方法步骤。
198.附图中的流程图和框图，图示了按照本公开各种实施方式的系统、方法和计算机程序产品的可能实现的体系架构、功能和操作。在这点上，路程图或框图中的每个方框可以代表一个模块、程序段或代码的一部分，所述模块、程序段或代码的一部分包含一个或多个
用于实现规定的逻辑功能的可执行指令。也应当注意，在有些作为替换的实现中，方框中所标注的功能也可以以不同于附图中所标注的顺序发生。例如，两个接连地表示的方框实际上可以基本并行地执行，它们有时也可以按相反的顺序执行，这依所涉及的功能而定。也要注意的是，框图和/或流程图中的每个方框、以及框图和/或流程图中的方框的组合，可以用执行规定的功能或操作的专用的基于硬件的系统来实现，或者可以用专用硬件与计算机指令的组合来实现。
199.描述于本公开实施方式中所涉及到的单元或模块可以通过软件的方式实现，也可以通过硬件的方式来实现。所描述的单元或模块也可以设置在处理器中，这些单元或模块的名称在某种情况下并不构成对该单元或模块本身的限定。
200.作为另一方面，本公开实施例还提供了一种计算机可读存储介质，该计算机可读存储介质可以是上述实施方式中所述装置中所包含的计算机可读存储介质；也可以是单独存在，未装配入设备中的计算机可读存储介质。计算机可读存储介质存储有一个或者一个以上程序，所述程序被一个或者一个以上的处理器用来执行描述于本公开实施例的方法。
201.以上描述仅为本公开的较佳实施例以及对所运用技术原理的说明。本领域技术人员应当理解，本公开实施例中所涉及的发明范围，并不限于上述技术特征的特定组合而成的技术方案，同时也应涵盖在不脱离所述发明构思的情况下，由上述技术特征或其等同特征进行任意组合而形成的其它技术方案。例如上述特征与本公开实施例中公开的(但不限于)具有类似功能的技术特征进行互相替换而形成的技术方案。

技术特征：

1.一种消息管理方法，包括：消息生产者将生产的消息上传至消息管理装置存储，并生成相应的消息生产日志文件，其中，所述消息生产日志文件携带有消息上传请求标识信息和/或消息标识信息，所述消息上传请求标识信息与消息标识信息相对应；所述消息管理装置将存储的消息下发至消息消费者，并生成相应的消息消费日志文件，其中，所述消息消费日志文件携带有消息标识信息；响应于接收到消息管理请求，获取所述消息管理请求中携带的目标消息标识信息，并根据所述目标消息标识信息获取对应目标消息的轨迹数据。2.根据权利要求1所述的方法，所述消息生产者将生产的消息上传至消息管理装置存储，并生成相应的消息生产日志文件，包括：消息生产者基于生产者标识信息生成建立消息上传通道请求，发送给消息管理装置；所述消息管理装置响应于接收到所述建立消息上传通道请求，基于所述建立消息上传通道请求携带的生产者标识信息对于所述消息生产者进行身份鉴权，身份鉴权通过后，建立与所述消息生产者之间的消息上传通道，并向所述消息生产者发送消息上传通道已建立通知消息；所述消息生产者响应于接收到消息上传通道已建立通知消息，使用建立的所述消息上传通道向所述消息管理装置发送消息上传请求，其中，所述消息上传请求携带有消息上传请求标识信息和消息本体，并在发送完成之后生成第一消息生产日志文件，其中，所述第一消息生产日志文件包含消息上传请求标识信息；消息管理装置响应于接收到所述消息上传请求，为所述消息本体设置消息标识信息，生成第二消息生产日志文件，其中，所述第二消息生产日志文件包含所述消息标识信息和消息上传请求标识信息；所述消息管理装置对于所述消息上传请求携带的消息本体进行存储，并在存储完成之后向所述消息生产者发送消息存储成功通知消息，生成第三消息生产日志文件，其中，所述第三消息生产日志文件包含所述消息标识信息和消息上传请求标识信息；所述消息生产者响应于接收到所述消息存储成功通知消息，生成第四消息生产日志文件，其中，所述第四消息生产日志文件包含所述消息标识信息和消息上传请求标识信息。3.根据权利要求2所述的方法，所述消息生产者生成第一消息生产日志文件之后，还包括：利用所述消息上传请求标识信息对于所述第一消息生产日志文件进行去重。4.根据权利要求1-3任一所述的方法，所述消息管理装置将存储的消息下发至消息消费者，并生成相应的消息消费日志文件，包括：消息消费者基于消费者标识信息生成建立消息消费通道请求，发送给消息管理装置；所述消息管理装置响应于接收到所述建立消息消费通道请求，基于所述建立消息消费通道请求携带的消费者标识信息对于所述消息消费者进行身份鉴权，身份鉴权通过后，建立与所述消息消费者之间的消息消费通道，并向所述消息消费者发送消息消费通道已建立通知消息；所述消息消费者响应于接收到消息消费通道已建立通知消息，使用建立的所述消息消费通道向所述消息管理装置发送消息消费请求，其中，所述消息消费请求中携带订阅消息
属性信息；所述消息管理装置接收到与所述订阅消息属性信息匹配的订阅消息后，将所述订阅消息即时或定时通过所述消息消费通道发送给所述消息消费者，生成第一消息消费日志文件，其中，所述第一消息消费日志文件包含订阅消息标识信息；所述消息消费者响应于通过所述消息消费通道接收到所述订阅消息，生成第二消息消费日志文件，其中，所述第二消息消费日志文件包含订阅消息标识信息；并向所述消息管理装置发送订阅消息接收成功反馈消息，生成第三消息消费日志文件，其中，所述第三消息消费日志文件包含订阅消息标识信息；所述消息管理装置响应于接收到所述订阅消息接收成功反馈消息，生成第四消息消费日志文件，其中，所述第四消息消费日志文件包含订阅消息标识信息。5.根据权利要求1-3任一所述的方法，所述消息管理装置将存储的消息下发至消息消费者，并生成相应的消息消费日志文件，包括：消息消费者基于消费者标识信息生成建立消息消费通道请求，发送给消息管理装置；所述消息管理装置响应于接收到所述建立消息消费通道请求，基于所述建立消息消费通道请求携带的消费者标识信息对于所述消息消费者进行身份鉴权，身份鉴权通过后，建立与所述消息消费者之间的消息消费通道，并向所述消息消费者发送消息消费通道已建立通知消息；所述消息消费者响应于接收到消息消费通道已建立通知消息，使用建立的所述消息消费通道即时或定时向所述消息管理装置发送消息消费请求，其中，所述消息消费请求中携带订阅消息属性信息；所述消息管理装置将存储的、与所述订阅消息属性信息匹配的订阅消息，通过所述消息消费通道发送给所述消息消费者，生成第五消息消费日志文件，其中，所述第五消息消费日志文件包含订阅消息标识信息；所述消息消费者响应于通过所述消息消费通道接收到所述订阅消息，生成第六消息消费日志文件，其中，所述第六消息消费日志文件包含订阅消息标识信息；并向所述消息管理装置发送订阅消息接收成功反馈消息，生成第七消息消费日志文件，其中，所述第七消息消费日志文件包含订阅消息标识信息；所述消息管理装置响应于接收到所述订阅消息接收成功反馈消息，生成第八消息消费日志文件，其中，所述第八消息消费日志文件包含订阅消息标识信息。6.根据权利要求5所述的方法，在所述消息消费者响应于接收到消息消费通道已建立通知消息，使用建立的所述消息消费通道即时或定时向所述消息管理装置发送消息消费请求之后，当所述消息管理装置确定当前存储的消息中并无与所述订阅消息属性信息匹配的消息时，通过所述消息消费通道向所述消息消费者发送无订阅消息通知消息。7.根据权利要求1-6任一所述的方法，所述根据所述目标消息标识信息获取对应目标消息的轨迹数据，包括：根据所述目标消息标识信息查询所述消息生产日志文件和消息消费日志文件，获取包含所述目标消息标识信息，或者包括相应消息上传请求标识信息的消息生产日志文件和消息消费日志文件，其中，所述相应消息上传请求标识信息为与所述目标消息标识信息存在关联关系的消息上传请求标识信息；
根据所述消息生产日志文件和消息消费日志文件确定所述目标消息的轨迹数据。8.一种消息管理系统，包括：消息生产者，被配置为将生产的消息上传至消息管理装置存储，并生成相应的消息生产日志文件，其中，所述消息生产日志文件携带有消息上传请求标识信息和/或消息标识信息，所述消息上传请求标识信息与消息标识信息相对应；消息管理装置，被配置为将存储的消息下发至消息消费者，并生成相应的消息消费日志文件，其中，所述消息消费日志文件携带有消息标识信息；响应于接收到消息管理请求，获取所述消息管理请求中携带的目标消息标识信息，并根据所述目标消息标识信息获取对应目标消息的轨迹数据。9.根据权利要求8所述的系统，所述消息生产者将生产的消息上传至消息管理装置存储，并生成相应的消息生产日志文件的部分，被配置为：消息生产者基于生产者标识信息生成建立消息上传通道请求，发送给消息管理装置；所述消息管理装置响应于接收到所述建立消息上传通道请求，基于所述建立消息上传通道请求携带的生产者标识信息对于所述消息生产者进行身份鉴权，身份鉴权通过后，建立与所述消息生产者之间的消息上传通道，并向所述消息生产者发送消息上传通道已建立通知消息；所述消息生产者响应于接收到消息上传通道已建立通知消息，使用建立的所述消息上传通道向所述消息管理装置发送消息上传请求，其中，所述消息上传请求携带有消息上传请求标识信息和消息本体，并在发送完成之后生成第一消息生产日志文件，其中，所述第一消息生产日志文件包含消息上传请求标识信息；消息管理装置响应于接收到所述消息上传请求，为所述消息本体设置消息标识信息，生成第二消息生产日志文件，其中，所述第二消息生产日志文件包含所述消息标识信息和消息上传请求标识信息；所述消息管理装置对于所述消息上传请求携带的消息本体进行存储，并在存储完成之后向所述消息生产者发送消息存储成功通知消息，生成第三消息生产日志文件，其中，所述第三消息生产日志文件包含所述消息标识信息和消息上传请求标识信息；所述消息生产者响应于接收到所述消息存储成功通知消息，生成第四消息生产日志文件，其中，所述第四消息生产日志文件包含所述消息标识信息和消息上传请求标识信息。10.根据权利要求9所述的系统，所述消息生产者生成第一消息生产日志文件的部分之后，还被配置为：利用所述消息上传请求标识信息对于所述第一消息生产日志文件进行去重。

技术总结

本公开实施例公开了一种消息管理方法、系统、电子设备、存储介质及程序产品，所述方法包括：消息生产者将生产的消息上传至消息管理装置存储，并生成相应的消息生产日志文件，其中，消息生产日志文件携带有消息上传请求标识信息和/或消息标识信息；所述消息管理装置将存储的消息下发至消息消费者，并生成相应的消息消费日志文件，其中，消息消费日志文件携带有消息标识信息；响应于接收到消息管理请求，获取所述消息管理请求中携带的目标消息标识信息，并根据目标消息标识信息获取对应目标消息的轨迹数据。该技术方案实现简单，时间成本低，操作方便，能够有效衡量端至端之间的消息传输延时，当发生消息传输错误时能够对于传输错误点进行定位。点进行定位。点进行定位。