[發明專利]數據存儲方法和裝置

有效

• 申請號: 201810503062.2
• 申請日: 2018-05-23
• 公開（公告）號: CN108829740B
• 公開（公告）日: 2021-11-02
• 發明（設計）人: 張惕遠
• 申請（專利權）人: 搖了購(武漢)電子商務有限公司
• 主分類號: G06F16/22
• 分類號: G06F16/22;G06F16/23
• 代理公司: 北京超凡志成知識產權代理事務所(普通合伙) 11371
• 代理人: 陳曉云

本發明實施例提供一種數據存儲方法和裝置，該數據存儲方法包括獲取第一數據輪詢線程上的索引號并對該索引號進行自增，作為當前索引號，并判斷該當前索引號是否大于總索引號；若所述當前索引號不大于所述總索引號，則繼續判斷所述當前索引號的處理狀態是否為已處理狀態；若所述當前索引號的處理狀態為未處理狀態，則根據所述當前索引號提取數據對象并通過所述第一數據輪詢線程對該數據對象執行入庫操作。本發明能夠有效實現待存儲數據的異步入庫，以緩解高并發下的系統存儲壓力。

技術領域

本發明涉及數據處理技術領域，具體而言，涉及一種數據存儲方法和裝置。

背景技術

傳統的數據入庫是基于客戶端發出的數據入庫請求進行數據對象的存儲，而不會考慮執行對待存儲的數據對象進行入庫操作時是否有實時性要求、是否耗時等問題，且僅會在待存儲的數據對象完成入庫后才對客戶端進行響應。

發明內容

有鑒于此，本發明實施例提供一種數據存儲方法和裝置，能有效解決上述問題。

本發明較佳實施例提供一種數據存儲方法，應用于緩存服務器，所述方法包括：

獲取第一數據輪詢線程上的索引號并對該索引號進行自增，作為當前索引號，判斷該當前索引號是否大于總索引號；

若所述當前索引號不大于所述總索引號，則繼續判斷所述當前索引號的處理狀態是否為已處理狀態；

若所述當前索引號的處理狀態為未處理狀態，則根據所述當前索引號提取數據對象并通過所述第一數據輪詢線程對該數據對象執行入庫操作。

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

若所述當前索引號大于所述總索引號，則回退所述當前索引號，并根據資源對象鎖對所述第一數據輪詢線程執行等待操作直到第二數據輪詢線程通知所述第一數據輪詢線程存在數據對象需要入庫時所述第一數據輪詢線程解鎖并停止等待操作。

進一步地，根據所述當前索引號提取數據對象并通過所述第一數據輪詢線程對該數據對象執行入庫操作的步驟包括：

根據所述當前索引號獲取與該當前索引號對應的key；

根據所述key提取與該key對應的數據對象作為待入庫數據，并通過所述第一數據輪詢線程對所述待入庫數據執行入庫操作。

進一步地，通過所述第一數據輪詢線程對該數據對象執行入庫操作的步驟包括：

根據所述數據對象的主鍵值判斷數據庫服務器中是否存在與該主鍵值對應的數據對象；

若存在，則根據所述待入庫數據對所述數據庫服務器中已經存在的數據對象進行更新入庫操作；

若不存在，則對所述待入庫數據執行新增入庫操作。

進一步地，在執行獲取第一數據輪詢線程上的當前索引號的步驟之前，所述方法還包括：

創建用于將已緩存的數據對象存入數據庫服務器中的第一數據輪詢線程，以及用于接收各外部服務器生產的數據對象并進行數據緩存的第二數據輪詢線程。

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

通過所述第二數據輪詢線程獲取各外部服務器生產的數據對象，依次對各數據對象進行索引號設置，并對完成索引號設置的數據對象進行緩存。

本發明實施例還提供一種數據存儲裝置，應用于緩存服務器，所述裝置包括：

索引號獲取模塊，用于獲取第一數據輪詢線程上的索引號并對該索引號進行自增，作為當前索引號，判斷該當前索引號是否大于總索引號；

狀態判斷模塊，用于在所述當前索引號不大于所述總索引號時，繼續判斷所述當前索引號的處理狀態是否為已處理狀態；