日本免费高清视频-国产福利视频导航-黄色在线播放国产-天天操天天操天天操天天操|www.shdianci.com

學無先后，達者為師

網站首頁 編程語言 正文

Redis高并發場景下秒殺超賣解決方案(秒殺場景)_Redis

作者：趙廣陸 ? 更新時間： 2022-06-12 編程語言

1 什么是秒殺

秒殺最直觀的定義：在高并發場景下而下單某一個商品，這個過程就叫秒殺

【秒殺場景】

  • 火車票搶票
  • 雙十一限購商品
  • 熱度高的明星演唱會門票
  • …

2 為什么要防止超賣

早起的12306購票，剛被開發出來使用的時候，12306會經常出現 超賣 這種現象，也就是說車票只剩10張了，卻被20個人買到了，這種現象就是超賣！

還有在高并發的情況下，如果說沒有一定的保護措施，系統會被這種高流量造成宕機

  • 庫存100件 你賣了1000件 等著虧錢吧！
  • 防止黑客
  • 假如我們網站想下發優惠給群眾，但是被黑客利用技術將下發給群眾的利益收入囊中
  • 保證用戶體驗
  • 高并發場景下，網頁不能打不開、訂單不能支付 要保證網站的使用！

3 單體架構常規秒殺

3.1 常規減庫存代碼

/**
 * @Author oldlu
 */
@Service
@Transactional  //控制事務
public class OrderServiceImpl implements OrderService {

    @Autowired
    private StockMapper stockMapper;

    private OrderMapper orderMapper;

    //在非并發情況下無問題
    @Override
    public Integer kill(Integer id) {
        //根據商品id校驗庫存是否還存在
        Stock stock = stockMapper.checkStock(id);
        //當已售和庫存相等就庫存不足了
        if(stock.getSale().equals(stock.getCount())){
            throw new RuntimeException("庫存不足!");
        }else{
            //扣除庫存  (已售數量+1)
            stock.setSale(stock.getSale()+1);
            stockMapper.updateSale(stock);   //更新信息
            //創建訂單
            Order order = new Order();
            order.setSid(stock.getId()).setName(stock.getName()).setCreateDate(new Date());
            orderMapper.createOrder(order); //創建訂單
            return order.getId();   //mybatis主鍵生成策略 直接返回創建的id
        }
    }
}

測試controller

/**
 * @Author oldlu
 */
@RestController
@RequestMapping("/stock")
public class StockController {
    @Autowired
    private OrderService orderService;
    //開發秒殺方法
    @GetMapping("/kill/{id}")
    public String kill(@PathVariable("id") Integer id){
        System.out.println("秒殺商品的ID=====================>"+id);
        try {
            //根據秒殺商品id調用秒殺業務
            Integer orderId = orderService.kill(id);
            return "秒殺成功,訂單ID為："+String.valueOf(orderId);
        }catch (Exception e){
            e.printStackTrace();
            return e.getMessage();
        }
    }
}

正常情況看不會有什么問題,就是你訪問一下庫存少一個

3.2 模擬高并發

3.3 超賣現象

3.4 分析原因

線程不安全,方法就是加鎖,單機簡單加鎖即可解決,如果是分布式集群模式搭建那就要考慮分布式鎖

4 簡單實現悲觀樂觀鎖解決單體架構超賣

4.1 悲觀鎖

/**
 * @Author oldlu
 */
@RestController
@RequestMapping("/stock")
public class StockController {

    @Autowired
    private OrderService orderService;

    //開發秒殺方法
    @GetMapping("/kill/{id}")
    public String kill(@PathVariable("id") Integer id){
        System.out.println("秒殺商品的ID=====================>"+id);
        try {
            //使用悲觀鎖
            synchronized (this){
                //根據秒殺商品id調用秒殺業務
                Integer orderId = orderService.kill(id);
                return "秒殺成功,訂單ID為："+String.valueOf(orderId);
            }
        }catch (Exception e){
            e.printStackTrace();
            return e.getMessage();
        }
    }

}

這樣效率很差會造成線程阻塞，線程排隊問題,對用戶的體驗不是很好,必須處理完一個才能繼續.

4.2 樂觀鎖

    /**
     * 扣除庫存
     * @param stock
     */
    public void updateSale(Stock stock){
        //扣除庫存  (已售數量+1)
        stock.setSale(stock.getSale()+1);
        stockMapper.updateSale(stock);   //更新信息
    }

/**
 * 扣除庫存
 * @param stock
 */
public void updateSale(Stock stock){
    //在sql層面完成銷量+1 和 版本號 +1 并且根據商品id和版本號同時查詢更新的商品
    Integer updRows = stockMapper.updateSale(stock);   //更新信息
    if(updRows == 0){   //代表沒有拿到版本號
        throw new RuntimeException("搶購失敗,請重試！");
    }
}

也就是沒更新成功說明已經秒殺完了, 相對悲觀鎖而言樂觀鎖保證了一定的效率，而不像悲觀鎖那樣會造成線程阻塞使用樂觀鎖需要使用版本號，在操作數據的時候要對版本號進行更新

4.3 redis鎖setnx

但是上述代碼在高并發，可能其他線程會釋放別人的鎖

4.4 使用Redision

https://github.com/redisson/redisson

5 分布式鎖的解決方案

實現分布式鎖的解決方案

6 采用緩存隊列防止超賣

高并發緩存隊列防止溢出解決方案

原文鏈接：https://blog.csdn.net/ZGL_cyy/article/details/124095922

欄目分類
最近更新