Redis高并发场景下秒杀超卖解决

Posted 2022-04-15 赵广陆

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了Redis高并发场景下秒杀超卖解决相关的知识，希望对你有一定的参考价值。

1 什么是秒杀

秒杀最直观的定义：在高并发场景下而下单某一个商品，这个过程就叫秒杀

2 为什么要防止超卖

早期的购票，刚被开发出来使用的时候，经常出现超卖这种现象，也就是说车票只剩10张了，却被20个人买到了，这种现象就是超卖！

还有在高并发的情况下，如果说没有一定的保护措施，系统会被这种高流量造成严重的损失

库存100件你卖了1000件等着亏钱吧！
防止恶意争抢
- 假如我们网站想下发优惠给群众，但是被不法分子利用技术将下发给群众的利益收入囊中
保证用户体验
- 高并发场景下，特别卡,别说秒杀了,打都打不开直接就不能用

3 单体架构常规秒杀

3.1 常规减库存代码

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

    @Autowired
    private StockMapper stockMapper;

    @Autowired
    private OrderMapper orderMapper;

    @Override
    public Integer SaleKill(Integer 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();

测试controller

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

    @Autowired
    private OrderService orderService;

    @GetMapping("/kill/id")
    public String SaleKill(@PathVariable("id") Integer id)
        try 
            Integer orderId = orderService.SaleKill(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("抢购失败,请重试！");