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

有效

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

本申請公開了一種用于規則引擎的消息路由方法，涉及規則引擎領域，可用于云平臺、物聯網等領域。具體實現方案為：通過規則引擎執行以下操作：響應于獲取到目標消息，基于規則引擎中設置的路由規則，規劃目標消息的第一傳輸路徑，并使目標消息按照第一傳輸路徑路由至第一節點；以及響應于目標消息在第一傳輸路徑中出現消息流轉失敗的情況，基于路由規則重新規劃目標消息的第二傳輸路徑，并使目標消息按照第二傳輸路徑路由至不同于第一節點的一個或者多個第二節點，其中，一個或者多個第二節點包括外部目的地節點。

技術領域

本申請涉及規則引擎領域，可用于云平臺、物聯網等領域，更具體地，涉及一種用于規則引擎的消息路由方法和裝置、電子設備和存儲介質。

背景技術

在物聯網等領域應用規則引擎的場景下，消息流轉過程中由于消息處理異常、數據目的地異常等原因，可能會導致數據丟失。

發明內容

本申請提供了一種用于規則引擎的消息路由方法和裝置、電子設備以及存儲介質。

根據第一方面，提供了一種用于規則引擎的消息路由方法，包括：通過上述規則引擎執行以下操作：響應于獲取到目標消息，基于上述規則引擎中設置的路由規則，規劃上述目標消息的第一傳輸路徑，并使上述目標消息按照上述第一傳輸路徑路由至第一節點；以及響應于上述目標消息在上述第一傳輸路徑中出現消息流轉失敗的情況，基于上述路由規則重新規劃上述目標消息的第二傳輸路徑，并使上述目標消息按照上述第二傳輸路徑路由至不同于上述第一節點的一個或者多個第二節點，其中，上述一個或者多個第二節點包括外部目的地節點。

根據第二方面，提供了一種消息路由裝置，應用于規則引擎，上述裝置包括：第一路徑規劃模塊，用于響應于獲取到目標消息，基于上述規則引擎中設置的路由規則，規劃上述目標消息的第一傳輸路徑；第一消息路由模塊，用于使上述目標消息按照上述第一傳輸路徑路由至第一節點；第二路徑規劃模塊，用于響應于上述目標消息在上述第一傳輸路徑中出現消息流轉失敗的情況，基于上述路由規則重新規劃上述目標消息的第二傳輸路徑；以及第二消息路由模塊，用于使上述目標消息按照上述第二傳輸路徑路由至不同于上述第一節點的一個或者多個第二節點，其中，上述一個或者多個第二節點包括外部目的地節點。

根據第三方面，提供了一種電子設備，包括：至少一個處理器；以及與上述至少一個處理器通信連接的存儲器；其中，上述存儲器存儲有可被上述至少一個處理器執行的指令，上述指令被上述至少一個處理器執行，以使上述至少一個處理器能夠執行本申請實施例的方法。

根據第四方面，提供了一種存儲有計算機指令的非瞬時計算機可讀存儲介質，包括：上述計算機指令用于使上述計算機執行本申請實施例的方法。

根據第五方面，提供了一種計算機程序產品，包括計算機程序，所述計算機程序在被處理器執行時實現上述方法。

根據本申請實施例提供的技術方案，可以在規則引擎中預先創建一些路由規則，在這些路由規則中除了配置指定的內部目的地節點的地址等相關信息之外，還可以添加外部目的地節點的地址等相關信息。由此，在通過這些路由規則將消息路由至指定的內部目的地節點出現消息流轉失敗的情況下，還可以將流轉失敗的消息重新路由至新添加的外部目的地節點，不僅可以防止數據丟失，而且可以提高路由規則配置的便利性和靈活性，以滿足用戶的個性化需求。

應當理解，本部分所描述的內容并非旨在標識本申請的實施例的關鍵或重要特征，也不用于限制本申請的范圍。本申請的其它特征將通過以下的說明書而變得容易理解。

附圖說明

附圖用于更好地理解本方案，不構成對本申請的限定。其中：

圖1示例性示出了適于本申請實施例的用于規則引擎的消息路由方法和裝置的系統架構；

圖2示例性示出了根據本申請實施例的用于規則引擎的消息路由方法的流程圖；