现象

做一人一单的时候，为了提升性能，需要将原来的业务改造成Lua脚本加Stream流的方式实现异步秒杀。

代码改造完成，使用Jmeter进行并发测试，发现redis中的数据和预期相同，库存减1，该用户也成功添加了进去，但是打开数据库的订单表，发现这条数据没有添加进去。

排查

开始以为是consumer没有收到消息，检查了一遍队列名称，consumerGroup，consumer名称都是没问题的。

然后在子线程中打了断点，然后再次启动，发现报出了一个空指针异常，定位到了是创建对象createVoucherOrder2当中Long userId = UserHolder.getUser().getId()中user居然是空，token也没失效。

emmm,最后发现是createVoucherOrder2是在子线程中调用的，已经切换线程了，自然不能再从ThreadLocal里获取对象了。

队列中存在的订单对象中包含了userId，所以正确的做法应该是从订单对象里面取。

真的是一个很容易忽略的错误。

贴相关代码

        private void createVoucherOrder2(VoucherOrder voucherOrder) {//添加逻辑：该用户是否已经已经下过单了//防止黄牛恶意刷单 但是会存在和超卖相同的问题 同一个用户但是超卖了三张票Long userId = voucherOrder.getUserId();RLock lock = redissonClient.getLock("lock:order:" + userId);boolean tryLock = lock.tryLock();if (!tryLock) {log.error("不允许重复下单");return;}try {Long voucherId = voucherOrder.getVoucherId();//3.查询订单Integer count = query().eq("user_id", userId).eq("voucher_id", voucherId).count();//4.校验一人一单if (count > 0) {log.error("无法重复下单");return;}//5.库存扣减 超减问题并发量3000的情况下 超卖10张boolean success = seckillVoucherService.update().setSql("stock= stock -1").eq("voucher_id", voucherId).gt("stock", 0).update();if (!success) {log.error("库存不足，下单失败");return;}//6.添加订单voucherOrderService.save(voucherOrder);}catch (Exception e){log.error("下单失败{}",e.getMessage());}finally {lock.unlock();}}

emmm

再次启动，Mysql订单表成功添加一条数据。

Jmeter汇总报告