[Java] Java基于redis和mysql实现简单的秒杀(附demo)

• 商家提交秒杀商品申请，录入秒杀商品数据，主要有：商品标题，商品原价，秒杀价格，商品图片，介绍等信息
  
• 运营商审核秒杀申请
  
• 秒杀频道首页列出秒杀商品，点击秒杀商品图片可以跳转到秒杀商品详细页面
  
• 商品详细页面显示秒杀商品信息，点击立即抢购实现秒杀下单，下单时扣减库存，当库存为０或者不存在活动时间范围内时无法秒杀
  
• 秒杀下单成功，直接跳转到支付页面(扫码),支付成功，跳转到成功页面，填写收货、电话、收件人等信息，完成订单。
  
• 当用户秒杀下单５分钟内未支付，取消预订单，调用支付的关闭订单接口，恢复库存。
  

@Override
@Transactional(rollbackFor = Exception.class)
public GoodsEntity initGoods(String name, Integer amount, BigDecimal price) {
GoodsEntity goodsEntity = new GoodsEntity().setName(name).setAmount(amount).setPrice(price).setStartDate(new Date()).setEndDate(new Date());
Assert.isTrue(goodsService.save(goodsEntity), "抢购商品初始化发生异常～");
// 缓存库存
redisTemplate.opsForValue().increment("amount:" + goodsEntity.getId(), amount);
// 缓存商品信息
redisTemplate.opsForValue().set("goods:" + goodsEntity.getId(), goodsEntity);
return goodsEntity;
}

@Override
@Transactional(rollbackFor = Exception.class)
public Boolean secKill(String key) {
Long result = redisTemplate.opsForValue().decrement("amount:" + key, 1);
if (result.compareTo(0L) >= 0) {
// 下面的数据库操作建议走MQ让数据库按照他的处理能力，从消息队列中拿取消息进行处理。
Try.of(() -> {
Assert.isTrue(goodsService.secKill(Long.valueOf(key)), "库存不足！");
OrderEntity orderEntity = new OrderEntity().setGoodsId(Long.valueOf(key)).setOrderNo(UUID.randomUUID().toString().replace("-", ""));
Assert.isTrue(orderService.save(orderEntity), "订单创建发生异常～");
redisTemplate.opsForValue().set("secKill:" + orderEntity.getId(), orderEntity.getOrderNo(), 10, TimeUnit.SECONDS);
return true;
}).onFailure((e) -> {
log.error("持久化异常：" + e.getMessage());
redisTemplate.opsForValue().increment("amount:" + key, 1);
});
return false;
}
redisTemplate.opsForValue().increment("amount:" + key, 1);
return false;
}