[發明專利]一種數據傳輸方法、裝置及電子設備

在審

• 申請號: 202011458853.1
• 申請日: 2020-12-11
• 公開（公告）號: CN114629925A
• 公開（公告）日: 2022-06-14
• 發明（設計）人: 吳文瑞;趙永偉;張益軍
• 申請（專利權）人: 飛狐信息技術（天津）有限公司
• 主分類號: H04L67/1097
• 分類號: H04L67/1097
• 代理公司: 北京集佳知識產權代理有限公司 11227
• 代理人: 尹秀

1.一種數據傳輸方法，其特征在于，應用于消息系統中的消息生產者，與所述消息生產者通信的消息轉發系統中預先設置有，用于存儲業務消息的第一數據存儲集群，以及，用于存儲與所述業務消息對應的消息軌跡的第二數據存儲集群；所述數據傳輸方法包括：

獲取待發送的目標業務消息；

依據所述目標業務消息對應的業務消息主題的屬性信息，生成所述目標業務消息對應的消息生產軌跡；

發送所述消息生產軌跡到所述第二數據存儲集群，以使所述第二數據存儲集群存儲所述目標業務消息對應的消息軌跡；

發送所述目標業務消息至所述消息轉發系統中的第一數據存儲集群，以使所述第一數據存儲集群存儲所述目標業務消息；

在接收到所述第一數據存儲集群反饋的消息接收數據之后，依據所述消息接收數據以及所述目標業務消息對應的消息發送屬性信息，生成所述目標業務消息對應的消息生產軌跡追加數據；

將所述消息生產軌跡追加數據發送至所述第二數據存儲集群，以使所述第二數據存儲集群將所述消息生產軌跡追加數據添加到所述目標業務消息對應的消息軌跡中。

2.根據權利要求1所述的數據傳輸方法，其特征在于，依據所述目標業務消息對應的業務消息主題的屬性信息，生成所述目標業務消息對應的消息生產軌跡，包括：

調用所述消息生產者預先設置的消息生產軌跡生成程序，以使所述消息生產軌跡生成程序依據所述目標業務消息對應的業務消息主題的屬性信息，分析得到所述目標業務消息的基礎屬性信息；

獲取當前時間的時間戳；

將所述基礎數據信息以及所述時間戳確定為所述目標業務消息對應的消息生產軌跡的內容。

3.根據權利要求2所述的數據傳輸方法，其特征在于，依據所述消息接收數據以及所述目標業務消息對應的消息發送屬性信息，生成所述目標業務消息對應的消息生產軌跡追加數據，包括：

調用所述消息生產軌跡生成程序，以使所述消息生產軌跡生成程序依據所述消息接收數據以及所述目標業務消息對應的消息發送屬性信息進行消息發送過程分析，得到所述目標業務消息的消息發送分析結果；

將所述消息發送分析結果確定為所述目標業務消息對應的消息生產軌跡追加數據。

4.一種數據傳輸方法，其特征在于，應用于消息系統中的消息消費者，與所述消息消費者通信的消息轉發系統中，預先設置有，用于存儲業務消息的第一數據存儲集群，以及，用于存儲與所述業務消息對應的消息軌跡的第二數據存儲集群；所述數據傳輸方法包括：

發送用于獲取目標業務消息的請求至所述第一數據存儲集群，以使所述第一數據存儲集群發送所述目標業務消息；

在成功接收所述第一數據存儲集群發送的目標業務消息之后，依據所述目標業務消息的消息接收過程信息，生成所述目標業務消息對應的消息消費軌跡；

將所述消息消費軌跡發送至所述第二數據存儲集群，以使所述第二數據存儲集群將所述消息消費軌跡添加到所述目標業務消息對應的消息軌跡中；

對所述目標業務消息執行消息消費操作，并在成功執行消息消費操作之后，依據所述目標業務消息的消息消費操作數據，生成所述目標業務消息對應的消息消費軌跡追加數據；

發送所述消息消費軌跡追加數據至所述第二數據存儲集群，以使所述第二數據存儲集群將所述消息消費軌跡追加數據添加到所述目標業務消息對應的消息軌跡中。

5.根據權利要求4所述的數據傳輸方法，其特征在于，依據所述目標業務消息的消息接收過程信息，生成所述目標業務消息對應的消息消費軌跡，包括：

調用所述消息消費者內預先設置的消息消費軌跡生成程序，以使所述消息消費軌跡生成程序依據所述目標業務消息的消息接收屬性信息以及當前時間的時間戳，確定所述目標業務消息對應的消息消費軌跡的內容。

6.根據權利要求5所述的數據傳輸方法，其特征在于，依據所述目標業務消息的消息消費操作數據，生成所述目標業務消息對應的消息消費軌跡追加數據，包括：

調用所述消息消費軌跡生成程序，以使所述消息消費軌跡生成程序對所述目標業務消息的消息消費操作數據進行消息消費過程分析，得到消費分析結果；

將所述消息分析結果確定為所述目標業務消息對應的消息消費軌跡追加數據。