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

在審

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

1.一種信息傳輸方法，其特征在于，包括：

實時獲取當前環境參數；

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

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

2.根據權利要求1所述的信息傳輸方法，其特征在于，所述控制節點集群中的各節點通過各所述節點間的通信鏈路進行端到端的信息傳輸，包括：

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

3.根據權利要求2所述的信息傳輸方法，其特征在于，所述分區通過哈希分區策略或Round-robin分區策略確定。

4.根據權利要求1所述的信息傳輸方法，其特征在于，所述生產節點包括第一節點，所述消費節點包括第二節點和第三節點；

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

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

5.所述根據權利要求4所述的信息傳輸方法，其特征在于，以使所述第二節點將對所述原始信息進行消費后生成的訂閱信息發送至所述第三節點，包括：

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

6.根據權利要求1所述的信息傳輸方法，其特征在于，所述將各所述節點切換至與消息中間件的通信鏈路，通過所述消息中間件進行各所述節點間的信息傳輸，包括：

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

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

7.根據權利要求1所述的信息傳輸方法，其特征在于，所述消息中間件與各所述節點間的通信協議為RSocket。

8.根據權利要求1所述的信息傳輸方法，其特征在于，各所述節點采用的API相同。

9.一種信息傳輸裝置，其特征在于，包括：

數據獲取模塊，用于實時獲取當前環境參數；

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

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

10.一種電子設備，其特征在于，包括：存儲器、處理器及存儲在存儲器上并可在處理器上運行的計算機程序，其特征在于，所述處理器執行所述程序時實現如權利要求1至權利要求8任一項所述的信息傳輸方法。

11.一種信息傳輸系統，其特征在于，包括多個節點、消息中間件以及如權利要求10所述的電子設備，各所述節點至少包括生產節點和消費節點；

各所述節點用于在接收到所述電子設備的第一控制信號時，通過各所述節點間的通信鏈路進行端到端的信息傳輸；以及，

在接收到所述電子設備的第二控制信號時，切換至與消息中間件的通信鏈路，通過所述消息中間件進行各所述節點間的信息傳輸。