[發明專利]消息異步處理方法和裝置

有效

• 申請號: 201610835127.4
• 申請日: 2016-09-20
• 公開（公告）號: CN107786623B
• 公開（公告）日: 2021-03-30
• 發明（設計）人: 王博;李松林;吳凱
• 申請（專利權）人: 平安科技（深圳）有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08
• 代理公司: 廣州華進聯合專利商標代理有限公司 44224
• 代理人: 王寧

本發明涉及一種消息異步處理方法和裝置，所述方法包括：拉取消息數據；將所述消息數據寫入緩存，所述消息數據包括消息內容和終端標識，所述終端標識與用戶終端對應，所述用戶終端與第一服務器連接；在緩存中讀取消息數據，將讀取到的消息數據發送至與終端標識對應的第一服務器，以使得所述第一服務器將所述消息內容發送至與所述終端標識對應的客戶終端，并且返回對應的狀態數據；接收所述狀態數據，將所述消息數據和對應的狀態數據映射至數據庫進行保存。采用本方法能夠有效提高海量消息發送效率。

技術領域

本發明涉及計算機技術領域，特別是涉及一種消息異步處理方法和裝置。

背景技術

目前保險已逐步深入到了人們的日常生活中，保險種類也是日益繁多。為了能夠讓客戶更便捷的了解保險信息，保險公司通常會主動向客戶發送各種消息。在傳統的方式中，后臺會將各種各樣需要發送的消息先寫入數據庫，然后再從數據庫中讀取出來，將消息發送至運營商服務器，通過運營商服務器將消息發送至用戶終端。由于每條消息的讀寫都需要耗費一定的時間，當消息的數量達到百萬甚至千萬級別時，這種傳統的方式，勢必會導致消息發送效率下降。面對海量消息時如何有效提高發送效率成為目前需要解決的一個技術問題。

發明內容

基于此，有必要針對上述技術問題，提供一種能夠有效提高海量消息發送效率的消息異步處理方法和裝置。

一種消息異步處理方法，所述方法包括：

拉取消息數據；

將所述消息數據寫入緩存，所述消息數據包括消息內容和終端標識，所述終端標識與用戶終端對應，所述用戶終端與第一服務器連接；

在緩存中讀取消息數據，將讀取到的消息數據發送至與終端標識對應的第一服務器，以使得所述第一服務器將所述消息內容發送至與所述終端標識對應的客戶終端，并且返回對應的狀態數據；

接收所述狀態數據，將所述消息數據和對應的狀態數據映射至數據庫進行保存。

在其中一個實施例中，所述消息數據和狀態數據通過主鍵標識進行關聯，所述將所述消息數據和對應的狀態數據映射至數據庫進行保存的步驟包括：

查詢數據庫中是否存在狀態數據對應的主鍵標識；

若存在，則根據所述主鍵標識將所述狀態數據在數據庫中進行更新；

否則，根據所述主鍵標識將所述消息數據和狀態數據映射至數據庫進行保存。

在其中一個實施例中，在所述將讀取到的消息數據發送至與終端標識對應的第一服務器的步驟之前，還包括：

根據消息模板標識的優先級確定消息數據對應的優先級；

根據所述優先級將消息數據分為多個隊列；

所述將讀取到的消息數據發送至與終端標識對應的第一服務器的步驟包括：

提取所述消息數據中的終端標識，采用多個線程對多個隊列中的消息內容按照所述優先級發送至與終端標識對應的第一服務器。

在其中一個實施例中，所述拉取消息數據的步驟包括：

對所述終端標識進行計數，判斷所述終端標識在第一預設時間內的累計數量是否大于第一預設數量；

若是，則根據所述終端標識拉取第一預設數量的消息數據，并且拒絕拉取所述終端標識對應的超出第一預設數量的消息數據。

在其中一個實施例中，所述方法還包括：

若在第二預設時間內超出第二預設數量的消息數據未被發送，則生成告警信息，并將所述告警信息發送至運營終端，所述運營終端用于遠程處理異常狀況，所述告警信息中包括異常網關；