解决秒杀系统库存超卖问题：乐观锁与Redis分布式锁的应用

GeekLiHua

发布于 2025-01-21 15:46:19

16600

代码可运行

文章被收录于专栏：JavaJava

运行总次数：0

代码可运行

解决秒杀系统库存超卖问题：乐观锁与Redis分布式锁的应用

秒杀系统在高并发场景下，库存超卖问题一直是业务开发中的一大难题。本文将详细介绍如何使用乐观锁和Redis分布式锁来解决这一问题，以确保秒杀系统的稳定性和高性能。

1. 乐观锁解决方案

乐观锁是一种无锁机制，通过版本号的方式实现并发控制。在秒杀系统中，我们可以在商品表中增加一个版本号字段，每次更新库存时同时更新版本号。用户提交秒杀请求时，先获取商品的版本号，然后在更新库存时验证版本号是否仍然一致，如果一致则更新成功，否则说明有其他用户已经修改了库存。以下是具体的实现代码：

1.1 数据库表设计

CREATE TABLE t_goods (
    id INT PRIMARY KEY,
    name VARCHAR(255),
    stock INT,
    version INT
);

1.2 商品服务代码

@Service
public class GoodsService {

    @Autowired
    private GoodsDao goodsDao;

    public boolean seckillGoods(long userId, long goodsId) {
        Goods goods = goodsDao.getGoodsById(goodsId);
        if (goods.getStock() > 0) {
            int affectedRows = goodsDao.reduceStock(goodsId, goods.getVersion());
            if (affectedRows > 0) {
                // 更新成功，进行秒杀操作
                createSeckillOrder(userId, goodsId);
                return true;
            }
        }
        return false;
    }
}

1.3 数据库更新方法

@Update("UPDATE t_goods SET stock = stock - 1, version = version + 1 WHERE id = #{goodsId} AND version = #{version}")
int reduceStock(@Param("goodsId") long goodsId, @Param("version") int version);

2. Redis分布式锁解决方案

在分布式环境中，为了确保多个节点的并发安全，我们可以使用Redis分布式锁。以下是使用Redisson实现的分布式锁代码：

2.1 引入Redisson依赖

<dependency>
    <groupId>org.redisson</groupId>
    <artifactId>redisson-spring-boot-starter</artifactId>
    <version>3.17.1</version> <!-- 请根据实际情况选择版本 -->
</dependency>

2.2 Redis分布式锁代码

@Service
public class GoodsService {

    @Autowired
    private RedissonClient redissonClient;

    public boolean seckillGoods(long userId, long goodsId) {
        String lockKey = "seckill:" + goodsId;
        RLock lock = redissonClient.getLock(lockKey);

        try {
            if (lock.tryLock(500, 10, TimeUnit.MILLISECONDS)) {
                Goods goods = goodsDao.getGoodsById(goodsId);
                if (goods.getStock() > 0) {
                    // 秒杀成功，更新库存
                    goodsDao.reduceStock(goodsId);
                    // 创建秒杀订单等操作
                    return true;
                }
            }
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        } finally {
            lock.unlock();
        }
        return false;
    }
}