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

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

文章插图

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

文章插图

从该业务流程图中可以看出，后端接口在接收前端用户的秒杀请求时，其核心处理逻辑为：
（1）首先判断当前用户是否已经抢购过该商品了，如果否，则代表用户没有抢购过该商品，可以进入下一步的处理逻辑
（2）判断该商品可抢的剩余数量，即库存是否充足（即是否大于0），如果是，则进入下一步的处理逻辑
（3）扣减库存，并更新数据库的中对应抢购记录的库存（一般是减一操作），判断更新库存的数据库操作是否成功了，如果是，则创建用户秒杀成功的订单，并异步发送短信或者邮件通知信息通知用户
（4）以上的操作逻辑如果有任何一步是不满足条件的，则直接结束整个秒杀的流程，即秒杀失败！
接下来，我们仍然基于MVC的开发模式，采用代码实战实现这一功能模块！

文章插图
【Java秒杀系统实战系列：商品秒杀代码实战】
（1）首先是在KillController 控制器开发接收“前端用户秒杀请求”的功能方法，其中，该方法需要接收前端请求过来的“待秒杀Id”，而当前用户的Id可以通过上一篇博文介绍的Shiro 的会话模块Session进行获取！
其源代码如下所示：
private static final String prefix = "kill"; @Autowiredprivate IKillService killService; @Autowiredprivate ItemKillSuccessMApper itemKillSuccessMapper; /*** * 商品秒杀核心业务逻辑 */@RequestMapping(value = https://www.isolves.com/it/cxkf/yy/JAVA/2019-07-23/prefix+"/execute",method = RequestMethod.POST,consumes = MediaType.APPLICATION_JSON_UTF8_VALUE)@ResponseBodypublic BaseResponse execute(@RequestBody @Validated KillDto dto, BindingResult result, HttpSession session){ if (result.hasErrors() || dto.getKillId()<=0){ return new BaseResponse(StatusCode.InvalidParams);}//获取当前登录用户的信息 Object uId=session.getAttribute("uid"); if (uId==null){ return new BaseResponse(StatusCode.UserNotLogin); } Integer userId= (Integer)uId ; BaseResponse response=new BaseResponse(StatusCode.Success); try { Boolean res=killService.killItem(dto.getKillId(),userId); if (!res){ return new BaseResponse(StatusCode.Fail.getCode(),"哈哈~商品已抢购完毕或者不在抢购时间段哦!"); } }catch (Exception e){ response=new BaseResponse(StatusCode.Fail.getCode(),e.getMessage()); } return response;}复制代码其中，KillDto对象主要封装了“待秒杀Id”等字段信息，其主要用于接收前端过来的用户秒杀请求信息，源代码如下所示：
@Data@ToStringpublic class KillDto implements Serializable{ @NotNull private Integer killId;private Integer userId; //在整合shiro之后，userId字段可以不需要了！因为通过session进行获取了}复制代码（2）紧接着是开发 killService.killItem(dto.getKillId(),userId) 的功能，该功能对应的代码的编写逻辑可以参见本文刚开始介绍时的流程图！其完整源代码如下所示：
@Autowiredprivate ItemKillSuccessMapper itemKillSuccessMapper; @Autowiredprivate ItemKillMapper itemKillMapper; @Autowiredprivate RabbitSenderService rabbitSenderService; //商品秒杀核心业务逻辑的处理@Overridepublic Boolean killItem(Integer killId, Integer userId) throws Exception { Boolean result=false;//TODO:判断当前用户是否已经抢购过当前商品 if (itemKillSuccessMapper.countByKillUserId(killId,userId) <= 0){ //TODO:查询待秒杀商品详情 ItemKill itemKill=itemKillMapper.selectById(killId);//TODO:判断是否可以被秒杀canKill=1? if (itemKill!=null && 1==itemKill.getCanKill() ){ //TODO:扣减库存-减一 int res=itemKillMapper.updateKillItem(killId);//TODO:扣减是否成功?是-生成秒杀成功的订单，同时通知用户秒杀成功的消息 if (res>0){ commonRecordKillSuccessInfo(itemKill,userId);result=true; } } }else{ throw new Exception("您已经抢购过该商品了!"); } return result;}复制代码其中，itemKillMapper.selectById(killId); 表示用于获取待秒杀商品的详情信息，这在前面的篇章中已经介绍过了；而 itemKillMapper.updateKillItem(killId); 主要用于扣减库存（在这里是减1操作），其对应的动态Sql如下所示：