解决秒杀系统库存超卖问题：乐观锁与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; } }
3. 优缺点比较
3.1 乐观锁
优点：
- 无锁机制，不会阻塞其他线程。
- 对于读多写少的场景性能较好。
缺点：
- 需要额外的版本号字段。
- 在高并发写入场景下，容易出现CAS失败，需要重试。
3.2 Redis分布式锁
优点：
- 在分布式环境中保证了并发安全。
- 使用简单，不需要修改数据库表结构。
缺点：
- 引入了额外的依赖，可能对性能有一定影响。
- 锁的过期时间需要谨慎设置，过长可能导致死锁，过短可能引起并发问题。
