最火的秒杀是如何实现的?
1、需求分析和技术难点:
(1) 分析:
秒杀的时候:减少库存和购买记录明细两个事件保持在同一个事物中。
使用联合查询避免同一用户多次秒杀同一商品(利用在插入购物明细表中的秒杀id和用户的唯一标识来避免)。
(2) 秒杀难点:事务和行级锁的处理
(3) 实现那些秒杀系统(以天猫的秒杀系统为例)
(4) 我们如何实现秒杀功能?
① 秒杀接口暴漏
② 执行秒杀
③ 相关查询
下面我们以主要代码实现秒杀系统:
PS:由于文章字符限制,没有办法将所有的代码列在文章中,大家可以在公众号内回复 ”秒杀“ 获取源码,方便您的学习
2.数据库设计和DAO层
(1) 数据库设计
(2) Dao层和对应的实体
① Seckill.java
② SuccessKilled.java
③ SeckillDao
④ SuccessKilledDao
⑤ mybatis配置文件:
⑥ SeckillDao.xml
⑦ SuccessKilledDao.xml
⑧ Mybatis整合Service:spring-dao.xml
3 Service层
① SeckillService
② SeckillServiceImpl
③ 异常的处理:
a.SeckillCloseException
b. SeckillException
c. RepeatKillException
④ 枚举SeckillStatEnum
⑤ spring_spring.xml文件
4.Web层,JSP页面和JS
(1) 详情页流程逻辑逻辑
(2) 配置web.xml
(3) SeckillResult
(4) spring-web.xml
(5) SeckillController中:
package com.force4us.web;import com.force4us.dto.Exposer;import com.force4us.dto.SeckillExecution;import com.force4us.dto.SeckillResult;import com.force4us.entity.Seckill;import com.force4us.enums.SeckillStatEnum;import com.force4us.exception.RepeatKillException;import com.force4us.exception.SeckillCloseException;import com.force4us.exception.SeckillException;import com.force4us.service.SeckillService;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.stereotype.Controller;import org.springframework.test.annotation.Repeat;import org.springframework.ui.Model;import org.springframework.web.bind.annotation.*;import java.util.Date;import java.util.List;
@Controller@RequestMapping("/seckill")public class SeckillController {
@Autowired private SeckillService seckillService;
@RequestMapping(value = "/list",method= RequestMethod.GET) public String list(Model model) { List<Seckill> list = seckillService.getSeckillList(); model.addAttribute("list",list); return "list"; }
@RequestMapping(value = "/{seckillId}/detail",method = RequestMethod.GET) public String detail(@PathVariable("seckillId") Long seckillId, Model model){ if(seckillId == null){ return "redirect:/seckill/list"; } Seckill seckill = seckillService.getById(seckillId); if(seckill == null){ return "forward:/seckill/list"; } model.addAttribute("seckill", seckill); return "detail"; }
//ajax ,json暴露秒杀接口的方法 @RequestMapping(value="/{seckillId}/exposer",method = RequestMethod.POST,produces = {"application/json;charset=UTF-8"}) @ResponseBody public SeckillResult<Exposer> exposer(@PathVariable("seckillId") Long seckillId){ SeckillResult<Exposer> result;
try { Exposer exposer = seckillService.exportSeckillUrl(seckillId); result = new SeckillResult<Exposer>(true,exposer); } catch (Exception e) { e.printStackTrace(); result = new SeckillResult<Exposer>(false,e.getMessage()); }
return result; }
@RequestMapping(value="/{seckillId}/{md5}/execution", method = RequestMethod.POST, produces = {"application/json;charset=UTF-8"}) @ResponseBody public SeckillResult<SeckillExecution> execute(@PathVariable("seckillId") Long seckillId, @PathVariable("md5") String md5, @CookieValue(value="killPhone", required = false) Long phone){ if(phone == null){ return new SeckillResult<SeckillExecution>(false,"未注册"); }
SeckillResult<SeckillExecution> result;
try { SeckillExecution execution = seckillService.executeSeckillProcedure(seckillId,phone, md5); return new SeckillResult<SeckillExecution>(true,execution); } catch (RepeatKillException e1) { SeckillExecution execution = new SeckillExecution(seckillId, SeckillStatEnum.REPEAT_KILL); return new SeckillResult<SeckillExecution>(true,execution); } catch(SeckillCloseException e2){ SeckillExecution execution = new SeckillExecution(seckillId, SeckillStatEnum.END); return new SeckillResult<SeckillExecution>(true,execution); }catch(Exception e){ SeckillExecution execution = new SeckillExecution(seckillId, SeckillStatEnum.INNER_ERROR); return new SeckillResult<SeckillExecution>(true,execution); } }
@RequestMapping(value = "/time/now", method = RequestMethod.GET) @ResponseBody public SeckillResult<Long> time(){ Date now = new Date(); return new SeckillResult<Long>(true,now.getTime()); }
@RequestMapping("/test") public String test(){ return "helloworld"; }}
(6) list.jsp
<%@ page contentType="text/html;charset=UTF-8" language="java" %><%@include file="common/tag.jsp"%><!DOCTYPE html><html lang="zh-CN"><head> <meta charset="utf-8"> <meta http-equiv="X-UA-Compatible" content="IE=edge"> <meta name="viewport" content="width=device-width, initial-scale=1"> <!-- 上述3个meta标签*必须*放在最前面,任何其他内容都*必须*跟随其后! --> <title>秒杀列表页</title> <%@include file="/WEB-INF/jsp/common/head.jsp"%>
</head><body>
<div class="container"> <div class="panel panel-default"> <div class="panel-heading text-center"> <h2>秒杀列表</h2> </div> <div class="panel-body"> <table class="table table-hover"> <thead> <tr> <th>名称</th> <th>库存</th> <th>开始时间</th> <th>结束时间</th> <th>创建时间</th> <th>详情页</th> </tr> </thead> <tbody> <c:forEach items="${list}" var="sk"> <tr> <td>${sk.name}</td> <td>${sk.number}</td> <td> <fmt:formatDate value="${sk.startTime}" pattern="yyyy-MM-dd HH:mm:ss" /> </td> <td> <fmt:formatDate value="${sk.endTime}" pattern="yyyy-MM-dd HH:mm:ss" /> </td> <td> <fmt:formatDate value="${sk.createTime}" pattern="yyyy-MM-dd HH:mm:ss" /> </td> <td><a class="btn btn-info" href="/seckill/${sk.seckillId}/detail" target="_blank">详情</a></td> </tr> </c:forEach> </tbody> </table>
</div> </div></div>
</body><!-- jQuery (necessary for Bootstrap's JavaScript plugins) --><script src="https://cdn.bootcss.com/jquery/1.12.4/jquery.min.js"></script>
<!-- 最新的 Bootstrap 核心 JavaScript 文件 --><script src="https://cdn.bootcss.com/bootstrap/3.3.7/js/bootstrap.min.js" integrity="sha384-Tc5IQib027qvyjSMfHjOMaLkfuWVxZxUPnCJA7l2mCWNIpG9mGCD8wGNIcPD7Txa" crossorigin="anonymous"></script>
</html>
(7) details.jsp
<%@ page contentType="text/html;charset=UTF-8" language="java" %><%@include file="common/tag.jsp"%><!DOCTYPE html><html lang="zh-CN"><head> <meta charset="utf-8"> <meta http-equiv="X-UA-Compatible" content="IE=edge"> <meta name="viewport" content="width=device-width, initial-scale=1"> <!-- 上述3个meta标签*必须*放在最前面,任何其他内容都*必须*跟随其后! --> <title>秒杀详情页</title> <%@include file="common/head.jsp"%>
</head><body>
<div class="container"> <div class="panel panel-default text-center"> <div class="pannel-heading"> <h1>${seckill.name}</h1> </div>
<div class="panel-body"> <h2 class="text-danger"> <%--显示time图标--%> <span class="glyphicon glyphicon-time"></span> <%--展示倒计时--%> <span class="glyphicon" id="seckill-box"></span> </h2> </div> </div></div>
<%--登录弹出层 输入电话--%><div id="killPhoneModal" class="modal fade">
<div class="modal-dialog">
<div class="modal-content"> <div class="modal-header"> <h3 class="modal-title text-center"> <span class="glyphicon glyphicon-phone"> </span>秒杀电话: </h3> </div>
<div class="modal-body"> <div class="row"> <div class="col-xs-8 col-xs-offset-2"> <input type="text" name="killPhone" id="killPhoneKey" placeholder="填写手机号^o^" class="form-control"> </div> </div> </div>
<div class="modal-footer"> <%--验证信息--%> <span id="killPhoneMessage" class="glyphicon"> </span> <button type="button" id="killPhoneBtn" class="btn btn-success"> <span class="glyphicon glyphicon-phone"></span> Submit </button> </div>
</div> </div>
</div>
</body><!-- jQuery (necessary for Bootstrap's JavaScript plugins) --><script src="https://cdn.bootcss.com/jquery/1.12.4/jquery.min.js"></script>
<!-- 最新的 Bootstrap 核心 JavaScript 文件 --><script src="https://cdn.bootcss.com/bootstrap/3.3.7/js/bootstrap.min.js" integrity="sha384-Tc5IQib027qvyjSMfHjOMaLkfuWVxZxUPnCJA7l2mCWNIpG9mGCD8wGNIcPD7Txa" crossorigin="anonymous"></script><%--jQuery Cookie操作插件--%><script src="https://cdn.bootcss.com/jquery-cookie/1.4.1/jquery.cookie.min.js"></script><%--jQuery countDown倒计时插件--%><script src="https://cdn.bootcss.com/jquery.countdown/2.2.0/jquery.countdown.min.js"></script>
<script src="/resource/script/seckill.js" typ="text/javascript"></script>
<script type="text/javascript"> $(function(){ seckill.detail.init({ seckillId:${seckill.seckillId}, startTime:${seckill.startTime.time}, endTime:${seckill.endTime.time} }); })
</script></html>
(8) seckill.js
//存放主要交互逻辑的js代码// javascript 模块化(package.类.方法)
var seckill = { //封装秒杀相关ajax的url URL: { now: function () { return '/seckill/time/now'; }, exposer: function (seckillId) { return '/seckill/' + seckillId + '/exposer'; }, execution: function (seckillId, md5) { return '/seckill/' + seckillId + '/' + md5 + '/execution'; } },
//验证手机号 validatePhone: function(phone){ if(phone && phone.length == 11 && !isNaN(phone)){ return true; }else{ return false; }
},
//详情页秒杀逻辑 detail:{ //详情页初始化 init:function (params) { //手机验证和登录,计时交互 //规划我们的交互流程 //在cookie中查找手机号 var killPhone = $.cookie('killPhone'); //验证手机号 if(!seckill.validatePhone(killPhone)){ //绑定手机,控制输出 var killPhoneModal = $('#killPhoneModal'); killPhoneModal.modal({ show:true,//显示弹出层 backdrop:'static',//禁止位置关闭 keyboard:false//关闭键盘事件 });
$('#killPhoneBtn').click(function () { var inputPhone = $('#killPhoneKey').val(); console.log("inputPhone" + inputPhone); if(seckill.validatePhone(inputPhone)){ //电话写入cookie,7天过期 $.cookie('killPhone',inputPhone,{expires:7, path:'/seckill'}); //验证通过,刷新页面 window.location.reload(); }else{ $('#killPhoneMessage').hide().html('<label class="label label-danger">手机号错误</label>').show(300); } }); } //已经登录 //计时交互
var startTime = params['startTime']; var endTime = params['endTime']; var seckillId = params['seckillId']; $.get(seckill.URL.now(), {}, function (result) { if (result && result['success']) { var nowTime = result['data']; //时间判断 计时交互 seckill.countDown(seckillId, nowTime, startTime, endTime); } else { console.log('result: ' + result); alert('result: ' + result); } }); } },
handlerSeckill: function (seckillId, node) { //获取秒杀地址,控制显示器,执行秒杀 node.hide().html('<button class="btn btn-primary btn-lg" id="killBtn">开始秒杀</button>');
$.post(seckill.URL.exposer(seckillId), {}, function (result) { //在回调函数种执行交互流程 if (result && result['success']) { var exposer = result['data']; if (exposer['exposed']) { //开启秒杀 //获取秒杀地址 var md5 = exposer['md5']; var killUrl = seckill.URL.execution(seckillId, md5); console.log("killUrl: " + killUrl); //绑定一次点击事件 $('#killBtn').one('click', function () { //执行秒杀请求 //1.先禁用按钮 $(this).addClass('disabled');//,<-$(this)===('#killBtn')-> //2.发送秒杀请求执行秒杀 $.post(killUrl, {}, function (result) { if (result && result['success']) { var killResult = result['data']; var state = killResult['state']; var stateInfo = killResult['stateInfo']; //显示秒杀结果 node.html('<span class="label label-success">' + stateInfo + '</span>'); } }); }); node.show(); } else { //未开启秒杀(浏览器计时偏差) var now = exposer['now']; var start = exposer['start']; var end = exposer['end']; seckill.countDown(seckillId, now, start, end); } } else { console.log('result: ' + result); } });
},
countDown: function (seckillId, nowTime, startTime, endTime) { console.log(seckillId + '_' + nowTime + '_' + startTime + '_' + endTime); var seckillBox = $('#seckill-box'); if (nowTime > endTime) { //秒杀结束 seckillBox.html('秒杀结束!'); } else if (nowTime < startTime) { //秒杀未开始,计时事件绑定 var killTime = new Date(startTime + 1000);//todo 防止时间偏移 seckillBox.countdown(killTime, function (event) { //时间格式 var format = event.strftime('秒杀倒计时: %D天 %H时 %M分 %S秒 '); seckillBox.html(format); }).on('finish.countdown', function () { //时间完成后回调事件 //获取秒杀地址,控制现实逻辑,执行秒杀 console.log('______fininsh.countdown'); seckill.handlerSeckill(seckillId, seckillBox); }); } else { //秒杀开始 seckill.handlerSeckill(seckillId, seckillBox); } }}
5.优化:
由于减少库存和购买明细需要在同一事物当中,在次中间会出现网络延迟,GC,缓存,数据库的并发等,所以需要进行优化。
(1) 使用Redis优化:具体代码看上面。
(2) 调整业务逻辑:先进行insert,插入购买明细,然后进行减少库存数量,具体代码看上面。
(3) 调用存储过程seckill.sql
6.系统部署:
到这里,已经基本完工。由于文章字符限制,没有办法将所有的代码列在文章中,大家可以在公众号内回复 ”秒杀“ 获取源码,方便您的学习
陛下...看完奏折,点个赞再走吧!
推荐阅读
技术:jenkins和docker实现自动化构建部署
技术:设计图都不会画,还想做”架构师“?
技术:玩转linux 这些命令就够了
技术:Kafka、RabbitMQ、RocketMQ等消息中间件的对比
技术:玩转linux 这些命令就够了
技术:30分钟如何学会使用Shiro
工具:如何通过技术手段 “干掉” 视频APP里讨厌广告?
工具:通过技术手段 “干掉” 视频APP里讨厌的广告之(腾讯视频)
博主11年java开发经验,现从事智能语音工作的研发,关注微信公众号与博主进行技术交流!更过干货资源等你来拿!
最火的秒杀是如何实现的?相关推荐
- 使用KALI实现远程控制PC
使用KALI生成木马病毒实现远程控制 前言 该文章内容仅用于学习使用Kali Linux系统,请不要将它用于非法的途径,如有意外概不负责. 我将会详细介绍使用Kali Linux系 ...
- 渗透外网测试KALI+隧道+加壳
使用KALI生成木马病毒实现远程控制 前言 该文章内容仅用于学习使用Kali Linux系统,请不要将它用于非法的途径,如有意外概不负责. 我将会详细介绍使用Kali Linux系 ...
- 老火 给大家说两句自己简单实现秒杀思路
大家应该都知道,秒杀为啥 用 异步队列 这种形式来处理吧?哈哈 因为我们写的程序功能之前常理都是 用户请求到后台,后台操作数据库进行实现相应功能. 上边说道 用户 --> 后台服务器 ...
- 这款录屏神器在 GitHub 火了,秒杀 33 种同类工具!
本次推荐一个录屏神器 「Screenity」 ,在 GitHub 上非常火爆,目前已狂揽 4.1K 颗星星. 1. 功能亮点 windows 和 Mac 自带的录屏软件功能都比较有限(windows ...
- 推荐 GitHub 上很火的录屏工具,秒杀 33 种同行工具
大家好,我是你们的 猫哥,那个不喜欢吃鱼.又不喜欢喵 的超级猫 ~ 今天要推荐一个强大.功能丰富的屏幕录制工具,它是 Chrome 插件. 功能 ???? 无限记录您的标签页,桌面,任何应用程序和相机 ...
- 秒杀大王卡!最近超火的电信物联卡哪里有卖?
虽然物联网近年来一直被提及,但物联卡的应用在生活中却是很普遍了,物联网卡是三大运营商提供的用于智能设备连接网络的一种流量卡,那么既然是由三大运营商提供,那么有劣势肯定会存在着差异,今天小编对电信物联卡 ...
- 12306系统的秒杀“艺术”:如何抗住100万人同时抢1万张票?
作者 | IT牧场 编辑 | 阿秃 每到节假日期间,一二线城市返乡.外出游玩的人们几乎都面临着一个问题--抢火车票.虽然现在大多数情况下都能订到票,但是放票瞬间即无票的场景,相信大家都深有体会. 尤其 ...
- 拿到腾讯字节快手 offer 后,他的 LeetCode 刷题经验在 GitHub 火了!
杨净 发自 凹非寺 量子位 报道 | 公众号 QbitAI 今天,你刷LeetCode了吗? 最近,GitHub上这样一套LeetCode笔记火了. 一位Java研发工程师分享了一个名为「LeetC ...
- 面试被问到秒杀系统,这个点你一定得答到!
本文来源:搜云库 概述 在面试被问到系统设计这块时候,秒杀系统经常是一个热门考点.今天我们就讨论一下其中的重要一点:如何进行秒杀系统的流量销锋? 如果你看过秒杀系统的流量监控图的话,你会发现它是一条直 ...
最新文章
- python中,time、calendar、datetime
- Redis分布式锁 Spring Schedule实现任务调度
- 【JavaScript】document对象属性
- 无需另配定时器在STM32 HAL下实现微秒级延时(兼容FreeRTOS)
- 数据结构---function
- MySQL事务ACID实现原理
- 解决重启centos后resolv.conf总被清空的问题
- Python快速计算Fibonacci数列中第n项的方法
- 通过对极几何求解相机运动
- Python3—元组
- getline基本用途
- 微型计算机工作最小时间单位,2010~2011学年第1学期微机原理2试卷A(答案)
- vue强制刷新组件_Vue强制组件重新渲染
- java ffmpeg m3u8合片_FFmpeg MP4视频切片成TS m3u8播放系列
- 网易云登陆界面怎么用PHP做,网易云音乐登录流程图
- CodeReview流程梳理
- 计算机excel操作知识点汇总,【计算机二级之Excel】考点汇总
- Fantastic-Matplotlib 第二回
- 最近超火的100句土味情话合集,拿去撩妹撩汉吧!
- win7通过win10的ISO镜像免费升级正版win10(组图)