Java高并发秒杀API(三)之Web层

@RequestMapping(value = "/path", method = RequestMethod.GET) @RequestMapping(value = "/path", method = RequestMethod.POST) @RequestMapping(value = "/path", method = RequestMethod.PUT) @RequestMapping(value = "/path", method = RequestMethod.DELETE)

<web-app metadata-complete="true" version="3.0" xmlns="http://Java.sun.com/xml/ns/javaee" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_3_0.xsd">     <servlet>         <servlet-name>seckill-dispatcher</servlet-name>         <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>         <init-param>             <param-name>contextConfigLocation</param-name>             <param-value>classpath:spring/spring-*.xml</param-value>         </init-param>     </servlet>     <servlet-mapping>         <servlet-name>seckill-dispatcher</servlet-name>         <url-pattern>/</url-pattern>     </servlet-mapping> </web-app>

<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:context="http://www.springframework.org/schema/context" xmlns:mvc="http://www.springframework.org/schema/mvc" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc.xsd">     <annotation-driven></annotation-driven>     <default-servlet-handler></default-servlet-handler>     <bean class="org.springframework.web.servlet.view.InternalResourceViewResolver">         <property name="viewClass" value="org.springframework.web.servlet.view.JStlView"></property>         <property name="prefix" value="/WEB-INF/jsp/"></property>         <property name="suffix" value=".jsp"></property>     </bean>     <component-scan base-package="com.lewis.web"></component-scan> </beans>

@Controller @RequestMapping("/seckill") // url:模块/资源/{}/细分 public class SeckillController {     @Autowired     private SeckillService seckillService; <pre class="brush:php;toolbar:false">@RequestMapping(value = "/list", method = RequestMethod.GET) public String list(Model model) {     // list.jsp+mode=ModelAndView     // 获取列表页     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.GET, 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 = "userPhone", required = false) Long userPhone) {     if (userPhone == null) {         return new SeckillResult<SeckillExecution>(false, "未注册");     }     try {         SeckillExecution execution = seckillService.executeSeckill(seckillId, userPhone, 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()); }

// 将所有的ajax请求返回类型，全部封装成json数据 public class SeckillResult<T> { // 请求是否成功 private boolean success; private T data; private String error;</p><pre class="brush:php;toolbar:false">public SeckillResult(boolean success, T data) {     this.success = success;     this.data = data; }  public SeckillResult(boolean success, String error) {     this.success = success;     this.error = error; }  public boolean isSuccess() {     return success; }  public void setSuccess(boolean success) {     this.success = success; }  public T getData() {     return data; }  public void setData(T data) {     this.data = data; }  public String getError() {     return error; }  public void setError(String error) {     this.error = error; }

// 存放主要交互逻辑的js代码 // JavaScript 模块化(package.类.方法) var seckill = { // 封装秒杀相关ajax的url URL: { now: function () { return '/seckill/seckill/time/now'; }, exposer: function (seckillId) { return '/seckill/seckill/' + seckillId + '/exposer'; }, execution: function (seckillId, md5) { return '/seckill/seckill/' + seckillId + '/' + md5 + '/execution'; } }, // 验证手机号 validatePhone: function (phone) { if (phone && phone.length == 11 && !isNaN(phone)) { return true; // 直接判断对象会看对象是否为空,空就是undefine就是false; isNaN 非数字返回true } else { return false; } }, // 详情页秒杀逻辑 detail: { // 详情页初始化 init: function (params) { // 手机验证和登录,计时交互 // 规划我们的交互流程 // 在cookie中查找手机号 var userPhone = $.cookie('userPhone'); // 验证手机号 if (!seckill.validatePhone(userPhone)) { // 绑定手机 控制输出 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('userPhone', inputPhone, { expires: 7, path: '/seckill' }); // 验证通过刷新页面 window.location.reload(); } else { // todo 错误文案信息抽取到前端字典里 $('#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('开始秒杀'); $.get(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'); // , // 2.发送秒杀请求执行秒杀 $.post(killUrl, {}, function (result) { if (result && result['success']) { var killResult = result['data']; var state = killResult['state']; var stateInfo = killResult['stateInfo']; // 显示秒杀结果 node.html('' + stateInfo + ''); } }); }); 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 + '<em>' + nowTime + '</em>' + startTime + '_' + endTime); var seckillBox = $('#seckill-box'); if (nowTime > endTime) { // 秒杀结束 seckillBox.html('秒杀结束!'); } else if (nowTime < startTime) { // 秒杀未开始,计时事件绑定 var killTime = new Date(startTime + 1000); seckillBox.countdown(killTime, function (event) { // 时间格式 var format = event.strftime('秒杀倒计时: %D天 %H时 %M分 %S秒'); seckillBox.html(format); }).on('finish.countdown', function () { // 时间完成后回调事件 // 获取秒杀地址,控制现实逻辑,执行秒杀 seckill.handlerSeckill(seckillId, seckillBox); }); } else { // 秒杀开始 seckill.handlerSeckill(seckillId, seckillBox); } } };

// 封装秒杀相关ajax的url URL: { now: function () { return '/seckill/seckill/time/now'; }, exposer: function (seckillId) { return '/seckill/seckill/' + seckillId + '/exposer'; }, execution: function (seckillId, md5) { return '/seckill/seckill/' + seckillId + '/' + md5 + '/execution'; } },

<dependency> <groupId>org.webjars.bower</groupId> <artifactId>jquery.countdown</artifactId> <version>2.1.0</version> </dependency>

<script src="js/jquery.countdown.min.js"></script>

new Date(startTime - 0 + 1000); new Date(Number(startTime) + 1000);