[發明專利]一種消息處理方法、裝置、系統、電子設備及存儲介質

有效

• 申請號: 202010618081.7
• 申請日: 2020-06-30
• 公開（公告）號: CN111786886B
• 公開（公告）日: 2022-09-06
• 發明（設計）人: 崔博文
• 申請（專利權）人: 京東科技控股股份有限公司
• 主分類號: H04L45/00
• 分類號: H04L45/00;G06Q30/06;G06Q40/08
• 代理公司: 北京華夏泰和知識產權代理有限公司 11662
• 代理人: 沈園園;王衛忠

本申請涉及一種消息服務方法、裝置、電子設備及存儲介質，該方法包括：獲取監聽到的服務消息的消息類型；根據所述消息類型確定所述服務消息對應的目標處理對象；解析所述服務消息中的參數信息確定路由策略；根據所述路由策略將所述服務消息發送至所述目標處理對象。該技術方案通過判斷服務消息的消息類型，根據消息類型確定目標處理終端，以及確定路由策略，通過路由策略將服務消息發送至目標處理對象，解決了現有技術中所有處理終端監聽服務消息導致系統承受壓力大，以及容易造成資源浪費的問題。

技術領域

本申請涉及數據處理領域，尤其涉及一種消息處理方法、裝置、系統、電子設備及存儲介質。

背景技術

目前在電子商務平臺的的訂單系統中，伴隨著訂單狀態的變化，系統會發送不同的服務消息，例如：訂單系統包括：下單完成，出庫，妥投，簽收成功等節點，其中每一個節點對應一個消息隊列，當訂單狀態處于某一個節點時，該節點對應的消息隊列會向業務處理系統發送服務消息。在實現本發明的過程中，發明人發現，在現有技術中任何一個消息隊列在產生服務消息時，業務處理系統中的處理終端都會去監聽此條消息。此種方式不但會造成業務處理過程中的資源浪費，而且會造成業務處理系統壓力過大。

發明內容

為了解決上述技術問題或者至少部分地解決上述技術問題，本申請提供了一種消息處理方法、裝置、系統、電子設備及存儲介質。

根據本申請實施例的一個方面，提供了一種消息處理方法，包括：

獲取監聽到的服務消息的消息類型；

根據所述消息類型確定所述服務消息對應的目標處理對象；

解析所述服務消息中的參數信息確定路由策略；

根據所述路由策略將所述服務消息發送至所述目標處理對象。

進一步的，所述獲取監聽到的服務消息的消息類型包括：

獲取所述服務消息的字段信息；

按照預設規則對所述字段信息進行分析確定所述服務消息的消息類型。

進一步的，所述根據所述消息類型確定所述服務消息對應的目標處理對象，包括：

根據所述消息類型確定所述服務消息對應的至少一個處理對象；

確定滿足第一預設條件的處理對象為所述目標處理對象。

進一步的，所述方法還包括：

確定所述目標處理對象的目標數量；

根據所述目標數量將所述服務消息加載至任務列表。

進一步的，在解析所述服務消息中的參數信息確定路由策略之前，所述方法還包括：

基于所述任務列表讀取所述服務消息攜帶的報文內容；

對所述報文內容中參數信息的參數類型進行分析得到分析結果。

進一步的，所述解析所述服務消息中的參數信息確定路由策略，包括：

當根據所述分析結果確定所述服務消息滿足第二預設條件時，獲取所述報文內容中的標識信息；

根據所述標識信息確定所述路由策略。

根據本申請實施例的另一個方面，還提供了一種消息處理裝置，包括：

分析模塊，用于獲取監聽到的服務消息的消息類型；

確定模塊，用于根據所述消息類型確定所述服務消息對應的目標處理對象；

解析模塊，用于解析所述服務消息中的參數信息確定路由策略；