4.测试秒杀接口耗时4.1

这篇是测试使用RabbitMQ消息异步处理订单以及不异步处理订单的耗时对比

4.测试秒杀接口耗时

需要修改VoucherOrderController中的秒杀代码在秒杀操作前后计算接口耗时

4.1

seckillVoucher(PathVariable(id)

Long

voucherOrderService.seckillVoucher(voucherId);

}改为

PostMapping(seckill/{id})public

Result

seckillVoucher(PathVariable(id)

Long

System.currentTimeMillis();Result

result

voucherOrderService.seckillVoucher(voucherId);long

endTime

System.currentTimeMillis();long

duration

startTime;log.info(秒杀接口耗时{}ms,duration);

return

voucherOrderService.seckillVoucher(voucherId);return

命令行输出结构为3ms

修改VoucherOrderServiceImpl.java代码如下

主要注释掉如下三个方法

handleVoucherOrderseckillVouchercreateVoucherOrder

TODO

handleVoucherOrder(VoucherOrder

voucherOrder)

redissonClient.getLock(lock:order:userId);

//尝试获取锁

proxy.createVoucherOrder(voucherOrder);

}finally

(redisLock.isHeldByCurrentThread())

redisLock.unlock();

seckillVoucherService.update().setSql(stockstock-1)

.eq(voucher_id,

Result.fail(result1?库存不足:不能重复下单);

VoucherOrder

voucherOrder.setUserId(UserHolder.getUser().getId());

voucherOrder.setVoucherId(voucherId);

//存入消息队列等待异步消费

rabbitTemplate.convertAndSend(hmdianping.direct,direct.seckill,voucherOrder);

return

createVoucherOrder(VoucherOrder

voucherOrder){

seckillVoucherService.getById(voucherId);//

(voucher.getBeginTime().isAfter(LocalDateTime.now()))

{//

(voucher.getEndTime().isBefore(LocalDateTime.now()))

{//

UserHolder.getUser().getId();int

count

Result.fail(用户已经购买过一次);}//6扣减库存boolean

success

seckillVoucherService.update().setSql(stock

stock

Result.fail(库存不足);}//7.创建订单VoucherOrder

voucherOrder

redisIdWorker.nextId(order);voucherOrder.setId(orderId);voucherOrder.setUserId(userId);//

7.3.代金券idvoucherOrder.setVoucherId(voucherId);save(voucherOrder);return

Result.ok(orderId);}Overridepublic

void

createVoucherOrder(VoucherOrder

voucherOrder)

handleVoucherOrder(VoucherOrder

voucherOrder)