如何通过SpringBoot实现商城秒杀系统
这篇文章主要介绍了如何通过SpringBoot实现商城秒杀系统,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
学习自:地址
1.主要流程
1.1数据库:
window下:Zookeeper,Redis,rabbitmq-server。jdk1.8以上。
1.3介绍
这里只做秒杀部分功能,其他功能不会涉及。项目运行后可访问秒杀商品页面
用户登陆后可以查看商品的详情并进行抢购。
注意,用户对于一件商品只能抢购一次,进行第二次抢购时会被拒绝。当用户抢购成功时会异步发送一封邮件给用户。
主要逻辑就是以上。接下来看代码
1.4项目结构,api封装一些枚举和返回值,model主要是实体类和sql映射文件,service实现业务逻辑代码。
要细述的话,东西太多,如果想深入了解,可点击上面的链接。
基本的秒杀逻辑如下,判断用户是否已经抢购过该商品,如果没有则查询待秒杀商品详情,判断该商品是否可以别秒杀,判断依据为库存是否足够
如果符合条件,则该商品库存减1,接着,再一次判断扣减是否成功,如果扣减成功则生成秒杀成功的订单,同时通知用户秒杀成功的信息。
publicBooleankillItem(IntegerkillId,IntegeruserId)throwsException{ Booleanresult=false; //TODO:判断当前用户是否已经抢购过当前商品 if(itemKillSuccessMapper.countByKillUserId(killId,userId)<=0){ //TODO:查询待秒杀商品详情 ItemKillitemKill=itemKillMapper.selectById(killId); //TODO:判断是否可以被秒杀canKill=1? if(itemKill!=null&&1==itemKill.getCanKill()){ //TODO:扣减库存-减一 intres=itemKillMapper.updateKillItem(killId); //TODO:扣减是否成功?是-生成秒杀成功的订单,同时通知用户秒杀成功的消息 if(res>0){ commonRecordKillSuccessInfo(itemKill,userId); result=true; } } }else{ thrownewException("您已经抢购过该商品了!"); } returnresult; }
代码优化1:使用redis的分布式锁,使用当前秒杀商品的id和当前用户的id组成一个key,使用StringBuffer拼接,使用雪花算法生成一个value,存进redis中。
@Autowired privateStringRedisTemplatestringRedisTemplate; /** *商品秒杀核心业务逻辑的处理-redis的分布式锁 *@paramkillId *@paramuserId *@return *@throwsException */ @Override publicBooleankillItemV3(IntegerkillId,IntegeruserId)throwsException{ Booleanresult=false; if(itemKillSuccessMapper.countByKillUserId(killId,userId)<=0){ //TODO:借助Redis的原子操作实现分布式锁-对共享操作-资源进行控制 ValueOperationsvalueOperations=stringRedisTemplate.opsForValue(); finalStringkey=newStringBuffer().append(killId).append(userId).append("-RedisLock").toString(); finalStringvalue=RandomUtil.generateOrderCode(); BooleancacheRes=valueOperations.setIfAbsent(key,value);//luna脚本提供“分布式锁服务”,就可以写在一起 //TOOD:redis部署节点宕机了 if(cacheRes){ stringRedisTemplate.expire(key,30,TimeUnit.SECONDS); try{ ItemKillitemKill=itemKillMapper.selectByIdV2(killId); if(itemKill!=null&&1==itemKill.getCanKill()&&itemKill.getTotal()>0){ intres=itemKillMapper.updateKillItemV2(killId); if(res>0){ commonRecordKillSuccessInfo(itemKill,userId); result=true; } } }catch(Exceptione){ thrownewException("还没到抢购日期、已过了抢购时间或已被抢购完毕!"); }finally{ if(value.equals(valueOperations.get(key).toString())){ stringRedisTemplate.delete(key); } } } }else{ thrownewException("Redis-您已经抢购过该商品了!"); } returnresult; }
代码优化2:将BooleancacheRes=lock.tryLock(30,10,TimeUnit.SECONDS);每隔30秒判断当前用户是否超时写在了锁外面,不会因为一次卡顿而影响整个程序。
@Autowired privateRedissonClientredissonClient; /** *商品秒杀核心业务逻辑的处理-redisson的分布式锁 *@paramkillId *@paramuserId *@return *@throwsException */ @Override publicBooleankillItemV4(IntegerkillId,IntegeruserId)throwsException{ Booleanresult=false; finalStringlockKey=newStringBuffer().append(killId).append(userId).append("-RedissonLock").toString(); RLocklock=redissonClient.getLock(lockKey); try{ BooleancacheRes=lock.tryLock(30,10,TimeUnit.SECONDS); if(cacheRes){ //TODO:核心业务逻辑的处理 if(itemKillSuccessMapper.countByKillUserId(killId,userId)<=0){ ItemKillitemKill=itemKillMapper.selectByIdV2(killId); if(itemKill!=null&&1==itemKill.getCanKill()&&itemKill.getTotal()>0){ intres=itemKillMapper.updateKillItemV2(killId); if(res>0){ commonRecordKillSuccessInfo(itemKill,userId); result=true; } } }else{ thrownewException("redisson-您已经抢购过该商品了!"); } } }finally{ lock.unlock(); //lock.forceUnlock(); } returnresult; }
代码优化3:
@Autowired privateCuratorFrameworkcuratorFramework; privatestaticfinalStringpathPrefix="/kill/zkLock/"; /** *商品秒杀核心业务逻辑的处理-基于ZooKeeper的分布式锁 *@paramkillId *@paramuserId *@return *@throwsException */ @Override publicBooleankillItemV5(IntegerkillId,IntegeruserId)throwsException{ Booleanresult=false; InterProcessMutexmutex=newInterProcessMutex(curatorFramework,pathPrefix+killId+userId+"-lock"); try{ if(mutex.acquire(10L,TimeUnit.SECONDS)){ //TODO:核心业务逻辑 if(itemKillSuccessMapper.countByKillUserId(killId,userId)<=0){ ItemKillitemKill=itemKillMapper.selectByIdV2(killId); if(itemKill!=null&&1==itemKill.getCanKill()&&itemKill.getTotal()>0){ intres=itemKillMapper.updateKillItemV2(killId); if(res>0){ commonRecordKillSuccessInfo(itemKill,userId); result=true; } } }else{ thrownewException("zookeeper-您已经抢购过该商品了!"); } } }catch(Exceptione){ thrownewException("还没到抢购日期、已过了抢购时间或已被抢购完毕!"); }finally{ if(mutex!=null){ mutex.release(); } } returnresult; }
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持毛票票。
声明:本文内容来源于网络,版权归原作者所有,内容由互联网用户自发贡献自行上传,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任。如果您发现有涉嫌版权的内容,欢迎发送邮件至:czq8825#qq.com(发邮件时,请将#更换为@)进行举报,并提供相关证据,一经查实,本站将立刻删除涉嫌侵权内容。