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);