# 使用乐观锁
地址
- Github:https://github.com/dolyw/SeckillEvolution (opens new window)
- Gitee(码云):https://gitee.com/dolyw/SeckillEvolution (opens new window)
- 0. 整体流程
- 1. 传统方式
- 2. 使用乐观锁
- 3. 使用缓存
- 4. 使用分布式限流
- 5. 使用队列异步下单
# 1. 思路介绍
这次我们引入乐观锁,这里可以先查看一篇文章: MySQL那些锁 (opens new window)
主要改造是扣库存,每个线程在检查库存的时候会拿到当前商品的乐观锁版本号,然后在扣库存时,如果版本号不对,就会扣减失败,抛出异常结束,这样每个版本号就只能有一个线程操作成功,其他相同版本号的线程秒杀失败,就不会存在卖超问题了
# 2. 代码实现
在SeckillEvolutionController创建一个乐观锁下订单入口的方法
- SeckillEvolutionController
/**
* 使用乐观锁下订单
*
* @param id 商品ID
* @return com.example.common.ResponseBean
* @throws Exception
* @author wliduo[i@dolyw.com]
* @date 2019/11/22 14:24
*/
@PostMapping("/createOptimisticLockOrder/{id}")
public ResponseBean createOptimisticLockOrder(@PathVariable("id") Integer id) throws Exception {
Integer orderCount = seckillEvolutionService.createOptimisticLockOrder(id);
return new ResponseBean(HttpStatus.OK.value(), "购买成功", orderCount);
}
在Service添加方法
- ISeckillEvolutionService
/**
* 使用乐观锁创建订单(解决卖超问题)
*
* @param id
* @return java.lang.Integer
* @throws Exception
* @author wliduo[i@dolyw.com]
* @date 2019/11/22 14:21
*/
Integer createOptimisticLockOrder(Integer id) throws Exception;
- ISeckillEvolutionService
/**
* 乐观锁方式(名称注入)
*/
@Autowired
@Qualifier("seckillOptimisticLockService")
private ISeckillService seckillOptimisticLockServiceImpl;
@Override
@Transactional(rollbackFor = Exception.class)
public Integer createOptimisticLockOrder(Integer id) throws Exception {
// 检查库存
StockDto stockDto = seckillOptimisticLockServiceImpl.checkStock(id);
Thread.sleep(10);
// 扣库存
Integer saleCount = seckillOptimisticLockServiceImpl.saleStock(stockDto);
if (saleCount <= 0) {
throw new CustomException("扣库存失败");
}
// 下订单
Integer orderCount = seckillOptimisticLockServiceImpl.createOrder(stockDto);
if (saleCount <= 0) {
throw new CustomException("下订单失败");
}
return orderCount;
}
然后创建一个ISeckillService的使用乐观锁方式的实现类提供上面使用
- SeckillOptimisticLockServiceImpl
package com.example.seckill.impl;
import ...;
/**
* 使用乐观锁
*
* @author wliduo[i@dolyw.com]
* @date 2019-11-20 18:03:33
*/
@Service("seckillOptimisticLockService")
public class SeckillOptimisticLockServiceImpl implements ISeckillService {
@Autowired
private StockDao stockDao;
@Autowired
private StockOrderDao stockOrderDao;
@Override
public StockDto checkStock(Integer id) {
StockDto stockDto = stockDao.selectByPrimaryKey(id);
if (stockDto.getCount() > 0) {
return stockDto;
}
throw new CustomException("库存不足");
}
@Override
public Integer saleStock(StockDto stockDto) {
return stockDao.updateByOptimisticLock(stockDto);
}
@Override
public Integer createOrder(StockDto stockDto) {
StockOrderDto stockOrderDto = new StockOrderDto();
stockOrderDto.setStockId(stockDto.getId());
return stockOrderDao.insertSelective(stockOrderDto);
}
}
乐观锁详细使用方法实现,这里SQL直接写注解上了,没写XML里了,偷个懒
- StockDao
/**
* 乐观锁更新扣减库存
*
* @param stockDto
* @return int
* @throws
* @author wliduo[i@dolyw.com]
* @date 2019/11/22 14:14
*/
@Update("UPDATE t_seckill_stock SET count = count - 1, sale = sale + 1, version = version + 1 " +
"WHERE id = #{id, jdbcType = INTEGER} AND version = #{version, jdbcType = INTEGER}")
int updateByOptimisticLock(StockDto stockDto);
# 3. 开始测试
使用JMeter测试上面的代码,JMeter的使用可以查看: JMeter的安装使用 (opens new window)
我们调用一下商品库存初始化的方法,我使用的是PostMan,初始化库存表商品10个库存,而且清空订单表
这时候可以看到我们的数据,库存为10,卖出为0,订单表为空
打开JMeter,添加测试计划(测试计划文件在项目的src\main\resources\jmx下
),模拟500个并发线程测试秒杀10个库存的商品,填写请求地址,点击启动图标开始
可以看到500个并发线程执行完,最后商品实际显示为卖出10,库存还有0,而订单表也只有10条数据
其他的线程应该都是扣减库存失败了,我们可以查看下后台
这样就解决卖超问题,多个线程同时在检查库存的时候都会拿到当前商品的相同乐观锁版本号,然后在扣库存时,如果版本号不对,就会扣减失败,抛出异常结束,这样每个版本号就只能有第一个线程扣库存操作成功,其他相同版本号的线程秒杀失败,就不会存在卖超问题了
不过现在每次读取库存都去查数据库,我们可以看下Druid的监控,地址: http://localhost:8080/druid/sql.html (opens new window)
可以看到,查询库存执行了500次,遵从最后落地到数据库的请求数要尽量少的原则,其实我们可以把这个数据放缓存,提升性能