[發明專利]一種數據傳輸方法、裝置及電子設備在審
| 申請號： | 202011458853.1 | 申請日： | 2020-12-11 |
| 公開（公告）號： | CN114629925A | 公開（公告）日： | 2022-06-14 |
| 發明（設計）人： | 吳文瑞;趙永偉;張益軍 | 申請（專利權）人： | 飛狐信息技術（天津）有限公司 |
| 主分類號： | H04L67/1097 | 分類號： | H04L67/1097 |
| 代理公司： | 北京集佳知識產權代理有限公司 11227 | 代理人： | 尹秀 |
| 地址： | 300280 天津市經濟開發區第一大*** | 國省代碼： | 天津;12 |
| 權利要求書： | 查看更多 | 說明書： | 查看更多 |
| 摘要： | |||
| 搜索關鍵詞： | 一種 數據傳輸 方法 裝置 電子設備 | ||
本發明提供了一種數據傳輸方法、裝置及電子設備，消息轉發系統預先設置有，用于存儲業務消息的第一數據存儲集群，以及，用于存儲與所述業務消息對應的消息軌跡的第二數據存儲集群，在進行業務消息的發送時，目標業務消息存儲至第一數據存儲集群，目標業務消息對應的消息軌跡存儲到第二數據存儲集群。即通過本發明，將業務消息以及業務消息對應的消息軌跡分開存儲，后續在對業務消息或業務消息對應的消息軌跡進行分析時，根據要分析的數據是業務消息還是消息軌跡，直接從對應的存儲集群中查找數據即可，相比于從同時存儲有業務消息和消息軌跡的存儲集群中查找數據的方式，能夠快速的找到需要分析的數據，進而簡化了數據分析復雜度。
技術領域
本發明涉及消息處理領域，更具體的說，涉及一種數據傳輸方法、裝置及電子設備。
背景技術
消息是進行跨系統數據交換的主要媒介，能夠實現分布式系統之間的異步調用。
隨著微服務體系中各個系統調用愈加復雜，用于處理消息的消息系統在解決各個系統之間的數據流轉問題方面起到了越來越重要的作用。消息系統包括消息生產者、消息轉發系統以及消息消費者，消息生產者生成的業務消息以及業務消息對應的消息生產軌跡、消息消費者生成的消息消費軌跡均在消息轉發系統中進行存儲。
在對消息軌跡或業務消息進行分析時，需要從消息轉發系統中找到對應的數據，但是數據查找復雜，使得對業務消息或消息軌跡的數據分析復雜度較高。
發明內容
有鑒于此，本發明提供一種數據傳輸方法、裝置及電子設備，以解決對業務消息或消息軌跡的數據分析復雜度較高的問題。
為解決上述技術問題，本發明采用了如下技術方案：
一種數據傳輸方法，應用于消息系統中的消息生產者，與所述消息生產者通信的消息轉發系統中預先設置有，用于存儲業務消息的第一數據存儲集群，以及，用于存儲與所述業務消息對應的消息軌跡的第二數據存儲集群；所述數據傳輸方法包括：
獲取待發送的目標業務消息；
依據所述目標業務消息對應的業務消息主題的屬性信息，生成所述目標業務消息對應的消息生產軌跡；
發送所述消息生產軌跡到所述第二數據存儲集群，以使所述第二數據存儲集群存儲所述目標業務消息對應的消息軌跡；
發送所述目標業務消息至所述消息轉發系統中的第一數據存儲集群，以使所述第一數據存儲集群存儲所述目標業務消息；
在接收到所述第一數據存儲集群反饋的消息接收數據之后，依據所述消息接收數據以及所述目標業務消息對應的消息發送屬性信息，生成所述目標業務消息對應的消息生產軌跡追加數據；
將所述消息生產軌跡追加數據發送至所述第二數據存儲集群，以使所述第二數據存儲集群將所述消息生產軌跡追加數據添加到所述目標業務消息對應的消息軌跡中。
可選地，依據所述目標業務消息對應的業務消息主題的屬性信息，生成所述目標業務消息對應的消息生產軌跡，包括：
調用所述消息生產者預先設置的消息生產軌跡生成程序，以使所述消息生產軌跡生成程序依據所述目標業務消息對應的業務消息主題的屬性信息，分析得到所述目標業務消息的基礎屬性信息；
獲取當前時間的時間戳；
將所述基礎數據信息以及所述時間戳確定為所述目標業務消息對應的消息生產軌跡的內容。
可選地，依據所述消息接收數據以及所述目標業務消息對應的消息發送屬性信息，生成所述目標業務消息對應的消息生產軌跡追加數據，包括：
調用所述消息生產軌跡生成程序，以使所述消息生產軌跡生成程序依據所述消息接收數據以及所述目標業務消息對應的消息發送屬性信息進行消息發送過程分析，得到所述目標業務消息的消息發送分析結果；
該專利技術資料僅供研究查看技術是否侵權等信息，商用須獲得專利權人授權。該專利全部權利屬于飛狐信息技術（天津）有限公司，未經飛狐信息技術（天津）有限公司許可，擅自商用是侵權行為。如果您想購買此專利、獲得商業授權和技術合作，請聯系【客服】
本文鏈接：http://www.szxzyx.cn/pat/books/202011458853.1/2.html，轉載請聲明來源鉆瓜專利網。
