摘要：

本篇博文是“Java秒杀系统实战系列文章”的第六篇，本篇博文我们将进入整个秒杀系统核心功能模块的代码开发，即“商品秒杀”功能模块的代码实战。

内容：

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

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

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

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

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

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

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

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

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

其源代码如下所示：

private static final String prefix = "kill";@Autowired
private IKillService killService;@Autowired
private ItemKillSuccessMapper itemKillSuccessMapper;/**** 商品秒杀核心业务逻辑*/
@RequestMapping(value = prefix+"/execute",method = RequestMethod.POST,consumes = MediaType.APPLICATION_JSON_UTF8_VALUE)
@ResponseBody
public 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
@ToString
public class KillDto implements Serializable{@NotNullprivate Integer killId;private Integer userId; //在整合shiro之后，userId字段可以不需要了！因为通过session进行获取了
}

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

@Autowired
private ItemKillSuccessMapper itemKillSuccessMapper;@Autowired
private ItemKillMapper itemKillMapper;@Autowired
private RabbitSenderService rabbitSenderService;//商品秒杀核心业务逻辑的处理
@Override
public 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如下所示：

<!--抢购商品，剩余数量减一--><update id="updateKillItem">UPDATE item_killSET total = total - 1WHEREid = #{killId}</update>

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

/*** 通用的方法-用户秒杀成功后创建订单-并进行异步邮件消息的通知* @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+mailrabbitSenderService.sendKillSuccessEmailMsg(orderNo);//TODO:入死信队列，用于 “失效” 超过指定的TTL时间时仍然未支付的订单rabbitSenderService.sendKillSuccessOrderExpireMsg(orderNo);}}
}

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

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

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

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

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

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

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

Java秒杀系统实战系列~商品秒杀代码实战相关推荐

java 秒杀代码_Java秒杀系统实战系列~商品秒杀代码实战
摘要: 本篇博文是"Java秒杀系统实战系列文章"的第六篇,本篇博文我们将进入整个秒杀系统核心功能模块的代码开发,即"商品秒杀"功能模块的代码实战. 内容: & ...
基于Java微服务方案的商品秒杀系统
前言项目是基于Java微服务方案的商品秒杀系统.是前后端分离的项目,前端用React,后端为Java的微服务架构.项目本身用于学习,在一些地方还不够成熟,欢迎各位多多交流. 客户端前端服务器后台系 ...
java商品详情页设计_java高并发秒杀系统3-2节商品详情页上.mp4
本Java商城秒杀系统视频教程目录如下: java高并发秒杀系统1-1节java高并发商城秒杀优化学习指引.mp4 java高并发秒杀系统1-2节项目环境搭建(Eclipse)-节.mp4 ja ...
电商项目实战之商品秒杀
电商项目实战之商品秒杀定时任务 corn表达式实现方式基于注解基于接口实战秒杀系统秒杀系统关注问题秒杀架构设计商品上架获取当前秒杀商品获取当前商品的秒杀信息秒杀最终处理参考链 ...
秒杀系统（1）——秒杀功能设计理念
文章目录电商系统下单功能概述订单量:从 0 到 1000(架构1) 订单量:从 1000 到 100万锁机制悲观锁乐观锁分布式锁消息队列消息队列:架构2 从电商系统到秒杀系统流量限制 ...
JAVA秒杀mysql层实现_Java商城高并发秒杀系统架构分析设计与开发实战
课程大纲 1-1课程整体介绍.mp4 1-2核心技术列表.mp4 1-3课程要求与收益.mp4 1-4系统的整体演示.mp4 2-1微服务项目的搭建-SpringBoot搭建多模块项目一.mp4 2- ...
Java秒杀系统方案优化高性能高并发实战学习笔记
秒杀系统 (一)搭建环境自定义封装Result类自定义封装CodeMsg类集成redis和rabbit 封装RedisService类断言和日志测试 (二)实现用户登录和分布式Session ...
java系统优化方案_Java秒杀系统方案优化高性能高并发实战-一号门
类别: 视频语言: Java 发布日期: 2019-03-02 介绍:以"秒杀"这一Java高性能高并发的试金石场景为例,带你通过一系列系统级优化,学会应对高并发. 第1章课程 ...
阿里、百度、美团都在用的‘’高并发秒杀系统‘’；抢红包、秒杀活动、微博热搜、12306抢票等高并发场景
"秒杀活动"."抢红包"."微博热搜"."12306抢票"."共享单车拉新"等都是高并发的典型业务场 ...

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

摘要：

内容：

Java秒杀系统实战系列~商品秒杀代码实战相关推荐

最新文章

热门文章