spring boot高并发秒杀测试.zip

#### redis高并发秒杀测试 > 测试项目： https://github.com/14251104246/redis-demo.git #### 准备 - 使用`docker-compose`命令启动redis服务器（可以用其他方式启动） - idea启动测试项目 - jmeter测试脚本 - [高并发秒杀-重现超卖问题.jmx](https://github.com/14251104246/redis-demo/blob/master/src/test/jmeter/%E9%AB%98%E5%B9%B6%E5%8F%91%E7%A7%92%E6%9D%80-%E9%87%8D%E7%8E%B0%E8%B6%85%E5%8D%96%E9%97%AE%E9%A2%98.jmx) - [高并发秒杀-有事务方式减少库存.jmx](https://github.com/14251104246/redis-demo/blob/master/src/test/jmeter/%E9%AB%98%E5%B9%B6%E5%8F%91%E7%A7%92%E6%9D%80-%E6%9C%89%E4%BA%8B%E5%8A%A1%E6%96%B9%E5%BC%8F%E5%87%8F%E5%B0%91%E5%BA%93%E5%AD%98.jmx) #### 重现秒杀时出现的超卖问题 - 核心测试代码如下： ```java /** * 用于测试redis秒杀 */ @RestController @RequestMapping("/api/spike") @Slf4j public class SpikeController { @Resource(name = "stringRedisTemplate") private StringRedisTemplate stringRedisTemplate; @Autowired private RedissonClient redissonClient; //记录实际卖出的商品数量 private AtomicInteger successNum = new AtomicInteger(0); @RequestMapping(value = "/initSku", method = RequestMethod.GET) public String initSku() { //初始化库存数量 stringRedisTemplate.opsForValue().set("product_sku", "5"); //初始化实际卖出的商品数量0 successNum.set(0); return "初始化库存成功"; } /** * 会出现超卖情况的减少库存方式 * @return */ @RequestMapping(value = "/reduceSku", method = RequestMethod.GET) public String reduceSku() { Integer sku = Integer.parseInt(stringRedisTemplate.opsForValue().get("product_sku")); sku = sku - 1; if (sku < 0) { return "库存不足"; } stringRedisTemplate.opsForValue().set("product_sku", sku.toString()); //记录实际卖出的商品数量 return "减少库存成功,共减少" + successNum.incrementAndGet(); } @RequestMapping(value = "/successNum", method = RequestMethod.GET) public String successNum() { return "顾客成功抢到的商品数量：" + successNum.get(); } } ``` - 测试api： ``` API{初始化库存数量} >> http://127.0.0.1:8090/api/spike/initSku API{减少库存数量} >> http://127.0.0.1:8090/api/spike/reduceSku API{查看共减少库存数量} >> http://127.0.0.1:8090/api/spike/successNum ``` - 第一个api用于：初始化库存中的商品数量为5 - 第二个api用于：减少库存1个商品（即客户购买一个商品） - 第三个api用于：查看用户实际购买的商品 - 少量用户请求的情况展示： - 首先初始商品库存：http://127.0.0.1:8090/api/spike/initSku > - redis数据库中商品库存记录，结果为5 > - 查看用户实际购买的商品，结果为0 > - 客户购买5次商品（调用5次`减少库存数量`api）,下面只列出3个图 > > > - 客户继续购买（继续调用`减少库存数量`api）时，会提示库存不足 - 再次查看redis数据库中商品库存记录，结果为0 >  - 再次查看用户实际购买的商品，结果为5 >  - 大量用户请求的情况（高并发秒杀）展示 - 首先初始商品库存：http://127.0.0.1:8090/api/spike/initSku > - redis数据库中商品库存记录，结果为5 > - 查看用户实际购买的商品，结果为0 > - 使用jmeter打开测试脚本，可以看到基本配置如下 >  - jmeter并发配置如下（当用户数达到 1000 的时候才开始测试） >  - 点击jmeter的`start`按钮，开始1000个并发请求 - 再次查看redis数据库中商品库存记录，结果为0 >  - **注意：再次查看用户实际购买的商品，结果超过5，出现超卖情况！！！** >  #### 超卖问题原因分析 - 从上面测试结果，我们知道，高并发请求`http://127.0.0.1:8090/api/spike/reduceSku`，会出现超卖的情况 - 下面我们看下超卖问题的原因 ``` /** * 会出现超卖情况的减少库存方式 * @return */ @RequestMapping(value = "/reduceSku", method = RequestMethod.GET) public String reduceSku() { Integer sku = Integer.parseInt(stringRedisTemplate.opsForValue().get("product_sku")); sku = sku - 1; if (sku < 0) { return "库存不足"; } stringRedisTemplate.opsForValue().set("product_sku", sku.toString()); //记录实际卖出的商品数量 return "减少库存成功,共减少" + successNum.incrementAndGet(); } ``` - 从代码片可以看出，问题原因是库存数量`sku`的读和写操作不在同一个原子操作上，导致类似`不可重复读`的现象。可以类比多线程的问题。 #### 通过redis事务解决超卖问题 ##### 使用redis原生的sdk - 如下改造`reduceSku()`方法，作为一个新接口`http://127.0.0.1:8090/api/spike/reduceSku3` ``` /** * 加入事务的减少库存方式 * @return */ @RequestMapping(value = "/reduceSku3", method = RequestMethod.GET) public String reduceSku3() { Jedis jedis = new Jedis("127.0.0.1", 6379); List<Object> result ; Transaction transaction = null; try { jedis.watch("product_sku"); int sku = Integer.parseInt(jedis.get("product_sku")); if (sku > 0) { transaction = jedis.multi(); transaction.set("product_sku", String.valueOf(sku - 1)); // int exp = 1/0; result = transaction.exec(); if (result == null || result.isEmpty()) {