[發明專利]延時消息加載方法、裝置、設備及計算機可讀存儲介質

在審

• 申請號: 202010734028.3
• 申請日: 2020-07-24
• 公開（公告）號: CN111901224A
• 公開（公告）日: 2020-11-06
• 發明（設計）人: 陳真;王渝豐
• 申請（專利權）人: 中國平安財產保險股份有限公司
• 主分類號: H04L12/58
• 分類號: H04L12/58;H04L29/08;H04L12/823;H04L9/06
• 代理公司: 深圳市沃德知識產權代理事務所(普通合伙) 44347
• 代理人: 高杰;于志光

本發明涉及大數據技術領域，揭露了一種延時消息加載方法，包括：獲取延時消息，將所述延時消息傳輸至預設消息服務器中，通過定時器對所述延時消息進行延時到期監控，并選取延時到期的延時消息作為初始延時消息；對所述初始延時消息進行防重處理，得到目標延時消息，并將所述目標延時消息存入緩存中；查詢所述緩存中目標延時消息的發送記錄，根據所述發送記錄，執行所述目標延時消息的加載。本發明還涉及區塊鏈技術，所述延時消息可部署于區塊鏈節點中。本發明可以在于提高延時消息加載的時效性。

技術領域

本發明涉及大數據技術領域，尤其涉及一種延時消息加載的方法、裝置、電子設備及計算機可讀存儲介質。

背景技術

延時消息指的是消息發送后并不立即對用戶可見，而是在指定的時間投遞給用戶的消息。延時消息加載應用于“在一段時間之后，完成一個工作任務”的業務需求場景中。例如，其中一個業務需求場景為：一個網上商城系統中，在用戶下單后沒有立即支付，則所述商城系統會生成一個延時消息，并在用戶下單時間開始的預設時間間隔后加載所述延時消息提醒用戶在規定時間內還未支付，則商城訂單將被取消。通過延時消息加載的方式可以很好的減輕網上商城系統的后臺數據庫的壓力。

目前延時消息的加載主要通過數據庫輪詢的方式實現，即啟動一個cron定時任務加載延時消息，但是通過數據庫輪詢加載延時消息會存在如下弊端：需要在規定時間內輪詢一次延時消息，導致延時消息的加載時效性變差，同時在延時消息任務量大的情況下，需要耗費大量的系統維護成本。

發明內容

本發明提供一種延時消息加載的方法、裝置、電子設備及計算機可讀存儲介質，其主要目的在于提高延時消息加載的時效性以及降低系統維護成本。

為實現上述目的，本發明提供的一種延時消息加載方法，包括：

獲取延時消息，將所述延時消息傳輸至預設消息服務器中，通過定時器對所述延時消息進行延時到期監控，并選取延時到期的延時消息作為初始延時消息；

對所述初始延時消息進行防重處理，得到目標延時消息，并將所述目標延時消息存入緩存中；

查詢所述緩存中目標延時消息的發送記錄，根據所述發送記錄，執行所述目標延時消息的加載。

可選地，所述通過定時器對所述延時消息進行延時到期監控，包括：

獲取所述延時消息的延時時間，基于所述定時器創建定時任務服務，根據所述延時時間，利用所述定時任務服務監控所述延時消息的到期時間。

可選地，所述對所述初始延時消息進行防重處理，得到目標延時消息，包括：

計算所述初始延時消息的唯一標識，利用所述唯一標識生成所述初始延時消息的分布式鎖；

根據所述分布式鎖，判斷出所述初始延時消息在所述消息服務器中是否重復存在；

若重復存在，則刪除任意一個初始延時消息后生成所述目標延時消息；

若沒有重復存在，則生成所述目標延時消息。

可選地，所述執行所述目標延時消息的加載之后，該方法還包括：

獲取所述目標延時消息的版本信息，根據所述版本信息，過濾所述預設消息服務器中對應的延時消息。

可選地，所述版本信息包括：唯一標識、版本號以及序列號。

為了解決上述問題，本發明還提供一種延時消息加載裝置，所述裝置包括：

監控模塊，用于獲取延時消息，將所述延時消息傳輸至預設消息服務器中，通過定時器對所述延時消息進行延時到期監控，并選取延時到期的延時消息作為初始延時消息；