[發明專利]信息傳輸方法、裝置及系統

在審

• 申請號: 202110133176.4
• 申請日: 2021-01-29
• 公開（公告）號: CN112988411A
• 公開（公告）日: 2021-06-18
• 發明（設計）人: 劉舟;鐘曉文;楊帆;謝林廷
• 申請（專利權）人: 廣州三七互娛科技有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54
• 代理公司: 廣州三環專利商標代理有限公司 44202
• 代理人: 陳志明

本申請公開了一種信息傳輸方法、裝置及系統，所述方法包括：實時獲取當前環境參數；在所述當前環境參數符合第一預設條件時，控制節點集群中的各節點通過各所述節點間的通信鏈路進行端到端的信息傳輸，其中，各所述節點至少包括生產節點和消費節點；在所述當前環境參數不符合所述第一預設條件時，將各所述節點切換至與消息中間件的通信鏈路，通過所述消息中間件進行各所述節點間的信息傳輸。

技術領域

本申請涉及數據處理技術領域，特別涉及一種信息傳輸方法、裝置及系統。

背景技術

在基于消息驅動的應用開發的過程中，通常需要通過若干生產節點，若干消費節點和消息隊列來實現消息生產和消費，以完成應用開發。其中，生產節點為負責向消息隊列發送消息的節點，消費節點為從消息隊列中獲取消息的節點，消息隊列為用于存儲信息的消息中間件。由于消息隊列可用于存儲信息，因此不管生產者產生信息的速度多迅猛，通過中間消息隊列的緩存，可以保證后臺程序的正常運行。但上述系統進行基于消息驅動的應用開發時，由于消息均需先通過中間消息隊列進行緩存，處理方式不夠靈活，僅適用于需要集成重量級中心化服務的業務，無法滿足不同環境下的業務需求。

發明內容

本申請的目的在于至少解決現有技術中存在的技術問題之一，提供一種信息傳輸方法、裝置及系統，在滿足任何時期的業務需求的同時，提高業務處理效率。

本申請實施例提供一種信息傳輸方法，包括：

實時獲取當前環境參數；

在所述當前環境參數符合第一預設條件時，控制節點集群中的各節點通過各所述節點間的通信鏈路進行端到端的信息傳輸，其中，各所述節點至少包括生產節點和消費節點；

在所述當前環境參數不符合所述第一預設條件時，將各所述節點切換至與消息中間件的通信鏈路，通過所述消息中間件進行各所述節點間的信息傳輸。

進一步的，所述控制節點集群中的各節點通過各所述節點間的通信鏈路進行端到端的信息傳輸，包括：

控制所述生產節點根據所述生產節點與各所述消費節點間的通信鏈路所屬分區，向各所述消費節點分別提供對應的信息。

進一步的，所述分區通過哈希分區策略或Round-robin分區策略確定。

進一步的，所述生產節點包括第一節點，所述消費節點包括第二節點和第三節點；

所述控制節點集群中的各節點通過各所述節點間的通信鏈路進行端到端的信息傳輸，包括：

控制所述第二節點通過與所述第一節點的通信鏈路接收所述第一節點發送的原始信息，以使所述第二節點將對所述原始信息進行消費后生成的訂閱信息發送至所述第三節點，所述原始信息由所述第一節點根據所述第三節點的消費請求生成。

進一步的，以使所述第二節點將對所述原始信息進行消費后生成的訂閱信息發送至所述第三節點，包括：

控制所述第二節點通過與所述第三節點的通信鏈路接收所述第三節點的所述消費請求，以使所述第二節點根據所述消費請求與所述原始信息匹配結果對所述原始信息進行消費，生成所述訂閱信息發送至所述第三節點。

進一步的，所述將各所述節點切換至與消息中間件的通信鏈路，通過所述消息中間件進行各所述節點間的信息傳輸，包括：

將各所述節點切換至與消息中間件的通信鏈路后，接收所述生產節點提供的信息，并將從所述生產節點接收到的信息標記為緩存信息；

檢測所述消息中間件中存在的信息，并在檢測到所述消息中間件中不存在與所述緩存信息相同的信息時，將所述緩存信息發送至所述消息中間件，以使所述消息中間件將所述緩存信息轉發至對應的所述消費節點。

進一步的，所述消息中間件與各所述節點間的通信協議為RSocket。