[發明專利]處理異步消息的方法、裝置及設備

在審

• 申請號: 201810482053.X
• 申請日: 2018-05-18
• 公開（公告）號: CN108712494A
• 公開（公告）日: 2018-10-26
• 發明（設計）人: 鄒靖贇
• 申請（專利權）人: 阿里巴巴集團控股有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08;G06F9/54
• 代理公司: 北京博思佳知識產權代理有限公司 11415
• 代理人: 林祥

本說明書實施例提供一種處理異步消息的方法、裝置及設備，該方案中，消息發送方令異步消息攜帶有該消息的發送時刻，則消息接收方接收到消息后，可以對比所述消息的接收時刻和所述發送時刻，通過判斷兩者差值是否超過預設延遲閾值，消息接收方可以發現該消息是否發生嚴重延遲；基于此，消息接收方可以記錄差值超過預設延遲閾值的數量，進而可以自動決策是否啟動延遲應對流程。

技術領域

本說明書涉及互聯網技術領域，尤其涉及處理異步消息的方法、裝置及設備。

背景技術

目前，大型的網絡服務系統常常會面臨高并發請求，因此有些業務可以采用異步化方式來實現。作為例子，A系統的一個業務需要調用B系統一個接口時，如果對實時性的要求不是特別高，A系統可以把消息發給中間件(也可以稱為消息隊列服務)，然后A系統就可以完成這些業務，而之后的消息投遞過程就完全交給中間件來實現。根據業務配置，中間件可以即刻投遞消息給B系統，也可以延遲一定時間后投遞?？梢岳斫?，高并發場景下，采用異步化方式，業務系統犧牲了一定的時效性來保障性能，但如果出現嚴重滯后也可能帶來一些問題。

發明內容

為克服相關技術中存在的問題，本說明書提供了處理異步消息的方法、裝置及設備。

根據本說明書實施例的第一方面，提供一種處理異步消息的方法，包括：

接收消息發送方的異步消息，所述異步消息攜帶有該異步消息的發送時間；

判斷所述異步消息是否滿足預設延遲條件；所述預設延遲條件基于以下至少任一參數設定：異步消息的數量、異步消息的接收時間或異步消息的發送時間；

根據判斷結果確定是否啟動延遲應對流程。

可選的，所述預設延遲條件包括：所述接收時間與發送時間的時間間隔超過預設時長。

可選的，所述預設延遲條件還包括：所述時間間隔超過預設時長的同一類異步消息的數量達到預定值。

可選的，所述類別包括：業務類別或指示消息所屬消息發送方的類別。

可選的，所述方法還包括：

在啟動延遲應對流程后，監測所述數量的增長頻率，根據監測結果確定是否終止所述延遲應對流程。

可選的，所述方法還包括：

若所述數量在預設時長內未增加，將所述數量清零。

根據本說明書實施例的第二方面，提供一種處理異步消息的裝置，包括：

消息接收模塊，用于：接收消息發送方的異步消息，所述異步消息攜帶有該異步消息的發送時間；

判斷模塊，用于：判斷所述異步消息是否滿足預設延遲條件；所述預設延遲條件基于以下至少任一參數設定：異步消息的數量、異步消息的接收時間或異步消息的發送時間；

確定模塊，用于：根據判斷結果確定是否啟動延遲應對流程。

可選的，所述預設延遲條件包括：所述接收時間與發送時間的時間間隔超過預設時長。

可選的，所述預設延遲條件還包括：所述時間間隔超過預設時長的同一類異步消息的數量達到預定值。

可選的，所述類別包括：業務類別或指示消息所屬消息發送方的類別。

可選的，所述裝置還包括監測模塊，用于：

在啟動延遲應對流程后，監測所述數量的增長頻率，根據監測結果確定是否終止所述延遲應對流程。

可選的，所述判斷模塊，還用于：

若所述數量在預設時長內未增加，將所述數量清零。