:racehorse:基于SpringBoot + MySQL + Redis + RabbitMQ + Guava开发的高并发商品限时秒杀系统

两个问题 1、更新库存时没有送version number，所以更新库存失败 2、秒杀成功以后，返回的int 永远是1，作为订单号返回，是查不到订单的

GoodsVo 增加 int version 和getter setter

GoodsMapper getGoodsVoByGoodsId 增加返回 sg.version

GoodsService reduceStock()方法增加 sg.setVersion(goods.getVersion());

OrderService createOrder()方法 订单号要从实体类中取，否则update返回的永远是1 long orderId = orderInfo.getId();

redis pass 没有通过配置读取到实例化中，导致redis 设置了pass就会报错。 JedisPool jp = new JedisPool(config, redisConfig.getHost(), redisConfig.getPort(), redisConfig.getTimeout()*1000, redisConfig.getPassword(), 0); git中没有加redisConifg.getPassword() 在RedisPoolFactory.java中

点击立即秒杀 后台/do_seckill 方法中 user对象内的属性值都为null，当执行到//判断重复秒杀 SeckillOrder order = orderService.getOrderByUserIdGoodsId(user.getId(), goodsId);报空指针异常，请问为什么呢？

/** * 减少库存，每次减一 * * @return */ public boolean reduceStock(GoodsVo goods) { int numAttempts = 0; int ret = 0; SeckillGoods sg = new SeckillGoods(); sg.setGoodsId(goods.getId()); sg.setVersion(goods.getVersion()); do { numAttempts++; try { //TODO 如果version失效了，更新失败 再次执行时没有取出表中最新的version，所以不管循环几次，更新也是失败的？？？？ ret = goodsMapper.reduceStockByVersion(sg); } catch (Exception e) { e.printStackTrace(); } if (ret != 0) break; } while (numAttempts < DEFAULT_MAX_RETRIES);

    return ret > 0;
}

do { numAttempts++; try { ret = goodsMapper.reduceStockByVersion(sg); } catch (Exception e) { e.printStackTrace(); } if (ret != 0) break; } while (numAttempts < DEFAULT_MAX_RETRIES);

java.lang.IllegalStateException: ApplicationEventMulticaster not initialized - call 'refresh' before multicasting events via the context: org.springframework.boot.context.embedded.AnnotationConfigEmbeddedWebApplicationContext@117159c0: startup date [Wed Mar 23 20:50:25 CST 2022]; root of context hierarchy

秒杀下单时的一段代码： //预减库存 long stock = redisService.decr(GoodsKey.getGoodsStock, "" + goodsId);//10 if (stock < 0) { afterPropertiesSet(); long stock2 = redisService.decr(GoodsKey.getGoodsStock, "" + goodsId);//10 if(stock2 < 0){ localOverMap.put(goodsId, true); return Result.error(CodeMsg.SECKILL_OVER); } }

下面这个是afterPropertiesSet方法定义，每次调用都要获取所有商品并且遍历商品，这样会消耗性能吧，而且，我只是下单某一件商品，为什么在遍历中将每件商品标记为false?原本某些标记为true的商品变为false了 public void afterPropertiesSet() { List<GoodsVo> goodsVoList = goodsService.listGoodsVo(); if (goodsVoList == null) { return; } for (GoodsVo goods : goodsVoList) { redisService.set(GoodsKey.getGoodsStock, "" + goods.getId(), goods.getStockCount()); //初始化商品都是没有处理过的 localOverMap.put(goods.getId(), false); } }

long stock = redisService.decr(GoodsKey.getGoodsStock, "" + goodsId);//10
        if (stock < 0) {
            afterPropertiesSet();
            long stock2 = redisService.decr(GoodsKey.getGoodsStock, "" + goodsId);//10
            if(stock2 < 0){
                localOverMap.put(goodsId, true);
                return Result.error(CodeMsg.SECKILL_OVER);
            }
        }
        //判断重复秒杀
        //如果重复秒杀,是否多次减库存?
        SeckillOrder order = orderService.getOrderByUserIdGoodsId(user.getId(), goodsId);
        if (order != null) {
            return Result.error(CodeMsg.REPEATE_SECKILL);
        }

预减库存后,如果是重复秒杀,redis中的库存量还是会减少,导致其他用户不能下单