基于SpringBoot+Mybatis+Mysql+中间件构建的商城秒杀系统

package com.debug.kill.server.service.impl;/** * Created by Administrator on 2019/6/17. */ import com.debug.kill.model.dto.KillSuccessUserInfo; import com.debug.kill.model.entity.*; import com.debug.kill.model.mapper.*; import com.debug.kill.server.enums.SysConstant; import com.debug.kill.server.service.IKillService; import com.debug.kill.server.service.RabbitSenderService; import com.debug.kill.server.utils.RandomUtil; import com.debug.kill.server.utils.SnowFlake; import com.google.common.collect.Maps; import org.apache.curator.framework.CuratorFramework; import org.apache.curator.framework.recipes.locks.InterProcessMutex; import org.joda.time.DateTime; import org.redisson.api.RLock; import org.redisson.api.RedissonClient; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.core.env.Environment; import org.springframework.data.redis.core.StringRedisTemplate; import org.springframework.data.redis.core.ValueOperations; import org.springframework.stereotype.Service; import java.util.Map; import java.util.concurrent.TimeUnit; /** * @Author:debug (SteadyJack) * @Date: 2019/6/17 22:21 **/ @Service public class KillService implements IKillService { private static final Logger log= LoggerFactory.getLogger(KillService.class); private SnowFlake snowFlake=new SnowFlake(2,3); @Autowired private ItemKillSuccessMapper itemKillSuccessMapper; @Autowired private ItemKillMapper itemKillMapper; @Autowired private RabbitSenderService rabbitSenderService; @Autowired private Environment env; @Autowired private NewBeeMallOrderMapper mallOrderMapper; @Autowired private NewBeeMallOrderItemMapper orderItemMapper; @Autowired private UserMapper userMapper; /** * 商品秒杀核心业务逻辑的处理 * @param killId * @param userId * @return * @throws Exception */ @Override public Boolean killItem(Integer killId, Integer userId) throws Exception { Boolean result=false; //TODO:判断当前用户是否已经抢购了当前商品 if (itemKillSuccessMapper.countByKillUserId(killId,userId) <= 0){ //TODO:判断当前代抢购的商品库存是否充足、以及是否出在可抢的时间段内 - canKill ItemKill itemKill=itemKillMapper.selectById(killId); if (itemKill!=null && 1==itemKill.getCanKill()){ //TODO:扣减库存-减1 int res=itemKillMapper.updateKillItem(killId); if (res>0){ //TODO:判断是否扣减成功了?是-生成秒杀成功的订单、同时通知用户秒杀已经成功（在一个通用的方法里面实现） this.commonRecordKillSuccessInfo(itemKill,userId); result=true; } } }else{ throw new Exception("您已经抢购过该商品了！"); } return result; } /** * 通用的方法-记录用户秒杀成功后生成的订单-并进行异步邮件消息的通知 * @param kill * @param userId * @throws Exception */ private void commonRecordKillSuccessInfo(ItemKill kill, Integer userId) throws Exception{ //TODO:记录抢购成功后生成的秒杀订单记录 ItemKillSuccess entity=new ItemKillSuccess(); String orderNo=String.valueOf(snowFlake.nextId()); //entity.setCode(RandomUtil.generateOrderCode()); //传统时间戳+N位随机数 entity.setCode(orderNo); //雪花算法 entity.setItemId(kill.getItemId()); entity.setKillId(kill.getId()); entity.setUserId(userId.toString()); entity.setStatus(SysConstant.OrderStatus.SuccessNotPayed.getCode().byteValue()); entity.setCreateTime(DateTime.now().toDate()); //TODO:学以致用，举一反三 -> 仿照单例模式的双重检验锁写法 if (itemKillSuccessMapper.countByKillUserId(kill.getId(),userId) <= 0){ int res=itemKillSuccessMapper.insertSelective(entity); if (res>0){ //TODO:进行异步邮件消息的通知=rabbitmq+mail rabbitSenderService.sendKillSuccessEmailMsg(orderNo); //TODO:入死信队列，用于 “失效” 超过指定的TTL时间时仍然未支付的订单 rabbitSenderService.sendKillSuccessOrderExpireMsg(orderNo); //插入后台管理专属的订单表 try { NewBeeMallOrder order = new NewBeeMallOrder(); order.setOrderNo(orderNo); order.setUserId(Long.valueOf(userId)); User user=userMapper.selectByPrimaryKey(userId); if (user!=null){ order.setUserAddress("用户名："+user.getUserName()+" -- 用户邮箱："+user.getEmail()); } //总价 order.setTotalPrice(kill.getPrice()); if (mallOrderMapper.insertSelective(order) > 0) { NewBeeMallOrderItem item=new NewBeeMallOrderItem(); item.setOrderId(order.getOrderId()); item.setGoodsId(Long.valueOf(kill.getItemId())); item.setGoodsName(kill.getItemName()); item.setSellingPrice(kill.getPrice()); item.setGoodsCount(1); item.setCreateTime(DateTime.now().toDate()); orderItemMapper.insertSelective(item); } }catch (Exception e){ log.error("插入后台管理专属的订单表-发生异常：",e); } } } } /** * 商品秒杀核心业务逻辑的处理-mysql的优化 * @param killId * @param userId * @return * @throws Exception */ @Override public Boolean killItemV2(Integer killId, Integer userId) throws Exception { Boolean result=false; //TODO:判断当前用户是否已经抢购过当前商品 if (itemKillSuccessMapper.countByKillUserId(killId,userId) <= 0){ //TODO:A.查询待秒杀商品详情 ItemKill itemKill=itemKillMapper.selectByIdV2(killId); //TODO:判断是否可以被秒杀canKill=1? if (itemKill!=null && 1==itemKill.getCanKill() && itemKill.getTotal()>0){ //TODO:B.扣减库存-减一 int res=itemKillMapper.updateKillItemV2(killId); //TODO:扣减是否成功?是-生成秒杀成功的订单，同时通知用户秒杀成功的消息 if (res>0){ commonRecordKillSuccessInfo(itemKill,userId); result=true; } } }else{ throw new Exception("您已经抢购过该商品了!"); } return result; } @Autowired private StringRedisTemplate stringRedisTemplate; /** * 商品秒杀核心业务逻辑的处理-redis的分布式锁 * @param killId * @param userId * @return * @throws Exception */ @Override public Boolean killItemV3(Integer killId, Integer userId) throws Exception { Boolean result=false; if (itemKillSuccessMapper.countByKillUserId(killId,userId) <= 0){ //TODO:借助Redis的原子操作实现分布式锁-对共享操作-资源进行控制 ValueOperations valueOperations=stringRedisTemplate.opsForValue(); final String key=new StringBuffer().append(killId).append(userId).append("-RedisLock").toString(); final String value=RandomUtil.generateOrderCode(); Boolean cacheRes=valueOperations.setIfAbsent(key,value); //lua脚本提供“分布式锁服务”，就