加入收藏 | 设为首页 | 会员中心 | 我要投稿 南平站长网 (https://www.0599zz.com/)- 科技、建站、经验、云计算、5G、大数据,站长网!
当前位置: 首页 > 综合聚焦 > 移动互联 > 评测 > 正文

Java秒杀系统:商品秒杀代码实战

发布时间:2019-07-23 17:08:02 所属栏目:评测 来源:IT技术分享
导读:副标题#e# 内容: 商品秒杀功能模块是建立在商品详情功能模块的基础之上,对于这一功能模块而言,其主要的核心流程在于:前端发起抢购请求,该请求将携带着一些请求数据:待秒杀Id跟当前用户Id等数据;后端接口在接收到请求之后,将执行一系列的判断与秒杀
副标题[/!--empirenews.page--]

内容:

“商品秒杀”功能模块是建立在“商品详情”功能模块的基础之上,对于这一功能模块而言,其主要的核心流程在于:前端发起抢购请求,该请求将携带着一些请求数据:待秒杀Id跟当前用户Id等数据;后端接口在接收到请求之后,将执行一系列的判断与秒杀处理逻辑,最终将处理结果返回给到前端。

Java秒杀系统:商品秒杀代码实战

其中,后端接口的这一系列判断与秒杀处理逻辑还是挺复杂的,Debug将其绘制成了如下的流程图:

Java秒杀系统实战系列:商品秒杀代码实战

从该业务流程图中可以看出,后端接口在接收前端用户的秒杀请求时,其核心处理逻辑为:

(1)首先判断当前用户是否已经抢购过该商品了,如果否,则代表用户没有抢购过该商品,可以进入下一步的处理逻辑

(2)判断该商品可抢的剩余数量,即库存是否充足(即是否大于0),如果是,则进入下一步的处理逻辑

(3)扣减库存,并更新数据库的中对应抢购记录的库存(一般是减一操作),判断更新库存的数据库操作是否成功了,如果是,则创建用户秒杀成功的订单,并异步发送短信或者邮件通知信息通知用户

(4)以上的操作逻辑如果有任何一步是不满足条件的,则直接结束整个秒杀的流程,即秒杀失败!

接下来,我们仍然基于MVC的开发模式,采用代码实战实现这一功能模块!

(1)首先是在KillController 控制器开发接收“前端用户秒杀请求”的功能方法,其中,该方法需要接收前端请求过来的“待秒杀Id”,而当前用户的Id可以通过上一篇博文介绍的Shiro 的会话模块Session进行获取!

其源代码如下所示:

  1. private static final String prefix = "kill"; 
  2.   
  3. @Autowired 
  4. private IKillService killService; 
  5.   
  6. @Autowired 
  7. private ItemKillSuccessMapper itemKillSuccessMapper; 
  8.   
  9. /*** 
  10.  * 商品秒杀核心业务逻辑 
  11.  */ 
  12. @RequestMapping(value = prefix+"/execute",method = RequestMethod.POST,consumes = MediaType.APPLICATION_JSON_UTF8_VALUE) 
  13. @ResponseBody 
  14. public BaseResponse execute(@RequestBody @Validated KillDto dto, BindingResult result, HttpSession session){ 
  15.  if (result.hasErrors() || dto.getKillId()<=0){ 
  16.  return new BaseResponse(StatusCode.InvalidParams); 
  17. //获取当前登录用户的信息 
  18.  Object uId=session.getAttribute("uid"); 
  19.  if (uId==null){ 
  20.  return new BaseResponse(StatusCode.UserNotLogin); 
  21.  } 
  22.  Integer userId= (Integer)uId ; 
  23.  BaseResponse response=new BaseResponse(StatusCode.Success); 
  24.  try { 
  25.  Boolean res=killService.killItem(dto.getKillId(),userId); 
  26.  if (!res){ 
  27.  return new BaseResponse(StatusCode.Fail.getCode(),"哈哈~商品已抢购完毕或者不在抢购时间段哦!"); 
  28.  } 
  29.  }catch (Exception e){ 
  30.  response=new BaseResponse(StatusCode.Fail.getCode(),e.getMessage()); 
  31.  } 
  32.  return response; 
  33. }复制代码 

其中,KillDto对象主要封装了“待秒杀Id”等字段信息,其主要用于接收前端过来的用户秒杀请求信息,源代码如下所示:

  1. @Data 
  2. @ToString 
  3. public class KillDto implements Serializable{ 
  4.  @NotNull 
  5.  private Integer killId; 
  6.   
  7.  private Integer userId; //在整合shiro之后,userId字段可以不需要了!因为通过session进行获取了 
  8. }复制代码 

(2)紧接着是开发 killService.killItem(dto.getKillId(),userId) 的功能,该功能对应的代码的编写逻辑可以参见本文刚开始介绍时的流程图!其完整源代码如下所示:

  1. @Autowired 
  2. private ItemKillSuccessMapper itemKillSuccessMapper; 
  3.   
  4. @Autowired 
  5. private ItemKillMapper itemKillMapper; 
  6.   
  7. @Autowired 
  8. private RabbitSenderService rabbitSenderService; 
  9.   
  10. //商品秒杀核心业务逻辑的处理 
  11. @Override 
  12. public Boolean killItem(Integer killId, Integer userId) throws Exception { 
  13.  Boolean result=false; 
  14.   
  15.  //TODO:判断当前用户是否已经抢购过当前商品 
  16.  if (itemKillSuccessMapper.countByKillUserId(killId,userId) <= 0){ 
  17.  //TODO:查询待秒杀商品详情 
  18.  ItemKill itemKill=itemKillMapper.selectById(killId); 
  19.   
  20.  //TODO:判断是否可以被秒杀canKill=1? 
  21.  if (itemKill!=null && 1==itemKill.getCanKill() ){ 
  22.  //TODO:扣减库存-减一 
  23.  int res=itemKillMapper.updateKillItem(killId); 
  24.   
  25.  //TODO:扣减是否成功?是-生成秒杀成功的订单,同时通知用户秒杀成功的消息 
  26.  if (res>0){ 
  27.  commonRecordKillSuccessInfo(itemKill,userId); 
  28.   
  29.  result=true; 
  30.  } 
  31.  } 
  32.  }else{ 
  33.  throw new Exception("您已经抢购过该商品了!"); 
  34.  } 
  35.  return result; 
  36. }复制代码 

(编辑:南平站长网)

【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!

热点阅读