java秒杀系统 代码大全_Java秒杀系统:商品秒杀代码实战
内容:
“商品秒杀”功能模块是建立在“商品详情”功能模块的基础之上,对于这一功能模块而言,其主要的核心流程在于:前端发起抢购请求,该请求将携带着一些请求数据:待秒杀Id跟当前用户Id等数据;后端接口在接收到请求之后,将执行一系列的判断与秒杀处理逻辑,最终将处理结果返回给到前端。
其中,后端接口的这一系列判断与秒杀处理逻辑还是挺复杂的,Debug将其绘制成了如下的流程图:
从该业务流程图中可以看出,后端接口在接收前端用户的秒杀请求时,其核心处理逻辑为:
(1)首先判断当前用户是否已经抢购过该商品了,如果否,则代表用户没有抢购过该商品,可以进入下一步的处理逻辑
(2)判断该商品可抢的剩余数量,即库存是否充足(即是否大于0),如果是,则进入下一步的处理逻辑
(3)扣减库存,并更新数据库的中对应抢购记录的库存(一般是减一操作),判断更新库存的数据库操作是否成功了,如果是,则创建用户秒杀成功的订单,并异步发送短信或者邮件通知信息通知用户
(4)以上的操作逻辑如果有任何一步是不满足条件的,则直接结束整个秒杀的流程,即秒杀失败!
接下来,我们仍然基于MVC的开发模式,采用代码实战实现这一功能模块!
(1)首先是在KillController 控制器开发接收“前端用户秒杀请求”的功能方法,其中,该方法需要接收前端请求过来的“待秒杀Id”,而当前用户的Id可以通过上一篇博文介绍的Shiro 的会话模块Session进行获取!
其源代码如下所示:
privatestaticfinalString prefix ="kill";
@Autowired
privateIKillService killService;
@Autowired
privateItemKillSuccessMapper itemKillSuccessMapper;
/***
* 商品秒杀核心业务逻辑
*/
@RequestMapping(value = prefix+"/execute",method = RequestMethod.POST,consumes = MediaType.APPLICATION_JSON_UTF8_VALUE)
@ResponseBody
publicBaseResponse execute(@RequestBody@ValidatedKillDto dto, BindingResult result, HttpSession session){
if(result.hasErrors() || dto.getKillId()<=0){
returnnewBaseResponse(StatusCode.InvalidParams);
}
//获取当前登录用户的信息
Object uId=session.getAttribute("uid");
if(uId==null){
returnnewBaseResponse(StatusCode.UserNotLogin);
}
Integer userId= (Integer)uId ;
BaseResponse response=newBaseResponse(StatusCode.Success);
try{
Boolean res=killService.killItem(dto.getKillId(),userId);
if(!res){
returnnewBaseResponse(StatusCode.Fail.getCode(),"哈哈~商品已抢购完毕或者不在抢购时间段哦!");
}
}catch(Exception e){
response=newBaseResponse(StatusCode.Fail.getCode(),e.getMessage());
}
returnresponse;
}复制代码
其中,KillDto对象主要封装了“待秒杀Id”等字段信息,其主要用于接收前端过来的用户秒杀请求信息,源代码如下所示:
@Data
@ToString
publicclassKillDtoimplementsSerializable{
@NotNull
privateInteger killId;
privateInteger userId;//在整合shiro之后,userId字段可以不需要了!因为通过session进行获取了
}复制代码
(2)紧接着是开发 killService.killItem(dto.getKillId(),userId) 的功能,该功能对应的代码的编写逻辑可以参见本文刚开始介绍时的流程图!其完整源代码如下所示:
@Autowired
privateItemKillSuccessMapper itemKillSuccessMapper;
@Autowired
privateItemKillMapper itemKillMapper;
@Autowired
privateRabbitSenderService rabbitSenderService;
//商品秒杀核心业务逻辑的处理
@Override
publicBoolean killItem(Integer killId, Integer userId)throwsException {
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:扣减库存-减一
intres=itemKillMapper.updateKillItem(killId);
//TODO:扣减是否成功?是-生成秒杀成功的订单,同时通知用户秒杀成功的消息
if(res>0){
commonRecordKillSuccessInfo(itemKill,userId);
result=true;
}
}
}else{
thrownewException("您已经抢购过该商品了!");
}
returnresult;
}复制代码
其中,itemKillMapper.selectById(killId); 表示用于获取待秒杀商品的详情信息,这在前面的篇章中已经介绍过了;而 itemKillMapper.updateKillItem(killId); 主要用于扣减库存(在这里是减1操作),其对应的动态Sql如下所示:
UPDATE item_kill
SET total = total - 1
WHERE
id = #{killId}
复制代码
(3)值得一提的是,在上面 KillService执行killItem功能方法时,还开发了一个通用的方法:用户秒杀成功后创建秒杀订单、并异步发送通知消息给到用户秒杀成功的信息!该方法为 commonRecordKillSuccessInfo(itemKill,userId); 其完整的源代码如下所示:
/**
* 通用的方法-用户秒杀成功后创建订单-并进行异步邮件消息的通知
* @param kill
* @param userId
* @throws Exception
*/
privatevoidcommonRecordKillSuccessInfo(ItemKill kill, Integer userId)throwsException{
//TODO:记录抢购成功后生成的秒杀订单记录
ItemKillSuccess entity=newItemKillSuccess();
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){
intres=itemKillSuccessMapper.insertSelective(entity);
if(res>0){
//TODO:进行异步邮件消息的通知=rabbitmq+mail
rabbitSenderService.sendKillSuccessEmailMsg(orderNo);
//TODO:入死信队列,用于 “失效” 超过指定的TTL时间时仍然未支付的订单
rabbitSenderService.sendKillSuccessOrderExpireMsg(orderNo);
}
}
}复制代码
该方法涉及的功能模块稍微比较多,即主要包含了“分布式唯一ID-雪花算法的应用”、“整合RabbitMQ异步发送通知消息给用户”、“基于JavaMail开发发送邮件的功能”、“死信队列失效超时未支付的订单”等等,这些功能模块将在后面的小节一步一步展开进行介绍!
(4)最后是需要在前端页面info.jsp开发“提交用户秒杀请求”的功能,其部分核心源代码如下所示:
其中,提交的数据是采用application/json的格式提交的,即json的格式!并采用POST的请求方法进行交互!
(5)将整个系统、项目采用外置的tomcat运行起来,观察控制台的输出信息,如果没有报错信息,则代表整体的实战代码没有语法级别的错误!点击“详情”按钮,登录成功后,进入“待秒杀商品的的详情”,可以查看当前待秒杀商品的详情信息;点击“抢购”按钮,即可进入“秒杀”环节,后端经过一系列的逻辑处理之后,将处理的结果返回给到前端,如下图所示:
与此同时,当前用户的邮箱中将收到一条“秒杀成功”的邮件信息,表示当前用户已经成功秒杀抢到当前商品了,如下图所示:
除此之外,在数据库表item_kill_success中也将会生成一笔“秒杀成功的订单记录”,如下图所示:
当然,对于“邮件的通知”和“秒杀成功生成的订单的订单编号”的功能,在本节我们主要是分享介绍了秒杀系统中用户的“秒杀/抢购请求”功能!
【编辑推荐】
【责任编辑:张燕妮 TEL:(010)68476606】
点赞 0
java秒杀系统 代码大全_Java秒杀系统:商品秒杀代码实战相关推荐
- JAVA秒杀mysql层实现_Java商城高并发秒杀系统架构分析设计与开发实战
课程大纲 1-1课程整体介绍.mp4 1-2核心技术列表.mp4 1-3课程要求与收益.mp4 1-4系统的整体演示.mp4 2-1微服务项目的搭建-SpringBoot搭建多模块项目一.mp4 2- ...
- java语言代码大全_Java常用语言汇总
Java有哪些常用语?不介绍Java 常用语,对Java 的总体介绍就是不完整的.尽管促使Java 诞生的源动力是可移植性和安全性,但在Java 语言终成型的过程中,其他一些因素也起了重要的作用.接下 ...
- 【Java秒杀方案】11.功能开发-【商品秒杀及优化】防止超卖 接口优化(redis预减库存,内存标记减少redis访问,RabbitMQ异步下单) 安全优化(隐藏秒杀接口,验证码,接口防刷)
商品秒杀核心功能及优化 1. 正常秒杀流程 在商品详情页面等待秒杀倒计时–http://localhost:8080/goodsDetail.htm?goodsId=2 倒计时为0,开始秒杀,点[秒杀 ...
- Java内置线程池ExecutorService介绍及商品秒杀案例
第一.ExecutorService接口是java内置的线程池接口,通过学习接口中的方法,可以快速的掌握java内置线程池的基本使用 常用方法: void shutdown() 启动一次顺序关闭,执行 ...
- java定义时间格式大全_Java时间格式转换大全
package com.date; import java.text.DateFormat; import java.text.ParseException; import java.text.Par ...
- java子类代码块_java中父类子类静态代码块、构造代码块执行顺序
父类静态(代码块,变量赋值二者按顺序执行) 子类静态 父类构造代码块 父类构造方法 子类构造代码块 子类构造方法 普通方法在实列调用的时候执行,肯定位于上面之后了 //父类A public class ...
- redis如何解决秒杀超卖java_Spring Boot + redis解决商品秒杀库存超卖,看这篇文章就够了...
作者:涛哥谈篮球 来源:toutiao.com/i6836611989607809548 问题描述 在众多抢购活动中,在有限的商品数量的限制下如何保证抢购到商品的用户数不能大于商品数量,也就是不能出现 ...
- python基础代码大全博客园,python基础代码大全解释
python必背入门代码是什么? python必背代码是:defnot_empty(s):returnsandlen(s.strip())>0#returnsands.strip()#如果直接单 ...
- php 弹窗代码大全,PHP_asp.net弹出窗口代码大全,//关闭,父窗口弹出对话框,子窗 - phpStudy...
asp.net弹出窗口代码大全 //关闭,父窗口弹出对话框,子窗口直接关闭 this.Response.Write(""); //关闭,父窗口和子窗口都不弹出对话框,直接关闭 th ...
最新文章
- slf4j 日志监控
- flamingo的中文意思是什么_flamingo.是什么意思
- 实验一HSRP与STP结合
- 用ASP.NET 重绘TabControl代码
- AT4378-[AGC027D]ModuloMatrix【构造】
- diff算法_vue源码解读 diff算法
- javascript-阻止默认行为发生
- iPhone 12不标配充电器后,国产手机配件成了国外抢手货!
- 小程序入门学习07--动态设置标题、转发
- python多元回归因子选取_Python中的多元回归(带因子选择)
- 深入理解计算机系统(1.3)------操作系统的抽象概念
- 17、手势(Gesture)
- 请教点击按钮时获得文本框中的字符进行操作问题
- 双IP双线路实现方式 先来说说双线单IP和双线双IP的区别
- 希尔排序--简单易懂图解
- unity帧动画事件多次播放
- 超简单的倒计时代码编写
- 计算机d代表什么,DVI-D和DVI-I区别是什么?
- Java 复习之多线程
- 每日一题-特效药申报题解