電商系統中，sku的庫存是核心單元，本文以Javashop電商系統為例，說明庫存的存儲于扣減思路

商品庫存更新庫存添加和扣減，當用戶執行下單操作時 發送消息給MQ, consumer執行扣減庫存操作。商家端有單獨接口維護庫存。

庫存更新主要是操作商品Sku庫存信息。SKU是物理上不可分割的最小存貨單元。也就是說一款商品，可以根據SKU來確定具體的貨物存量。對應es_goods_sku表

商品庫存和商品sku庫存

商品的可用庫存和實際庫存（actual 實際庫存）（enable 可用庫存）

在redis中的鍵為庫存前綴_庫存名稱_商品id

{stock}{GOODS_STOCK}_actual_65

{stock}{GOODS_STOCK}_enable_127

sku的實際庫存和可用庫存

在redis中的鍵為庫存前綴_庫存名稱_商品skuid

{stock}{SKU_STOCK}_actual_1320633609858965506

{stock}{SKU_STOCK}_enable_1310759679300034562

商家端更新商品庫存，通GoodsQuantityManager.updateSkuQuantity() 將sku和商品信息更新到redis和數據庫 如果lua腳本執行成功，判斷javashopConfig配置中是否開啟緩沖池，如果開啟則更新緩沖區庫存，未開啟則同步數據到數據庫庫存。

首先查出緩存商品信息 包括商品信息 和商品sku信息

@PutMapping
public void updateQuantity(@ApiIgnore@Valid @RequestBody List<GoodsSkuQuantityVO>  skuQuantityList, @PathVariable("goods_id")Long goodsId)  {

   CacheGoods goods = goodsQueryManager.getFromCache(goodsId);

   Seller seller = UserContext.getSeller();
   if(goods == null || !goods.getSellerId().equals(seller.getSellerId())){
      throw new ServiceException(GoodsErrorCode.E307.code(), "沒有操作權限");
   }

   // 原有的sku集合
   List<GoodsSkuVO> skuList = goods.getSkuList();
   Map<Long,GoodsSkuVO> skuMap = new HashMap<>(skuList.size());
   for(GoodsSkuVO sku : skuList){
      skuMap.put(sku.getSkuId(), sku);
   }

校驗庫存 判斷商品庫存數量，是否具有sku信息和待發貨數量 代發貨數量必須小于可用庫存數量，實際庫存是設置后固定，可用庫存是當前剩余庫存量

//要更新的庫存列表
List<GoodsQuantityVO> stockList = new ArrayList<>();

for (GoodsSkuQuantityVO quantity : skuQuantityList) {

   if (quantity.getQuantityCount() == null || quantity.getQuantityCount() < 0 ) {
      throw new ServiceException(GoodsErrorCode.E307.code(), "sku總庫存不能為空或負數");
   }

   GoodsSkuVO sku = skuMap.get(quantity.getSkuId());
   if(sku == null){
      throw new ServiceException(GoodsErrorCode.E307.code(), "商品sku不存在");
   }
   //待發貨數
   Integer waitRogCount = sku.getQuantity()-sku.getEnableQuantity();
   //判斷庫存是否小于待發貨數
   if (quantity.getQuantityCount()<waitRogCount) {
      throw new ServiceException(GoodsErrorCode.E307.code(), "sku庫存數不能小于待發貨數");
   }

實際庫存和可用庫存 庫存

//實際庫存
   GoodsQuantityVO actualQuantityVo = new GoodsQuantityVO();
   //用傳遞的數量-現有的，就是變化的，如傳遞的是2000，原來是200，則就+1800，如果傳遞的是100，原來是200則就是-100
   int stockNum = quantity.getQuantityCount() -sku.getQuantity();
   actualQuantityVo.setQuantity(stockNum );
   actualQuantityVo.setGoodsId(goodsId);
   actualQuantityVo.setQuantityType(QuantityType.actual);
   actualQuantityVo.setSkuId(quantity.getSkuId());

   stockList.add(actualQuantityVo);

   //clone 一個quantity vo 設置為更新可用庫存
   try {
      GoodsQuantityVO enableVo =(GoodsQuantityVO)    actualQuantityVo.clone();
      enableVo.setQuantityType(QuantityType.enable);
      stockList.add(enableVo);
   } catch (CloneNotSupportedException e) {
      throw new ServiceException(GoodsErrorCode.E307.code(), "goodsQuantityVo clone error");
   }

}

更新庫存 數據庫和緩存中都需要更新，當開啟緩沖池并且緩沖池中數據已經飽和 則同步更新數據庫，如果未開啟緩沖池，則實時同步商品數據庫中的庫存數據

//更新庫存
this.goodsQuantityManager.updateSkuQuantity(stockList);

//如果商品庫存緩沖池開啟了，那么需要立即同步數據庫的商品庫存，以保證商品庫存顯示正常
if (javashopConfig.isStock()) {
   //立即同步數據庫的庫存
   goodsQuantityManager.syncDataBase();
}

更新sku庫存采用redis+lua腳本 利用redis原子性避免超賣問題

public Boolean updateSkuQuantity(List<GoodsQuantityVO> goodsQuantityList) {

    List<Long> skuIdList = new ArrayList();
    List<Long> goodsIdList = new ArrayList();

    List keys = new ArrayList<>();
    List values = new ArrayList<>();

    for (GoodsQuantityVO quantity : goodsQuantityList) {

        Assert.notNull(quantity.getGoodsId(), "goods id must not be null");
        Assert.notNull(quantity.getSkuId(), "sku id must not be null");
        Assert.notNull(quantity.getQuantity(), "quantity id must not be null");
        Assert.notNull(quantity.getQuantityType(), "Type must not be null");


        //sku庫存
        if (QuantityType.enable.equals(quantity.getQuantityType())) {
            keys.add(StockCacheKeyUtil.skuEnableKey(quantity.getSkuId()));
        } else if (QuantityType.actual.equals(quantity.getQuantityType())) {
            keys.add(StockCacheKeyUtil.skuActualKey(quantity.getSkuId()));
        }
        values.add("" + quantity.getQuantity());

        //goods庫存key
        if (QuantityType.enable.equals(quantity.getQuantityType())) {
            keys.add(StockCacheKeyUtil.goodsEnableKey(quantity.getGoodsId()));
        } else if (QuantityType.actual.equals(quantity.getQuantityType())) {
            keys.add(StockCacheKeyUtil.goodsActualKey(quantity.getGoodsId()));
        }
        values.add("" + quantity.getQuantity());


        skuIdList.add(quantity.getSkuId());
        goodsIdList.add(quantity.getGoodsId());
    }

    RedisScript<Boolean> redisScript = getRedisScript();
    Boolean result = stringRedisTemplate.execute(redisScript, keys, values.toArray());

    logger.debug("更新庫存：");
    logger.debug(goodsQuantityList.toString());
    logger.debug("更新結果：" + result);

    //如果lua腳本執行成功則記錄緩沖區
    if (result) {

        //判斷配置文件中設置的商品庫存緩沖池是否開啟
        if (javashopConfig.isStock()) {

            //是否需要同步數據庫
            boolean needSync = getSkuPool().oneTime(skuIdList);
            getGoodsPool().oneTime(goodsIdList);

            logger.debug("是否需要同步數據庫:" + needSync);
            logger.debug(getSkuPool().toString());

            //如果開啟了緩沖池，并且緩沖區已經飽和，則同步數據庫
            if (needSync) {
                syncDataBase();
            }
        } else {
            //如果未開啟緩沖池，則實時同步商品數據庫中的庫存數據
            syncDataBase(skuIdList, goodsIdList);
        }

    }


    return result;
}

總結

以上是生活随笔為你收集整理的电商系统中库存的存储于扣减的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。