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

内容：

创新互联长期为千余家客户提供的网站建设服务，团队从业经验10年，关注不同地域、不同群体，并针对不同对象提供差异化的产品和服务；打造开放共赢平台，与合作伙伴共同营造健康的互联网生态环境。为丹徒企业提供专业的成都网站设计、成都网站建设，丹徒网站改版等技术服务。拥有十载丰富建站经验和众多成功案例,为您定制开发。

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

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

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

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

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

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

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

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

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

其源代码如下所示：

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

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

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

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

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

其中，itemKillMapper.selectById(killId); 表示用于获取待秒杀商品的详情信息，这在前面的篇章中已经介绍过了；而 itemKillMapper.updateKillItem(killId); 主要用于扣减库存（在这里是减1操作），其对应的动态Sql如下所示：

 
 
 
 
    
  
  
  
  
  1.  
    2. 
  
  
  
  
  2.   
    3. 
  
  
  
  
  3.  UPDATE item_kill 
    4. 
  
  
  
  
  4.  SET total = total - 1 
    5. 
  
  
  
  
  5.  WHERE 
    6. 
  
  
  
  
  6.  id = #{killId} 
    7. 
  
  
  
  
  7.  复制代码 
    8.

（3）值得一提的是，在上面 KillService执行killItem功能方法时，还开发了一个通用的方法：用户秒杀成功后创建秒杀订单、并异步发送通知消息给到用户秒杀成功的信息！该方法为 commonRecordKillSuccessInfo(itemKill,userId); 其完整的源代码如下所示：

 
 
 
 
    
  
  
  
  
  1. /** 
    2. 
  
  
  
  
  2.  * 通用的方法-用户秒杀成功后创建订单-并进行异步邮件消息的通知 
    3. 
  
  
  
  
  3.  * @param kill 
    4. 
  
  
  
  
  4.  * @param userId 
    5. 
  
  
  
  
  5.  * @throws Exception 
    6. 
  
  
  
  
  6.  */ 
    7. 
  
  
  
  
  7. private void commonRecordKillSuccessInfo(ItemKill kill, Integer userId) throws Exception{ 
    8. 
  
  
  
  
  8.  //TODO:记录抢购成功后生成的秒杀订单记录 
    9. 
  
  
  
  
  9.   
    10. 
  
  
  
  
  10.  ItemKillSuccess entity=new ItemKillSuccess(); 
    11. 
  
  
  
  
  11.  String orderNo=String.valueOf(snowFlake.nextId()); 
    12. 
  
  
  
  
  12.   
    13. 
  
  
  
  
  13.  //entity.setCode(RandomUtil.generateOrderCode()); //传统时间戳+N位随机数 
    14. 
  
  
  
  
  14.  entity.setCode(orderNo); //雪花算法 
    15. 
  
  
  
  
  15.  entity.setItemId(kill.getItemId()); 
    16. 
  
  
  
  
  16.  entity.setKillId(kill.getId()); 
    17. 
  
  
  
  
  17.  entity.setUserId(userId.toString()); 
    18. 
  
  
  
  
  18.  entity.setStatus(SysConstant.OrderStatus.SuccessNotPayed.getCode().byteValue()); 
    19. 
  
  
  
  
  19.  entity.setCreateTime(DateTime.now().toDate()); 
    20. 
  
  
  
  
  20.  //TODO:学以致用，举一反三 -> 仿照单例模式的双重检验锁写法 
    21. 
  
  
  
  
  21.  if (itemKillSuccessMapper.countByKillUserId(kill.getId(),userId) <= 0){ 
    22. 
  
  
  
  
  22.  int res=itemKillSuccessMapper.insertSelective(entity); 
    23. 
  
  
  
  
  23.   
    24. 
  
  
  
  
  24.  if (res>0){ 
    25. 
  
  
  
  
  25.  //TODO:进行异步邮件消息的通知=rabbitmq+mail 
    26. 
  
  
  
  
  26.  rabbitSenderService.sendKillSuccessEmailMsg(orderNo); 
    27. 
  
  
  
  
  27.   
    28. 
  
  
  
  
  28.  //TODO:入死信队列，用于 “失效” 超过指定的TTL时间时仍然未支付的订单 
    29. 
  
  
  
  
  29.  rabbitSenderService.sendKillSuccessOrderExpireMsg(orderNo); 
    30. 
  
  
  
  
  30.  } 
    31. 
  
  
  
  
  31.  } 
    32. 
  
  
  
  
  32. }复制代码 
    33.

该方法涉及的功能模块稍微比较多，即主要包含了“分布式唯一ID-雪花算法的应用”、“整合RabbitMQ异步发送通知消息给用户”、“基于JavaMail开发发送邮件的功能”、“死信队列失效超时未支付的订单”等等，这些功能模块将在后面的小节一步一步展开进行介绍！

（4）最后是需要在前端页面info.jsp开发“提交用户秒杀请求”的功能，其部分核心源代码如下所示：

其中，提交的数据是采用application/json的格式提交的，即json的格式！并采用POST的请求方法进行交互！

（5）将整个系统、项目采用外置的tomcat运行起来，观察控制台的输出信息，如果没有报错信息，则代表整体的实战代码没有语法级别的错误！点击“详情”按钮，登录成功后，进入“待秒杀商品的的详情”，可以查看当前待秒杀商品的详情信息；点击“抢购”按钮，即可进入“秒杀”环节，后端经过一系列的逻辑处理之后，将处理的结果返回给到前端，如下图所示：

[[271509]]

与此同时，当前用户的邮箱中将收到一条“秒杀成功”的邮件信息，表示当前用户已经成功秒杀抢到当前商品了，如下图所示：

除此之外，在数据库表item_kill_success中也将会生成一笔“秒杀成功的订单记录”，如下图所示：

当然，对于“邮件的通知”和“秒杀成功生成的订单的订单编号”的功能，在本节我们主要是分享介绍了秒杀系统中用户的“秒杀/抢购请求”功能！

新闻名称：Java秒杀系统：商品秒杀代码实战
本文网址：http://www.shufengxianlan.com/qtweb/news30/287080.html

网站建设、网络推广公司-创新互联，是专注品牌与效果的网站制作，网络营销seo公司；服务项目有等

广告

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 创新互联

猜你还喜欢下面的内容

搜索引擎优化知识

同城分类信息

成都小谭网创广告　　 　B2C电商系统　　 　免备案空间腾讯云　　 　成都网站设计　　 　成都网络营销　　 　成都小程序开发　　 　广汉网站建设　　 　成都网站制作　　 　成都活动策划　　 　成都ssl证书申请　　 　联通机房服务器托管　　 　成都光华机房服务器托管　　 　公司宣传册设计　　 　成都花箱厂家　　 　红锐电子　　 　成都建网站　　 　网站改版维护　　 　川银永信　　 　安卓开发　　 　品牌设计