[發明專利]用于規則引擎的消息路由方法和裝置

有效

• 申請號: 202011384594.2
• 申請日: 2020-11-30
• 公開（公告）號: CN112532528B
• 公開（公告）日: 2023-04-25
• 發明（設計）人: 張揚揚
• 申請（專利權）人: 北京百度網訊科技有限公司
• 主分類號: H04L45/28
• 分類號: H04L45/28;H04L45/02;H04L9/40;H04L67/1042
• 代理公司: 中科專利商標代理有限責任公司 11021
• 代理人: 范芳茗

1.一種用于規則引擎的消息路由方法，包括，通過所述規則引擎執行以下操作：

響應于從消息中間件獲取到目標消息，基于所述規則引擎中設置的路由規則，規劃所述目標消息的第一傳輸路徑，并使所述目標消息按照所述第一傳輸路徑路由至第一節點，其中，所述第一節點位于公有云的內部；以及

響應于所述目標消息在所述第一傳輸路徑中出現消息流轉失敗的情況，基于所述路由規則重新規劃所述目標消息的第二傳輸路徑，并使所述目標消息按照所述第二傳輸路徑路由至不同于所述第一節點的一個或者多個第二節點，其中，所述一個或者多個第二節點包括外部目的地節點，所述外部目的地節點位于所述公有云的外部；

所述方法還包括：在基于所述路由規則重新規劃所述目標消息的第二傳輸路徑之前，

獲取針對所述目標消息創建的所述外部目的地節點的地址信息；以及

將所述地址信息添加到外部目的地節點列表中，以便用于配置所述路由規則；

所述方法還包括：使所述目標消息按照所述第二傳輸路徑路由至不同于所述第一節點的一個或者多個第二節點之前，

使所述規則引擎與所述外部目的地節點建立連接。

2.根據權利要求1所述的方法，還包括：

響應于接收到針對所述外部目的地節點列表的查詢請求，展示所述外部目的地節點列表。

3.根據權利要求1所述的方法，其中：

使所述規則引擎與所述外部目的地節點基于以下信息中的至少之一建立連接：用戶名和密碼；數字證書。

4.根據權利要求1所述的方法，還包括：在所述規則引擎與所述外部目的地節點建立連接之后，

對所述規則引擎與所述外部目的地節點進行連通性檢測。

5.根據權利要求1所述的方法，其中，所述外部目的地節點包括：Kafka集群。

6.一種消息路由裝置，應用于規則引擎，所述裝置包括：

第一路徑規劃模塊，用于響應于從消息中間件獲取到目標消息，基于所述規則引擎中設置的路由規則，規劃所述目標消息的第一傳輸路徑；

第一消息路由模塊，用于使所述目標消息按照所述第一傳輸路徑路由至第一節點，其中，所述第一節點位于公有云的內部；

第二路徑規劃模塊，用于響應于所述目標消息在所述第一傳輸路徑中出現消息流轉失敗的情況，基于所述路由規則重新規劃所述目標消息的第二傳輸路徑；以及

第二消息路由模塊，用于使所述目標消息按照所述第二傳輸路徑路由至不同于所述第一節點的一個或者多個第二節點，其中，所述一個或者多個第二節點包括外部目的地節點，所述外部目的地節點位于所述公有云的外部；

所述裝置還包括：

地址獲取模塊，用于在基于路由規則重新規劃目標消息的第二傳輸路徑之前，獲取針對目標消息創建的外部目的地節點的地址信息；

信息添加模塊，用于將地址信息添加到外部目的地節點列表中，以便用于配置路由規則；以及

連接模塊，用于在使目標消息按照第二傳輸路徑路由至不同于第一節點的一個或者多個第二節點之前，使規則引擎與外部目的地節點建立連接。

7.一種電子設備，其中，包括：

至少一個處理器；以及

與所述至少一個處理器通信連接的存儲器；其中，

所述存儲器存儲有可被所述至少一個處理器執行的指令，所述指令被所述至少一個處理器執行，以使所述至少一個處理器能夠執行權利要求1-5中任一項所述的方法。

8.一種存儲有計算機指令的非瞬時計算機可讀存儲介質，其中，所述計算機指令用于使所述計算機執行權利要求1-5中任一項所述的方法。