[發明專利]一種分布式環境下全局庫存控制方法及系統

在審

• 申請號: 202011036318.7
• 申請日: 2020-09-27
• 公開（公告）號: CN112102040A
• 公開（公告）日: 2020-12-18
• 發明（設計）人: 賀詩浩;何鑫堯;劉小齊;張雅娟;魏苗;王趙羿;雷鳴;劉廣宇;王維強;杜方舉
• 申請（專利權）人: 中國建設銀行股份有限公司
• 主分類號: G06Q30/06
• 分類號: G06Q30/06;G06Q10/08;G06F16/22;G06F16/2458;G06F16/27
• 代理公司: 北京三友知識產權代理有限公司 11127
• 代理人: 賈磊;劉飛

本發明提供一種分布式環境下全局庫存控制方法及系統，其包括：接收用戶的客戶端發送的購買請求或退回請求；根據購買請求消耗當前數據分片的庫存，或者，根據退回請求增加當前數據分片的庫存，生成訂單和訂單相關信息，并且將訂單相關信息發送到指定消息隊列；訂單相關信息包括：購買請求對應的被消耗的庫存，或者，退回請求對應的增加的庫存；監聽指定消息隊列的訂單相關信息，按照預設周期進行匯總統計，得到交易匯總統計結果，交易匯總統計結果是在預設周期內的交易的庫存之和；讀取交易匯總統計結果，根據交易匯總統計結果計算得到最新的全局庫存，并保存到全局庫存表中。該基于事件消息的流式統計方法，獲得數據存儲結構下的全局庫存視圖。

技術領域

本發明涉及分布式架構的在線交易系統，具體涉及一種分布式環境下全局庫存控制方法及系統。

背景技術

隨著科技的發展，越來越多的實體經濟在往電商的形式發展。用戶數量的不斷增長，導致對在線交易系統的并發性能要求越來越高。在不考慮性能情況下的庫存的增減，直接通過給數據庫表的單條數據加鎖即可實現。但是國內龐大的人口基數給系統的訪問帶來了巨大的壓力，為了提高性能，我們往往會采取并發的模式，高并發模式下由于多個用戶可同時下單，對在線交易系統會造成較大的壓力，故近年來面向客戶的在線交易系統逐步從集中式架構演化為分布式架構，具體說來又經過了系統功能的垂直拆分成前后臺和數據庫層，后臺應用邏輯層和數據庫層也逐步實現了分布式架構。隨著分庫分表等分布式數據架構的引入，不可避免地需要將同一邏輯實體的數據進行水平拆分，而從系統整體運營和維護的角度來看，依然需要整體的數據統計視圖。

在實現本發明過程中，發明人發現現有技術中至少存在如下問題：由于庫存被拆分，從全局角度就無法及時獲得一個完整的數據視圖，不利于管理運營方進行控制與決策。

發明內容

本發明實施例提供一種分布式環境下全局庫存控制方法及系統，以從全局角度獲得庫存統計數據視圖。

為達上述目的，第一方面，本發明實施例提供了一種分布式環境下全局庫存控制方法，其包括：

接收用戶的客戶端發送的購買請求或退回請求；

根據所述購買請求消耗當前數據分片的庫存，或者，根據所述退回請求增加當前數據分片的庫存，生成訂單和訂單相關信息，并且將所述訂單相關信息發送到指定消息隊列；其中，所述訂單相關信息包括：所述購買請求對應的被消耗的庫存，或者，所述退回請求對應的增加的庫存；

監聽所述指定消息隊列的所述訂單相關信息，按照預設周期進行匯總統計，得到交易匯總統計結果，所述交易匯總統計結果是在所述預設周期內的交易的庫存之和；

讀取所述交易匯總統計結果，根據所述交易匯總統計結果計算得到最新的全局庫存，并保存到全局庫存表中。

第二方面，本發明實施例提供了一種分布式環境下全局庫存控制系統，其包括：

動態流控模塊，包括接收轉發子模塊，用于接收用戶的客戶端發送的購買請求或退回請求；

訂單服務模塊，用于根據所述購買請求消耗當前數據分片的庫存，或者，根據所述退回請求增加當前數據分片的庫存，生成訂單和訂單相關信息，并且將所述訂單相關信息發送到指定消息隊列；其中，所述訂單相關信息包括：所述購買請求對應的被消耗的庫存，或者，所述退回請求對應的增加的庫存；

流式庫存統計模塊，用于監聽所述指定消息隊列的所述訂單相關信息，按照預設周期進行匯總統計，得到交易匯總統計結果，所述交易匯總統計結果是在所述預設周期內的交易的庫存之和；

庫存更新模塊，用于讀取所述交易匯總統計結果，根據所述交易匯總統計結果計算得到最新的全局庫存，并保存到全局庫存表中。

第三方面，本發明實施例提供了一種計算機可讀存儲介質，其上存儲有計算機程序，該程序被處理器執行時實現如上所述的一種分布式環境下全局庫存控制方法。