[發明專利]基于消息隊列的數據傳輸方法、裝置及存儲介質在審

申請號：	202011506075.9	申請日：	2020-12-18
公開（公告）號：	CN112527528A	公開（公告）日：	2021-03-19
發明（設計）人：	趙楚旋;蔣英明;萬書武;林琪琛;劉微明;覃芳	申請（專利權）人：	平安科技（深圳）有限公司
主分類號：	G06F9/54	分類號：	G06F9/54;G06F16/25
代理公司：	廣州三環專利商標代理有限公司 44202	代理人：	熊永強
地址：	518000 廣東省深圳市福田區福***	國省代碼：	廣東;44
權利要求書：	查看更多	說明書：	查看更多
摘要：
搜索關鍵詞：	基于消息隊列數據傳輸方法裝置存儲介質
鉆瓜網技術展會專利詞庫專利權人專利榜在售專利公布日期熱門專利

【說明書】：

本申請公開了一種基于消息隊列的數據傳輸方法、裝置、計算機設備及存儲介質，該方法包括：接收消息生產者發送的消息數據，消息數據中攜帶消息生產者生成的消息和消息關聯的數據源信息；確定數據源信息關聯的消息隊列，并根據數據源信息生成目標消息主題；在消息隊列中確定出目標消息主題關聯的目標存儲區域，并將目標消息主題和消息存儲至目標存儲區域；當接收消息消費者發送的攜帶數據源信息的消息訂閱請求后，根據數據源信息從消息隊列的目標存儲區域中拉取目標消息主題對應的消息并向消息消費者推送消息。采用本申請，可提高往消息隊列中存儲數據以及從消息隊列中拉取數據的操作便捷性，提高數據傳輸的效率，適用性高。

技術領域

本申請涉及計算機技術領域，尤其涉及一種基于消息隊列的數據傳輸方法、裝置及存儲介質。

背景技術

在大數據領域，消息隊列是分布式系統中重要的組件，消息隊列這種中間件主要解決應用耦合、異步消息、流量削峰等問題。現有基于消息隊列的生產者和消費者應用中，上游生產者應用根據事先定義好的消息主題生成消息并發送到消息隊列中間件中，下游消費者應用根據上游生產者應用事先約定好的消息主題消費應對的消息。然而在這樣的應用模式中，當上游生產者生成的消息中消息主題發生變更時，必須通知下游消費者應用，開發人員對消費者應用做代碼調整和二次開發以適應上游生產者生成的新的消息主題。此外，當消息隊列中間件進行重新選型或技術升級時，上游生產者和下游消費者兩端的應用架構都需要進行重構和代碼的重新開發才能將消息存儲至消息隊列中或者從消息隊列中拉取數據，操作繁瑣，實現成本高，適用性差。

發明內容

本申請提供一種基于消息隊列的數據傳輸方法、裝置及存儲介質，可提高往消息隊列中存儲數據以及從消息隊列中拉取數據的操作便捷性，提高數據傳輸的效率，適用性高。

第一方面，本申請提供了一種基于消息隊列的數據傳輸方法，該方法適用于消息管理者，該方法包括：

消息管理者接收消息生產者發送的消息數據，上述消息數據中攜帶上述消息生產者生成的消息和上述消息關聯的數據源信息；

上述消息管理者確定上述數據源信息關聯的消息隊列，并根據上述數據源信息生成目標消息主題；

上述消息管理者在上述消息隊列中確定出上述目標消息主題關聯的目標存儲區域，并將上述目標消息主題和上述消息存儲至上述目標存儲區域；

當接收到消息消費者發送的消息訂閱請求且上述消息訂閱請求中攜帶上述數據源信息時，上述消息管理者根據上述數據源信息從上述消息隊列的上述目標存儲區域中確定出上述目標消息主題，從上述目標存儲區域中拉取上述目標消息主題對應的上述消息并向上述消息消費者推送上述消息。

結合第一方面，在一種可能的實施方式中，上述消息隊列中包括上述目標存儲區域在內的至少一個存儲區域，一個存儲區域關聯一個消息主題并用于存儲所述消息主題的消息，同一個消息主題的消息關聯的數據源信息相同。

結合第一方面，在一種可能的實施方式中，上述數據源信息中包括上述消息所屬數據源的數據源名稱和上述數據源所屬項目的項目名稱，上述數據源所屬項目中包括上述數據源在內的至少一個數據源；

上述根據上述數據源信息生成目標消息主題包括：

根據上述項目名稱和上述數據源名稱生成目標消息主題，其中，一個數據源名稱對應一個消息主題。

結合第一方面，在一種可能的實施方式中，上述消息數據中包括攜帶在上述消息的頭部信息中的消息模式標識，上述消息模式標識用于標識上述消息的消息模式，以供上述消息消費者基于所述消息模式對上述消息進行消費。