java>> seckill>> 返回
项目作者： July077

项目描述 ：
一个整合SSM框架的高并发和商品秒杀项目,学习目前较流行的Java框架组合实现高并发秒杀API
高级语言： Java
项目地址: git://github.com/July077/seckill.git


seckill

一个整合SSM框架的高并发和商品秒杀项目,学习目前较流行的Java框架组合实现高并发秒杀API

项目的来源

项目的来源于国内IT公开课平台,质量没的说,很适合学习一些技术的基础,这个项目是由四个系列的课程组成的,流程分为几个流程,很基础地教你接触到一个相对有技术含量的项目

  • Java高并发秒杀API之业务分析与DAO层
  • Java高并发秒杀API之web层
  • Java高并发秒杀API之Service层
  • Java高并发秒杀API之高并发优化

其实这几个流程也就是开发的流程,首先从DAO层开始开发,从后往前开发,开始Coding吧！

项目环境的搭建

  • 操作系统 : Ubuntu 17.04
  • IDE ：IntelliJ IDEA 2016.2.5 x64 用Eclipse也一样的,工具时靠人用的
  • JDK : JDK1.8 建议使用JDK1.7以上版本,有许多语法糖用着挺舒服的
  • Web容器 ： Tomcat 8.0
  • 数据库 ：Mysql-5.6.17-WinX64 实验性的项目用Mysql就足够啦

  • 依赖管理工具 : Maven 管理jar包真的很方便

    这里列出的环境不是必须的,你喜欢用什么就用什么,这里只是给出参考,不过不同的版本可能会引起各种不同的问题就需要我们自己去发现以及排查,在这里使用Maven的话时方便我们管理JAR包,我们不用跑去各种开源框架的官网去下载一个又一个的JAR包,配置好了Maven后添加pom文件坐标就会从中央仓库下载JAR包,如果哪天替换版本也很方便

项目效果图

  • 秒杀商品列表

效果图

  • 秒杀结束提示界面

效果图

  • 开始秒杀提示界面

效果图

  • 重复秒杀提示界面

效果图

  • 秒杀秒杀成功提示界面

效果图

项目的运行

下载

Download Zip或者 git clone

  1.     git clone https://github.com/Sunybyjava/seckill.git

导入到IDE

这里因为是使用IDEA创建的项目,所以使用IDEA直接打开是很方便的,提前是你要配置好maven的相关配置,以及项目JDK版本,
JDK版本必须在1.8以上,因为在项目中使用了Java8的LocalDateTime以及LocalDate,所以低于这个版本编译会失败的

  • IDEA
    直接在主界面选择Open,然后找到项目所在路径,点击pom.xml打开就可以了
  • Eclipse
    这个项目是基于IDEA创建,我这里把项目转成了Eclipse的项目,如果你使用Eclipse的话也可以直接导入,只是步骤更繁琐一点,Eclipse导入步骤

项目编码

项目总结可能比较的长,密集恐惧症者请按小节进行阅读

这里按照上面几个流程走下去,你要有基本的Maven认识以及Java语法的一些概念,要不然可能不太理解

(一)Java高并发秒杀APi之业务分析与DAO层代码编写

构建项目的基本骨架

  • 首先我们要搭建出一个符合Maven约定的目录来,这里大致有两种方式,第一种:
    1. 第一种使用命令行手动构建一个maven结构的目录,当然我基本不会这样构建
      1. mvn archetype:generate -DgroupId=com.suny.seckill -DartifactId=seckill -Dpackage=com.suny.seckill -Dversion=1.0-SNAPSHOT -DarchetypeArtifactId=maven-archetype-webapp
      这里要注意的是使用archetype:generate进行创建,在Maven老版本中是使用archetype:create,现在这种方法已经被弃用了,所以使用命令行创建的话注意了,稍微解释下这段语句的意思,就是构建一个一个maven-archetype-webapp骨架的Webapp项目,然后groupId为com.suny.seckill,artifactId为seckill,这里是Maven相关知识,可以按照自己的情况进行修改

2.第二种直接在IDE中进行创建,这里以IDEA为例

  • 点击左上角File>New>Project>Maven
  • 然后在里面勾选Create from archetype,然后再往下拉找到org.apache.cocoon:cocoon-22-archetype-webapp,选中它,注意要先勾选那个选项,否则选择不了,然后点击Next继续
    创建Maven项目
    +然后就填写你的Maven的那几个重要的坐标了,自己看着填吧
    填写Maven坐标
    +再就配置你的Maven的相关信息,默认应该是配置好的
    填写Maven在你本机的位置
    +之后就是点Finsh,到此不出意外的话就应该创建成功了

构建pom文件

项目基本的骨架我们就创建出来了,接下来我们要添加一些基本的JAR包的依赖,也就是在pom.xml中添加各种开源组件的三坐标了 

  1. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  2.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
  3.           <modelVersion>4.0.0</modelVersion>
  4.           <groupId>com.suny.seckill</groupId>
  5.           <artifactId>seckill</artifactId>
  6.           <version>1.0-SNAPSHOT</version>
  7.           <name>seckill Maven Webapp</name>
  8.           <url>http://maven.apache.org</url>
  9.     <dependencies>
  11.         <!--junit测试-->
  12.         <dependency>
  13.             <groupId>junit</groupId>
  14.             <artifactId>junit</artifactId>
  15.             <version>4.12</version>
  16.             <scope>test</scope>
  17.         </dependency>
  19.         <!--配置日志相关,日志门面使用slf4j,日志的具体实现由logback实现-->
  20.         <dependency>
  21.             <groupId>ch.qos.logback</groupId>
  22.             <artifactId>logback-classic</artifactId>
  23.             <version>1.1.7</version>
  24.         </dependency>
  25.         <dependency>
  26.             <groupId>org.slf4j</groupId>
  27.             <artifactId>slf4j-api</artifactId>
  28.             <version>1.7.21</version>
  29.         </dependency>
  30.         <dependency>
  31.             <groupId>org.apache.logging.log4j</groupId>
  32.             <artifactId>log4j-core</artifactId>
  33.             <version>2.6.1</version>
  34.         </dependency>
  36.         <!--数据库相关依赖-->
  37.         <!--首先导入连接Mysql数据连接-->
  38.         <dependency>
  39.             <groupId>mysql</groupId>
  40.             <artifactId>mysql-connector-java</artifactId>
  41.             <version>5.1.39</version>
  42.         </dependency>
  44.         <!--导入数据库连接池-->
  45.         <dependency>
  46.             <groupId>c3p0</groupId>
  47.             <artifactId>c3p0</artifactId>
  48.             <version>0.9.1.2</version>
  49.         </dependency>
  51.         <!--导入mybatis依赖-->
  52.         <dependency>
  53.             <groupId>org.mybatis</groupId>
  54.             <artifactId>mybatis</artifactId>
  55.             <version>3.4.2</version>
  56.         </dependency>
  57.         <dependency>
  58.             <groupId>org.mybatis</groupId>
  59.             <artifactId>mybatis-spring</artifactId>
  60.             <version>1.3.1</version>
  61.         </dependency>
  63.         <!--导入Servlet web相关的依赖-->
  64.         <dependency>
  65.             <groupId>taglibs</groupId>
  66.             <artifactId>standard</artifactId>
  67.             <version>1.1.2</version>
  68.         </dependency>
  69.         <dependency>
  70.             <groupId>jstl</groupId>
  71.             <artifactId>jstl</artifactId>
  72.             <version>1.2</version>
  73.         </dependency>
  74.         <!--spring默认的json转换-->
  75.         <dependency>
  76.             <groupId>com.fasterxml.jackson.core</groupId>
  77.             <artifactId>jackson-databind</artifactId>
  78.             <version>2.8.5</version>
  79.         </dependency>
  80.         <dependency>
  81.             <groupId>javax.servlet</groupId>
  82.             <artifactId>javax.servlet-api</artifactId>
  83.             <version>3.1.0</version>
  84.         </dependency>
  86.         <!--导入spring相关依赖-->
  87.         <dependency>
  88.             <groupId>org.springframework</groupId>
  89.             <artifactId>spring-core</artifactId>
  90.             <version>4.3.6.RELEASE</version>
  91.         </dependency>
  92.         <dependency>
  93.             <groupId>org.springframework</groupId>
  94.             <artifactId>spring-beans</artifactId>
  95.             <version>4.3.6.RELEASE</version>
  96.         </dependency>
  97.         <dependency>
  98.             <groupId>org.springframework</groupId>
  99.             <artifactId>spring-context</artifactId>
  100.             <version>4.3.6.RELEASE</version>
  101.         </dependency>
  102.         <dependency>
  103.             <groupId>org.springframework</groupId>
  104.             <artifactId>spring-jdbc</artifactId>
  105.             <version>4.3.7.RELEASE</version>
  106.         </dependency>
  107.         <dependency>
  108.             <groupId>org.springframework</groupId>
  109.             <artifactId>spring-tx</artifactId>
  110.             <version>4.3.6.RELEASE</version>
  111.         </dependency>
  112.         <dependency>
  113.             <groupId>org.springframework</groupId>
  114.             <artifactId>spring-web</artifactId>
  115.             <version>4.3.6.RELEASE</version>
  116.         </dependency>
  117.         <dependency>
  118.             <groupId>org.springframework</groupId>
  119.             <artifactId>spring-webmvc</artifactId>
  120.             <version>4.3.7.RELEASE</version>
  121.         </dependency>
  123.         <!--导入springTest-->
  124.         <dependency>
  125.             <groupId>org.springframework</groupId>
  126.             <artifactId>spring-test</artifactId>
  127.             <version>4.2.7.RELEASE</version>
  128.         </dependency>
  129.     </dependencies>
  130.     <build>
  131.         <finalName>seckill</finalName>
  132.     </build>
  133. </project>

建立数据库

在根目录下有一个sql文件夹里面有一个sql数据库脚本,如果你不想自己手写的话就直接导入到你的数据库里面去吧,不过还是建议自己手写一遍加深印象

  2. -- 整个项目的数据库脚本
  3. -- 开始创建一个数据库
  4. CREATE DATABASE seckill;
  5. -- 使用数据库
  6. USE seckill;
  7. -- 创建秒杀库存表
  8. CREATE TABLE seckill(
  9.   `seckill_id` BIGINT NOT NULL AUTO_INCREMENT COMMENT '商品库存ID',
  10.   `name` VARCHAR(120) NOT NULL COMMENT '商品名称',
  11.   `number` INT NOT NULL COMMENT '库存数量',
  12.   `start_time` TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP() COMMENT '秒杀开启的时间',
  13.   `end_time` TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP() COMMENT '秒杀结束的时间',
  14.   `create_time` TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP() COMMENT '创建的时间',
  15.   PRIMARY KEY (seckill_id),
  16.   KEY idx_start_time(start_time),
  17.   KEY idx_end_time(end_time),
  18.   KEY idx_create_time(create_time)
  19. )ENGINE =InnoDB AUTO_INCREMENT=1000 DEFAULT CHARSET=utf8 COMMENT='秒杀库存表';
  21. -- 插入初始化数据
  23. insert into
  24.   seckill(name,number,start_time,end_time)
  25. values
  26.   ('1000元秒杀iphone6',100,'2016-5-22 00:00:00','2016-5-23 00:00:00'),
  27.   ('500元秒杀iPad2',200,'2016-5-22 00:00:00','2016-5-23 00:00:00'),
  28.   ('300元秒杀小米4',300,'2016-5-22 00:00:00','2016-5-23 00:00:00'),
  29.   ('200元秒杀红米note',400,'2016-5-22 00:00:00','2016-5-23 00:00:00');
  31. -- 秒杀成功明细表
  32. -- 用户登录相关信息
  33. create table success_killed(
  34.   `seckill_id` BIGINT NOT NULL COMMENT '秒杀商品ID',
  35.   `user_phone` BIGINT NOT NULL COMMENT '用户手机号',
  36.   `state` TINYINT NOT NULL DEFAULT -1 COMMENT '状态标示:-1无效 0成功 1已付款',
  37.   `create_time` TIMESTAMP NOT NULL COMMENT '创建时间',
  38.   PRIMARY KEY (seckill_id,user_phone), /*联合主键*/
  39.   KEY idx_create_time(create_time)
  40. )ENGINE =InnDB DEFAULT CHARSET =utf8 COMMENT ='秒杀成功明细表'
  • 在建立数据库的,如果按照我这里的数据库脚本建立的话应该是没问题的,但是我按照视频里面的数据库脚本建表的话发生了一个错误
    sql报错
    这个报错看起来比较的诡异,我仔细检查sql也没有错误,它总提示我end_time要有一个默认的值,可我记得我以前就不会这样,然后视频里面也没有执行错误,然后我感觉可能时MySQL版本的差异,我查看了下我数据库版本,在登录Mysql控制台后输入指令,在控制台的我暂时知道的有两种方式:
    1. select version();  
    2. select @@version;
    我的输出结果如下:
    Mysql版本
    其实登录进控制台就已经可以看到版本了,我的Mysql是5.7的,以前我用的时5.6的,然后去Google上搜索了下,找到了几个答案,参考链接：

然后网友评论里总结出来的几种解决办法,未经测试！：

  • 下次有问题一定要先看一下评论！！！create不了的同学,可以这样写：

    1.  `start_time` TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '秒杀开始时间',
    2.  `end_time` TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '秒杀结束时间',
    3.  `create_time` TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
    • 关于timestamp的问题,需要先运行 set explicit_defaults_for_timestamp = 1,否则会报invalid default value错误
    • 还需要注意的是SQL版本的问题会导致视频中seckill表创建会出错。只要将create_time放在start_time和end_time之前是方便的解决方法。

    对比下我修改过后的跟视频里面的sql片段:
    sql对比
    我们可以看到在这三个字段有一个小差别,那就是给start_time,end_time,create_time三个字段都添加一个默认值,然后执行数据库语句就没问题了

这里我们需要修改下web.xml中的servlet版本为3.0

打开WEB-INF下的web.xml,修改为以下代码:

  1. <web-app xmlns="http://java.sun.com/xml/ns/javaee"
  2.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3.          xsi:schemaLocation="http://java.sun.com/xml/ns/javaee
  4.                       http://java.sun.com/xml/ns/javaee/web-app_3_0.xsd"
  5.          version="3.0"
  6.          metadata-complete="true">
  7.     <!--用maven创建的web-app需要修改servlet的版本为3.0-->

修改的原因有以下几点:

  • 高版本的Servlet支持更多的特性,更方便我们的Coding,特别是支持注解这一特性
  • 在Servlet2.3中新加入了Listener接口的实现,,我们可以使用Listener引入Spring的ContextLoaderListener

举个栗子:

  • 在Servlet2.3以前我们这样配置ContextLoaderListener:
    1. <servlet>
    2. <servlet-name>context</servlet-name>
    3. <servlet-class>org.springframework.context.ContextLoaderServlet</servlet-class>
    4. <load-on-startup>1</load-on-startup>
    5. </servlet>
    • 在Servlet2.3以后可以使用Listener配置,也就是我们项目中使用的方法
      1. <listener>
      2. <listener-class>org.springframework.context.ContextLoaderListener</listener-class>
      3. </listener>
      两种方法的效果都是一样的,主要不要同时使用,否则会报错的

建立实体类

  • 首先建立SuccessKilled 秒杀状态表
    ```java
    package com.suny.entity;

import java.io.Serializable;
import java.time.LocalDateTime;

public class SuccessKilled implements Serializable {
private static final long serialVersionUID = 1834437127882846202L;

  1. private long seckillId;
  2. /* 用户的手机号码*/
  3. private long userPhone;
  4. /* 秒杀的状态*/
  5. private short state;
  6. /* 创建时间*/
  7. private LocalDateTime createTime;
  8. /* 多对一,因为一件商品在库存中肯定有许多,对应的购买信息也有很多*/
  9. private Seckill seckill;
  11. public SuccessKilled() {
  12. }
  14. public SuccessKilled(long seckillId, long userPhone, short state, LocalDateTime createTime, Seckill seckill) {
  15.     this.seckillId = seckillId;
  16.     this.userPhone = userPhone;
  17.     this.state = state;
  18.     this.createTime = createTime;
  19.     this.seckill = seckill;
  20. }
  22. public long getSeckillId() {
  23.     return seckillId;
  24. }
  26. public void setSeckillId(long seckillId) {
  27.     this.seckillId = seckillId;
  28. }
  30. public long getUserPhone() {
  31.     return userPhone;
  32. }
  34. public void setUserPhone(long userPhone) {
  35.     this.userPhone = userPhone;
  36. }
  38. public short getState() {
  39.     return state;
  40. }
  42. public void setState(short state) {
  43.     this.state = state;
  44. }
  46. public LocalDateTime getCreateTime() {
  47.     return createTime;
  48. }
  50. public void setCreateTime(LocalDateTime createTime) {
  51.     this.createTime = createTime;
  52. }
  54. public Seckill getSeckill() {
  55.     return seckill;
  56. }
  58. public void setSeckill(Seckill seckill) {
  59.     this.seckill = seckill;
  60. }
  62. @Override
  63. public String toString() {
  64.     return "SuccessKilled{" +
  65.             "主键ID=" + seckillId +
  66.             ", 手机号码=" + userPhone +
  67.             ", 秒杀状态=" + state +
  68.             ", 创建时间=" + createTime +
  69.             ", 秒杀的商品=" + seckill +
  70.             '}';
  71. }

}

  1.  - 再建立`Seckill` 秒杀商品信息
  2. ```java
  3. package com.suny.entity;
  5. import java.io.Serializable;
  6. import java.time.LocalDateTime;
  8. public class Seckill implements Serializable {
  10.     private static final long serialVersionUID = 2912164127598660137L;
  11.     /* 主键ID*/
  12.     private long seckillId;
  13.     /*  秒杀商品名字 */
  14.     private String name;
  15.     /* 秒杀的商品编号 */
  16.     private int number;
  17.     /* 开始秒杀的时间 */
  18.     private LocalDateTime startTime;
  19.     /* 结束秒杀的时间 */
  20.     private LocalDateTime endTime;
  21.     /* 创建的时间 */
  22.     private LocalDateTime createTIme;
  24.     public Seckill() {
  25.     }
  27.     public Seckill(long seckillId, String name, int number, LocalDateTime startTime, LocalDateTime endTime, LocalDateTime createTIme) {
  28.         this.seckillId = seckillId;
  29.         this.name = name;
  30.         this.number = number;
  31.         this.startTime = startTime;
  32.         this.endTime = endTime;
  33.         this.createTIme = createTIme;
  34.     }
  36.     public long getSeckillId() {
  37.         return seckillId;
  38.     }
  40.     public void setSeckillId(long seckillId) {
  41.         this.seckillId = seckillId;
  42.     }
  44.     public String getName() {
  45.         return name;
  46.     }
  48.     public void setName(String name) {
  49.         this.name = name;
  50.     }
  52.     public int getNumber() {
  53.         return number;
  54.     }
  56.     public void setNumber(int number) {
  57.         this.number = number;
  58.     }
  60.     public LocalDateTime getStartTime() {
  61.         return startTime;
  62.     }
  64.     public void setStartTime(LocalDateTime startTime) {
  65.         this.startTime = startTime;
  66.     }
  68.     public LocalDateTime getEndTime() {
  69.         return endTime;
  70.     }
  72.     public void setEndTime(LocalDateTime endTime) {
  73.         this.endTime = endTime;
  74.     }
  76.     public LocalDateTime getCreateTIme() {
  77.         return createTIme;
  78.     }
  80.     public void setCreateTIme(LocalDateTime createTIme) {
  81.         this.createTIme = createTIme;
  82.     }
  84.     @Override
  85.     public String toString() {
  86.         return "com.suny.entity.Seckill{" +
  87.                 "主键ID=" + seckillId +
  88.                 ", 秒杀商品='" + name + '\'' +
  89.                 ", 编号=" + number +
  90.                 ", 开始秒杀时间=" + startTime +
  91.                 ", 结束秒杀时间=" + endTime +
  92.                 ", 创建时间=" + createTIme +
  93.                 '}';
  94.     }
  95. }

对实体类创建对应的mapper接口,也就是dao接口类

  • 首先创建SeckillMapper,在我这里位于com.suny.dao包下
    ```java
    package com.suny.dao;

import com.suny.entity.Seckill;
import org.apache.ibatis.annotations.Param;

import java.time.LocalDateTime;
import java.util.List;

public interface SeckillMapper {
/**

  1.  * 根据传过来的<code>seckillId</code>去减少商品的库存.
  2.  *
  3.  * @param seckillId 秒杀商品ID
  4.  * @param killTime  秒杀的精确时间
  5.  * @return 如果秒杀成功就返回1,否则就返回0
  6.  */
  7. int reduceNumber(@Param("seckillId") long seckillId, @Param("killTime") LocalDateTime killTime);
  9. /**
  10.  * 根据传过来的<code>seckillId</code>去查询秒杀商品的详情.
  11.  *
  12.  * @param seckillId 秒杀商品ID
  13.  * @return 对应商品ID的的数据
  14.  */
  15. Seckill queryById(@Param("seckillId") long seckillId);
  17. /**
  18.  * 根据一个偏移量去查询秒杀的商品列表.
  19.  *
  20.  * @param offset 偏移量
  21.  * @param limit  限制查询的数据个数
  22.  * @return 符合偏移量查出来的数据个数
  23.  */
  24. List<Seckill> queryAll(@Param("offset") int offset, @Param("limit") int limit);

}

  1.  - 再创建`SuccessKilledMapper`
  2.  ```java
  3. package com.suny.dao;
  5. import com.suny.entity.SuccessKilled;
  6. import org.apache.ibatis.annotations.Param;
  9. public interface SuccessKilledMapper {
  10.     /**
  11.      * 插入一条详细的购买信息.
  12.      *
  13.      * @param seckillId 秒杀商品的ID
  14.      * @param userPhone 购买用户的手机号码
  15.      * @return 成功插入就返回1, 否则就返回0
  16.      */
  17.     int insertSuccessKilled(@Param("seckillId") long seckillId, @Param("userPhone") long userPhone);
  19.     /**
  20.      * 根据秒杀商品的ID查询<code>SuccessKilled</code>的明细信息.
  21.      *
  22.      * @param seckillId 秒杀商品的ID
  23.      * @param userPhone 购买用户的手机号码
  24.      * @return 秒杀商品的明细信息
  25.      */
  26.     SuccessKilled queryByIdWithSeckill(@Param("seckillId") long seckillId, @Param("userPhone") long userPhone);
  27. }

接下来书写xml配置文件

建立对应的mapper.xml

首先在src/main/resources建立com.suny.dao这个包,也就是对应mapper接口文件包一样的包名,这样符合Maven的约定,就是资源放置在Resource包下,Java包下则是放置java类文件,编译后最后还是会在同一个目录下.
建包

  • 首先建立SeckillMapper.xml
    ```xml
    <!DOCTYPE mapper

    1.   PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
    2.   "http://mybatis.org/dtd/mybatis-3-mapper.dtd">


    UPDATE seckill
    SET number = number - 1
    WHERE seckill_id = #{seckillId}
    AND start_time
    <![CDATA[
    <=
    ]]>
    #{killTime}
    AND end_time >= #{killTime}
    AND number > 0
     
  1. <select id="queryAll" resultType="com.suny.entity.Seckill">
  2.     SELECT
  3.         *
  4.     FROM seckill AS s
  5.     ORDER BY create_time DESC
  6.     LIMIT #{offset}, #{limit}
  7. </select>

  1. - 建立`SuccessKilledMapper.xml`
  2. ```xml
  4. <!DOCTYPE mapper
  5.         PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
  6.         "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
  7. <mapper namespace="com.suny.dao.SuccessKilledMapper">
  8.     <!--添加主键冲突时忽略错误返回0-->  
  9.     <insert id="insertSuccessKilled">
  10.         INSERT IGNORE INTO success_killed (seckill_id, user_phone, state)
  11.         VALUES (#{seckillId}, #{userPhone}, 0)
  12.     </insert>
  13.     <!--根据seckillId查询SuccessKilled对象,并携带Seckill对象,告诉mybatis把映射结果映射到SuccessKill属性同时映射到Seckill属性-->  
  14.     <select id="queryByIdWithSeckill" resultType="com.suny.entity.SuccessKilled">
  15.         SELECT
  16.             sk.seckill_id,
  17.             sk.user_phone,
  18.             sk.create_time,
  19.             sk.state,
  20.             s.seckill_id  "seckill.seckill_id",
  21.             s.name "seckill.name",
  22.             s.number "seckill",
  23.             s.start_time  "seckill.start_time",
  24.             s.end_time  "seckill.end_time",
  25.             s.create_time "seckill.create_time"
  26.         FROM success_killed sk
  27.             INNER JOIN seckill s ON sk.seckill_id = s.seckill_id
  28.         WHERE sk.seckill_id = #{seckillId}
  29.               AND sk.user_phone= #{userPhone}
  30.     </select>
  32. </mapper>
  • 建立Mybatis的配置文件mybatis-config.xml
    1. <?xml version="1.0" encoding="UTF-8" ?>
    2. <!DOCTYPE configuration PUBLIC
    3.       "-//mybatis.org//DTD MyBatis Generator Configuration 3.0//EN"
    4.       "http://mybatis.org/dtd/mybatis-3-config.dtd" >
    5. <configuration>
    6.   <!--首先配置全局属性-->
    7.   <settings>
    8.       <!--开启自动填充主键功能,原理时通过jdbc的一个方法getGeneratekeys获取自增主键值-->
    9.       <setting name="useGeneratedKeys" value="true"></setting>
    10.       <!--使用别名替换列名,默认就是开启的-->
    11.       <setting name="useColumnLabel" value="true"></setting>
    12.       <!--开启驼峰命名的转换-->
    13.       <setting name="mapUnderscoreToCamelCase" value="true"></setting>
    14.   </settings>
    15. </configuration>
  • 然后建立连接数据库的配置文件jdbc.properties,这里的属性要根据自己的需要去进行修改,切勿直接复制使用 
    1. jdbc.driver=com.mysql.jdbc.Driver
    2. jdbc.user=root
    3. jdbc.password=root
    4. jdbc.url=jdbc:mysql://localhost:3306/seckill?useUnicode=true&characterEncoding=utf-8
  • 建立Spring的dao的配置文件,在resources包下创建applicationContext-dao.xml
    ```xml

<?xml version=”1.0” encoding=”UTF-8”?>








































 
  2. - 基础的部分我们搭建完成了,然后要开始测试了
  3.  在`IDEA`里面有一个快速建立测试的快捷键`Ctrl+Shift+T`,在某个要测试的类里面按下这个快捷键就会出现`Create new Test`,然后选择你要测试的方法跟测试的工具就可以了,这里我们使用Junit作为测试
  4.   + 建立`SeckillMapperTest`文件,代码如下
  5.  ```java
  6. package com.suny.dao;
  8. import com.suny.entity.Seckill;
  9. import org.junit.Test;
  10. import org.junit.runner.RunWith;
  11. import org.springframework.test.context.ContextConfiguration;
  12. import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
  14. import javax.annotation.Resource;
  16. import java.time.LocalDateTime;
  17. import java.util.List;
  19. import static org.junit.Assert.*;
  22. @RunWith(SpringJUnit4ClassRunner.class)
  23. @ContextConfiguration({"classpath:spring/applicationContext-dao.xml"})
  24. public class SeckillMapperTest {
  25.     @Resource
  26.     private SeckillMapper seckillMapper;
  28.     @Test
  29.     public void reduceNumber() throws Exception {
  30.         long seckillId=1000;
  31.         LocalDateTime localDateTime=LocalDateTime.now();
  32.         int i = seckillMapper.reduceNumber(seckillId, localDateTime);
  33.         System.out.println(i);
  34.     }
  36.     @Test
  37.     public void queryById() throws Exception {
  38.         long seckillId = 1000;
  39.         Seckill seckill = seckillMapper.queryById(seckillId);
  40.         System.out.println(seckill.toString());
  41.     }
  43.     @Test
  44.     public void queryAll() throws Exception {
  45.         List<Seckill> seckills = seckillMapper.queryAll(0, 100);
  46.         for (Seckill seckill : seckills) {
  47.             System.out.println(seckill.toString());
  48.         }
  49.     }
  51. }

测试中可能会出现Mybatis参数绑定失败的错误,在mapper接口中的方法里面添加@Param的注解,显示的告诉mybatis参数的名称是什么,例如

  1.  List<Seckill> queryAll(@Param("offset") int offset, @Param("limit") int limit);

2016-5-23 13:46：28

(二)Java高并发秒杀API之Service层

首先在编写Service层代码前,我们应该首先要知道这一层到底时干什么的,这里摘取来自ITEYE一位博主的原话

Service层主要负责业务模块的逻辑应用设计。同样是首先设计接口,再设计其实现的类,接着再Spring的配置文件中配置其实现的关联。这样我们就可以在应用中调用Service接口来进行业务处理。Service层的业务实现,具体要调用到已定义的DAO层的接口,封装Service层的业务逻辑有利于通用的业务逻辑的独立性和重复利用性,程序显得非常简洁。

在项目中要降低耦合的话,分层是一种很好的概念,就是各层各司其职,尽量不做不相干的事,所以Service层的话顾名思义就是业务逻辑,处理程序中的一些业务逻辑,以及调用DAO层的代码,这里我们的DAo层就是连接数据库的那一层,调用关系可以这样表达:
View(页面)>Controller(控制层)>Service(业务逻辑)>Dao(数据访问)>Database(数据库)

  • 首先还是接口的设计,设计Service秒杀商品的接口 SeckillService
    首先在som.suny包下建立interfaces这个包,这个包里面存放Service相关的接口,然后建立SeckillService接口文件,代码如下:
    ```java

public interface SeckillService {

  1. /**
  2.  *  查询全部的秒杀记录.
  3.  * @return 数据库中所有的秒杀记录
  4.  */
  5. List<Seckill> getSeckillList();
  7. /**
  8.  *   查询单个秒杀记录
  9.  * @param seckillId   秒杀记录的ID
  10.  * @return   根据ID查询出来的记录信息
  11.  */
  12. Seckill getById(long seckillId);
  14. /**
  15.  * 在秒杀开启时输出秒杀接口的地址,否则输出系统时间跟秒杀地址
  16.  * @param seckillId  秒杀商品Id
  17.  * @return  根据对应的状态返回对应的状态实体
  18.  */
  19. Exposer exportSeckillUrl(long seckillId);
  21. /**
  22.  * 执行秒杀操作,有可能是失败的,失败我们就抛出异常
  23.  * @param seckillId  秒杀的商品ID
  24.  * @param userPhone 手机号码
  25.  * @param md5   md5加密值
  26.  * @return   根据不同的结果返回不同的实体信息
  27.  */
  28. SeckillExecution executeSeckill(long seckillId,long userPhone,String md5)throws SeckillException,RepeatKillException,SeckillCloseException;
  1. 建立后接口之后我们要写实现类了,在写实现类的时候我们肯定会碰到一个这样的问题,你要向前端返回`json`数据的话,你是返回什么样的数据好?直接返回一个数字状态码或者时文字?这样设计肯定是不好的,所以我们应该向前段返回一个实体信息`json`,里面包含了一系列的信息,无论是哪种状态都应该可以应对,既然是与数据库字段无关的类,那就不是`PO`了,所以我们建立一个`DTO`数据传输类,关于常见的几种对象我的解释如下:
  2.  + PO:   也就是我们在为每一张数据库表写一个实体的类
  3.  + VO,   对某个页面或者展现层所需要的数据,封装成一个实体类
  4.  + BO,   就是业务对象,我也不是很了解
  5.  + DTO,  跟VO的概念有点混淆,也是相当于页面需要的数据封装成一个实体类
  6.  + POJO, 简单的无规则java对象
  8.  在`com.suny`下建立`dto`包,然后建立`Exposer`类,这个类是秒杀时数据库那边处理的结果的对象
  9.   ```java
  10. public class Exposer {
  11.     /*是否开启秒杀 */
  12.     private boolean exposed;
  13.     /*  对秒杀地址进行加密措施  */
  14.     private String md5;
  15.     /* id为seckillId的商品秒杀地址   */
  16.     private long seckillId;
  17.     /* 系统当前的时间   */
  18.     private LocalDateTime now;
  19.     /* 秒杀开启的时间   */
  20.     private LocalDateTime start;
  21.     /*  秒杀结束的时间  */
  22.     private LocalDateTime end;
  24.     public Exposer() {
  25.     }
  27.     public Exposer(boolean exposed, String md5, long seckillId) {
  28.         this.exposed = exposed;
  29.         this.md5 = md5;
  30.         this.seckillId = seckillId;
  31.     }
  33.     public Exposer(boolean exposed, long seckillId, LocalDateTime now, LocalDateTime start, LocalDateTime end) {
  34.         this.exposed = exposed;
  35.         this.seckillId = seckillId;
  36.         this.now = now;
  37.         this.start = start;
  38.         this.end = end;
  39.     }
  41.     public Exposer(boolean exposed, long seckillId) {
  42.         this.exposed = exposed;
  43.         this.seckillId = seckillId;
  44.     }
  46.     public boolean isExposed() {
  47.         return exposed;
  48.     }
  50.     public void setExposed(boolean exposed) {
  51.         this.exposed = exposed;
  52.     }
  54.     public String getMd5() {
  55.         return md5;
  56.     }
  58.     public void setMd5(String md5) {
  59.         this.md5 = md5;
  60.     }
  62.     public long getSeckillId() {
  63.         return seckillId;
  64.     }
  66.     public void setSeckillId(long seckillId) {
  67.         this.seckillId = seckillId;
  68.     }
  70.     public LocalDateTime getNow() {
  71.         return now;
  72.     }
  74.     public void setNow(LocalDateTime now) {
  75.         this.now = now;
  76.     }
  78.     public LocalDateTime getStart() {
  79.         return start;
  80.     }
  82.     public void setStart(LocalDateTime start) {
  83.         this.start = start;
  84.     }
  86.     public LocalDateTime getEnd() {
  87.         return end;
  88.     }
  90.     public void setEnd(LocalDateTime end) {
  91.         this.end = end;
  92.     }
  94.     @Override
  95.     public String toString() {
  96.         return "Exposer{" +
  97.                 "秒杀状态=" + exposed +
  98.                 ", md5加密值='" + md5 + '\'' +
  99.                 ", 秒杀ID=" + seckillId +
  100.                 ", 当前时间=" + now +
  101.                 ", 开始时间=" + start +
  102.                 ", 结束=" + end +
  103.                 '}';
  104.     }
  105. }

然后我们给页面返回的数据应该是更加友好的封装数据,所以我们再在com.suny.dto包下再建立SeckillExecution用来封装给页面的结果:

  1. public class SeckillExecution {
  3.     private long seckillId;
  4.     /* 执行秒杀结果的状态   */
  5.     private int state;
  6.     /* 状态的明文标示   */
  7.     private String stateInfo;
  8.     /*  当秒杀成功时,需要传递秒杀结果的对象回去  */
  9.     private SuccessKilled successKilled;
  11.     /*  秒杀成功返回的实体  */
  12.     public SeckillExecution(long seckillId, int state, String stateInfo, SuccessKilled successKilled) {
  13.         this.seckillId = seckillId;
  14.         this.state = state;
  15.         this.stateInfo = stateInfo;
  16.         this.successKilled = successKilled;
  17.     }
  19.     /*  秒杀失败返回的实体  */
  20.     public SeckillExecution(long seckillId, int state, String stateInfo) {
  21.         this.seckillId = seckillId;
  22.         this.state = state;
  23.         this.stateInfo = stateInfo;
  24.     }
  26.     public long getSeckillId() {
  27.         return seckillId;
  28.     }
  30.     public void setSeckillId(long seckillId) {
  31.         this.seckillId = seckillId;
  32.     }
  34.     public int getState() {
  35.         return state;
  36.     }
  38.     public void setState(int state) {
  39.         this.state = state;
  40.     }
  42.     public String getStateInfo() {
  43.         return stateInfo;
  44.     }
  46.     public void setStateInfo(String stateInfo) {
  47.         this.stateInfo = stateInfo;
  48.     }
  50.     public SuccessKilled getSuccessKilled() {
  51.         return successKilled;
  52.     }
  54.     public void setSuccessKilled(SuccessKilled successKilled) {
  55.         this.successKilled = successKilled;
  56.     }
  58.     @Override
  59.     public String toString() {
  60.         return "SeckillExecution{" +
  61.                 "秒杀的商品ID=" + seckillId +
  62.                 ", 秒杀状态=" + state +
  63.                 ", 秒杀状态信息='" + stateInfo + '\'' +
  64.                 ", 秒杀的商品=" + successKilled +
  65.                 '}';
  66.     }
  67. }
定义秒杀中可能会出现的异常

  • 定义一个基础的异常,所有的子异常继承这个异常SeckillException

    1. /**
    2. *  秒杀基础异常
    3. * Created by 孙建荣 on 17-5-23.下午8:24
    4. */
    5. public class SeckillException extends RuntimeException {
    6. public SeckillException(String message) {
    7.     super(message);
    8. }
    10. public SeckillException(String message, Throwable cause) {
    11.     super(message, cause);
    12. }
    13. }
    • 首选可能会出现秒杀关闭后被秒杀情况,所以建立秒杀关闭异常SeckillCloseException,需要继承我们一开始写的基础异常
      ```java
      /**
    • 秒杀已经关闭异常,当秒杀结束就会出现这个异常
    • Created by 孙建荣 on 17-5-23.下午8:27
      */
      public class SeckillCloseException extends SeckillException{
      public SeckillCloseException(String message) {
      super(message);
      }

    public SeckillCloseException(String message, Throwable cause) {

    1. super(message, cause);

    }
    }
    ```

    • 然后还有可能发生重复秒杀异常RepeatKillException
      ```java

/**

  • 重复秒杀异常,不需要我们手动去try catch

  • Created by 孙建荣 on 17-5-23.下午8:26
    */
    public class RepeatKillException extends SeckillException{
    public RepeatKillException(String message) {

    1.  super(message);

    }

    public RepeatKillException(String message, Throwable cause) {

    1.  super(message, cause);

    }
    }
    ```

    实现Service接口

    ```java
    /**

  • Created by 孙建荣 on 17-5-23.下午9:30
    /
    @Service
    public class SeckillServiceImpl implements SeckillService {
    private Logger logger = LoggerFactory.getLogger(this.getClass());
    /     加入一个盐值,用于混淆*/
    private final String salt = “thisIsASaltValue”;

    @Autowired
    private SeckillMapper seckillMapper;
    @Autowired
    private SuccessKilledMapper successKilledMapper;

  1. /**
  2.  * 查询全部的秒杀记录.
  3.  *
  4.  * @return 数据库中所有的秒杀记录
  5.  */
  6. @Override
  7. public List<Seckill> getSeckillList() {
  8.     return seckillMapper.queryAll(0, 4);
  9. }
  11. /**
  12.  * 查询单个秒杀记录
  13.  *
  14.  * @param seckillId 秒杀记录的ID
  15.  * @return 根据ID查询出来的记录信息
  16.  */
  17. @Override
  18. public Seckill getById(long seckillId) {
  19.     return seckillMapper.queryById(seckillId);
  20. }
  22. /**
  23.  * 在秒杀开启时输出秒杀接口的地址,否则输出系统时间跟秒杀地址
  24.  *
  25.  * @param seckillId 秒杀商品Id
  26.  * @return 根据对应的状态返回对应的状态实体
  27.  */
  28. @Override
  29. public Exposer exportSeckillUrl(long seckillId) {
  30.     // 根据秒杀的ID去查询是否存在这个商品
  31.    /* Seckill seckill = seckillMapper.queryById(seckillId);
  32.     if (seckill == null) {
  33.         logger.warn("查询不到这个秒杀产品的记录");
  34.         return new Exposer(false, seckillId);
  35.     }*/
  36.     Seckill seckill = redisDao.getSeckill(seckillId);
  37.     if (seckill == null) {
  38.         // 访问数据库读取数据
  39.         seckill = seckillMapper.queryById(seckillId);
  40.         if (seckill == null) {
  41.             return new Exposer(false, seckillId);
  42.         } else {
  43.             // 放入redis
  44.             redisDao.putSeckill(seckill);
  45.         }
  46.     }
  48.     // 判断是否还没到秒杀时间或者是过了秒杀时间
  49.     LocalDateTime startTime = seckill.getStartTime();
  50.     LocalDateTime endTime = seckill.getEndTime();
  51.     LocalDateTime nowTime = LocalDateTime.now();
  52.     //   开始时间大于现在的时候说明没有开始秒杀活动    秒杀活动结束时间小于现在的时间说明秒杀已经结束了
  53.    /* if (!nowTime.isAfter(startTime)) {
  54.         logger.info("现在的时间不在开始时间后面,未开启秒杀");
  55.         return new Exposer(false, seckillId, nowTime, startTime, endTime);
  56.     }
  57.     if (!nowTime.isBefore(endTime)) {
  58.         logger.info("现在的时间不在结束的时间之前,可以进行秒杀");
  59.         return new Exposer(false, seckillId, nowTime, startTime, endTime);
  60.     }*/
  61.     if (nowTime.isAfter(startTime) && nowTime.isBefore(endTime)) {
  62.         //秒杀开启,返回秒杀商品的id,用给接口加密的md5
  63.         String md5 = getMd5(seckillId);
  64.         return new Exposer(true, md5, seckillId);
  65.     }
  66.     return new Exposer(false, seckillId, nowTime, startTime, endTime);
  69. }
  71. private String getMd5(long seckillId) {
  72.     String base = seckillId + "/" + salt;
  73.     return DigestUtils.md5DigestAsHex(base.getBytes());
  74. }
  76. /**
  77.  * 执行秒杀操作,失败的,失败我们就抛出异常
  78.  *
  79.  * @param seckillId 秒杀的商品ID
  80.  * @param userPhone 手机号码
  81.  * @param md5       md5加密值
  82.  * @return 根据不同的结果返回不同的实体信息
  83.  */
  84. @Override
  85. public SeckillExecution executeSeckill(long seckillId, long userPhone, String md5) throws SeckillException {
  86.     if (md5 == null || !md5.equals(getMd5(seckillId))) {
  87.         logger.error("秒杀数据被篡改");
  88.         throw new SeckillException("seckill data rewrite");
  89.     }
  90.     // 执行秒杀业务逻辑
  91.     LocalDateTime nowTIme = LocalDateTime.now();
  93.     try {
  94.         //执行减库存操作
  95.         int reduceNumber = seckillMapper.reduceNumber(seckillId, nowTIme);
  96.         if (reduceNumber <= 0) {
  97.             logger.warn("没有更新数据库记录,说明秒杀结束");
  98.             throw new SeckillCloseException("seckill is closed");
  99.         } else {
  100.             // 这里至少减少的数量不为0了,秒杀成功了就增加一个秒杀成功详细
  101.             int insertCount = successKilledMapper.insertSuccessKilled(seckillId, userPhone);
  102.             // 查看是否被重复插入,即用户是否重复秒杀
  103.             if (insertCount <= 0) {
  104.                 throw new RepeatKillException("seckill repeated");
  105.             } else {
  106.                 // 秒杀成功了,返回那条插入成功秒杀的信息
  107.                 SuccessKilled successKilled = successKilledMapper.queryByIdWithSeckill(seckillId, userPhone);

// return new SeckillExecution(seckillId,1,”秒杀成功”);
return new SeckillExecution(seckillId,1,”秒杀成功”,successKilled);
}
}
} catch (SeckillCloseException | RepeatKillException e1) {
throw e1;
} catch (Exception e) {
logger.error(e.getMessage(), e);
// 把编译期异常转换为运行时异常
throw new SeckillException(“seckill inner error : “ + e.getMessage());
}
}

  1. 在这里我们捕获了运行时异常,这样做的原因就是`Spring`的事物默认就是发生了`RuntimeException`才会回滚,可以检测出来的异常是不会导致事物的回滚的,这样的目的就是你明知道这里会发生异常,所以你一定要进行处理.如果只是为了让编译通过的话,那捕获异常也没多意思,所以这里要注意事物的回滚.  
  2. 然后我们还发现这里存在硬编码的现象,就是返回各种字符常量,例如`秒杀成功`,`秒杀失败`等等,这些字符串时可以被重复使用的,而且这样维护起来也不方便,要到处去类里面寻找这样的字符串,所有我们使用枚举类来管理这样状态,在`con.suny`包下建立`enum`包,专门放置枚举类,然后再建立`SeckillStatEnum`枚举类:
  3. ```java
  4. /**
  5.  * 常量枚举类
  6.  * Created by 孙建荣 on 17-5-23.下午10:15
  7.  */
  8. public enum SeckillStatEnum {
  9.     SUCCESS(1, "秒杀成功"),
  10.     END(0, "秒杀结束"),
  11.     REPEAT_KILL(-1, "重复秒杀"),
  12.     INNER_ERROR(-2, "系统异常"),
  13.     DATE_REWRITE(-3, "数据篡改");
  15.     private int state;
  16.     private String info;
  18.     SeckillStatEnum() {
  19.     }
  21.     SeckillStatEnum(int state, String info) {
  22.         this.state = state;
  23.         this.info = info;
  24.     }
  26.     public int getState() {
  27.         return state;
  28.     }
  30.     public String getInfo() {
  31.         return info;
  32.     }
  34.     public static SeckillStatEnum stateOf(int index) {
  35.         for (SeckillStatEnum statEnum : values()) {
  36.             if (statEnum.getState() == index) {
  37.                 return statEnum;
  38.             }
  39.         }
  40.         return null;
  41.     }
  42. }

既然把这些改成了枚举,那么在SeckillServiceImpl类中的executeSeckill方法中成功秒杀的返回值就应该修改为 

  1. return new SeckillExecution(seckillId, SeckillStatEnum.SUCCESS, successKilled);

改了这里以后会发现会报错,因为在实体类那边构造函数可不是这样的,然后修改SeckillExecution类的构造函数,把state跟stateInfo的值设置从构造函数里面的SeckillStatEnum中取出值来设置：

  2. /*  秒杀成功返回的实体  */
  3.     public SeckillExecution(long seckillId, SeckillStatEnum statEnum, SuccessKilled successKilled) {
  4.         this.seckillId = seckillId;
  5.         this.state = statEnum.getState();
  6.         this.stateInfo = statEnum.getInfo();
  7.         this.successKilled = successKilled;
  8.     }
  10.     /*  秒杀失败返回的实体  */
  11.     public SeckillExecution(long seckillId, SeckillStatEnum statEnum) {
  12.         this.seckillId = seckillId;
  13.         this.state = statEnum.getState();
  14.         this.stateInfo = statEnum.getInfo();
  15.     }

下一步肯定要注入Service了

首先在resources/spring下建立applicationContext-service.xml文件,用来配置Service层的相关代码:

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <beans xmlns="http://www.springframework.org/schema/beans"
  3.        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4.        xmlns:context="http://www.springframework.org/schema/context" xmlns:tx="http://www.springframework.org/schema/tx"
  5.        xsi:schemaLocation="http://www.springframework.org/schema/beans
  6.         http://www.springframework.org/schema/beans/spring-beans.xsd
  7.         http://www.springframework.org/schema/context
  8.         http://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd">
  10.     <!--配置自动扫描service包下的注解,在这里配置了自动扫描后,com.suny.service包下所有带有@Service注解的类都会被加入Spring容器中-->
  11.     <context:component-scan base-package="com.suny.service"></context:component-scan>
  13.     <!--配置事物,这里时使用基于注解的事物-->
  14.     <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
  15.         <!--注入数据库连接池-->
  16.         <property name="dataSource" ref="dataSource"></property>
  17.     </bean>
  19.     <!--开启基于注解的申明式事物-->
  20.     <tx:annotation-driven transaction-manager="transactionManager"></tx:annotation-driven>
  22. </beans>

在这里开启了基于注解的事物,常见的事物操作有以下几种方法

  • 在Spring早期版本中是使用ProxyFactoryBean+XMl方式来配置事物.
  • 在Spring配置文件使用tx:advice+aop命名空间,好处就是一次配置永久生效,你无须去关心中间出的问题,不过出错了你很难找出来在哪里出了问题
  • 注解@Transactional的方式,注解可以在方法定义,接口定义,类定义,public方法上,但是不能注解在private,final,static等方法上,因为Spring的事物管理默认是使用Cglib动态代理的:
    • private方法因为访问权限限制,无法被子类覆盖
    • final方法无法被子类覆盖
    • static时类级别的方法,无法被子类覆盖
    • protected方法可以被子类覆盖,因此可以被动态字节码增强
      不能被Spring AOP事物增强的方法
      | 序号 | 动态代理策略 |不能被事物增强的方法 |
      |:——-:| :——-: |:——-:|
      | 1 |基于接口的动态代理 |出了public以外的所有方法,并且 public static 的方法也不能被增强 |
      | 2 |基于Cglib的动态代理 | private,static,final的方法 |

然后你要在Service类上添加注解@Service,不用在接口上添加注解：

  2. @Service
  3. public class SeckillServiceImpl implements SeckillService

既然已经开启了基于注解的事物,那我们就去需要被事物的方法上加个注解@Transactional吧:

  1. @Transactional
  2.     @Override
  3.     public SeckillExecution executeSeckill(long seckillId, long userPhone, String md5) throws SeckillException

Service层的测试

写测试类,我这里的测试类名为SeckillServiceImplTest:

  1. /**
  2.  * Created by 孙建荣 on 17-5-23.下午10:30
  3.  */
  4. @RunWith(SpringJUnit4ClassRunner.class)
  5. @ContextConfiguration({"classpath:spring/applicationContext-dao.xml", "classpath:spring/applicationContext-service.xml"})
  6. public class SeckillServiceImplTest {
  7.     private Logger logger = LoggerFactory.getLogger(this.getClass());
  9.     @Autowired
  10.     private SeckillService seckillService;
  12.     @Test
  13.     public void getSeckillList() throws Exception {
  14.         List<Seckill> seckillList = seckillService.getSeckillList();
  15.         logger.info(seckillList.toString());
  16.         System.out.println(seckillList.toString());
  17.     }
  19.     @Test
  20.     public void getById() throws Exception {
  21.         long seckillId = 1000;
  22.         Seckill byId = seckillService.getById(seckillId);
  23.         System.out.println(byId.toString());
  24.     }
  26.     @Test
  27.     public void exportSeckillUrl() throws Exception {
  28.         long seckillId = 1000;
  29.         Exposer exposer = seckillService.exportSeckillUrl(seckillId);
  30.         System.out.println(exposer.toString());
  31.     }
  33.     @Test
  34.     public void executeSeckill() throws Exception {
  35.         long seckillId = 1000;
  36.         Exposer exposer = seckillService.exportSeckillUrl(seckillId);
  37.         if (exposer.isExposed()) {
  38.             long userPhone = 12222222222L;
  39.             String md5 = "bf204e2683e7452aa7db1a50b5713bae";
  40.             try {
  41.                 SeckillExecution seckillExecution = seckillService.executeSeckill(seckillId, userPhone, md5);
  42.                 System.out.println(seckillExecution.toString());
  43.             } catch (SeckillCloseException | RepeatKillException e) {
  44.                 e.printStackTrace();
  45.             }
  46.         } else {
  47.             System.out.println("秒杀未开启");
  48.         }
  49.     }
  51.     @Test
  52.     public void executeSeckillProcedureTest() {
  53.         long seckillId = 1001;
  54.         long phone = 1368011101;
  55.         Exposer exposer = seckillService.exportSeckillUrl(seckillId);
  56.         if (exposer.isExposed()) {
  57.             String md5 = exposer.getMd5();
  58.             SeckillExecution execution = seckillService.executeSeckillProcedure(seckillId, phone, md5);
  59.             System.out.println(execution.getStateInfo());
  60.         }
  61.     }
  64. }

测试的话如果每个方法测试都通过就说明通过,如果报错了话就仔细看下哪一步错了检查下

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

既然是Web层的会肯定要先引入SpringMvc了

  • 修改web.xml,引入SpringMvc的DispatcherServlet：

    1. <web-app xmlns="http://java.sun.com/xml/ns/javaee"
    2.        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    3.        xsi:schemaLocation="http://java.sun.com/xml/ns/javaee
    4.                     http://java.sun.com/xml/ns/javaee/web-app_3_0.xsd"
    5.        version="3.0"
    6.        metadata-complete="true">
    7.   <!--用maven创建的web-app需要修改servlet的版本为3.0-->
    9.   <servlet>
    10.       <servlet-name>seckill-dispatchServlet</servlet-name>
    11.       <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
    12.       <!--配置springmvc的配置文件-->
    13.       <init-param>
    14.           <param-name>contextConfigLocation</param-name>
    15.           <param-value>classpath:spring/applicationContext-*.xml</param-value>
    16.       </init-param>
    17.       <load-on-startup>
    18.           1
    19.       </load-on-startup>
    20.   </servlet>
    21.   <servlet-mapping>
    22.       <servlet-name>seckill-dispatchServlet</servlet-name>
    23.       <!--直接拦截所有请求,不再采用spring2.0的/*或者*.do方式-->
    24.       <url-pattern>/</url-pattern>
    25.   </servlet-mapping>
    26. </web-app>

    在这里的话如果你不配置这一段代码的：

    1. <!--配置springmvc的配置文件-->
    2.       <init-param>
    3.           <param-name>contextConfigLocation</param-name>
    4.           <param-value>classpath:spring/applicationContext-*.xml</param-value>
    5.       </init-param>

    SpringMvc默认就会默认去WEB-INF下查找默认规范的配置文件,像我这里配置的servlet-name是seckill-dispatchServlet的话,则默认会寻找WEB-INF一个名为seckill-dispatchServlet-Servlet.xml的配置文件

接下来编写Controller SeckillController

首先在com.suny下建立包为Controller的包,然后在里面新建一个类SeckillController：

  1. package com.suny.controller;
  3. /**
  4.  * Created by 孙建荣 on 17-5-24.下午10:11
  5.  */
  6. @Controller
  7. @RequestMapping("/seckill")
  8. public class SeckillController {
  9.     private final SeckillService seckillService;
  11.     @Autowired
  12.     public SeckillController(SeckillService seckillService) {
  13.         this.seckillService = seckillService;
  14.     }
  16.     /**
  17.      * 进入秒杀列表.
  18.      *
  19.      * @param model 模型数据,里面放置有秒杀商品的信息
  20.      * @return 秒杀列表详情页面
  21.      */
  22.     @RequestMapping(value = {"/list","","index"}, method = RequestMethod.GET)
  23.     public String list(Model model) {
  24.         List<Seckill> seckillList = seckillService.getSeckillList();
  25.         model.addAttribute("list", seckillList);
  26.         return "list";
  27.     }
  29.     @RequestMapping(value = "/{seckillId}/detail", method = RequestMethod.GET)
  30.     public String detail(@PathVariable("seckillId") Long seckillId, Model model) {
  31.         if (seckillId == null) {
  32.             return "redirect:/seckill/list";
  33.         }
  34.         Seckill seckill = seckillService.getById(seckillId);
  35.         if (seckill == null) {
  36.             return "forward:/seckill/list";
  37.         }
  38.         model.addAttribute("seckill", seckill);
  39.         return "detail";
  40.     }
  42.     /**
  43.      * 暴露秒杀接口的方法.
  44.      *
  45.      * @param seckillId 秒杀商品的id
  46.      * @return 根据用户秒杀的商品id进行业务逻辑判断,返回不同的json实体结果
  47.      */
  48.     @RequestMapping(value = "/{seckillId}/exposer", method = RequestMethod.GET)
  49.     @ResponseBody
  50.     public SeckillResult<Exposer> exposer(@PathVariable("seckillId") Long seckillId) {
  51.         // 查询秒杀商品的结果
  52.         SeckillResult<Exposer> result;
  53.         try {
  54.             Exposer exposer = seckillService.exportSeckillUrl(seckillId);
  55.             result = new SeckillResult<>(true, exposer);
  56.         } catch (Exception e) {
  57.             e.printStackTrace();
  58.             result = new SeckillResult<>(false, e.getMessage());
  59.         }
  60.         return result;
  61.     }
  63.     /**
  64.      * 用户执行秒杀,在页面点击相应的秒杀连接,进入后获取对应的参数进行判断,返回相对应的json实体结果,前端再进行处理.
  65.      *
  66.      * @param seckillId 秒杀的商品,对应的时秒杀的id
  67.      * @param md5       一个被混淆的md5加密值
  68.      * @param userPhone 参与秒杀用户的额手机号码,当做账号密码使用
  69.      * @return 参与秒杀的结果,为json数据
  70.      */
  71.     @RequestMapping(value = "/{seckillId}/{md5}/execution", method = RequestMethod.POST)
  72.     @ResponseBody
  73.     public SeckillResult<SeckillExecution> execute(@PathVariable("seckillId") long seckillId,
  74.                                                    @PathVariable("md5") String md5,
  75.                                                    @CookieValue(value = "userPhone", required = false) Long userPhone) {
  76.         // 如果用户的手机号码为空的说明没有填写手机号码进行秒杀
  77.         if (userPhone == null) {
  78.             return new SeckillResult<>(false, "没有注册");
  79.         }
  80.         // 根据用户的手机号码,秒杀商品的id跟md5进行秒杀商品,没异常就是秒杀成功
  81.         try {
  82.             // 这里换成储存过程
  83.  SeckillExecution execution = seckillService.executeSeckill(seckillId, userPhone, md5);
  84.             return new SeckillResult<>(true, execution);
  85.         } catch (RepeatKillException e1) {
  86.             // 重复秒杀
  87.             SeckillExecution execution = new SeckillExecution(seckillId, SeckillStatEnum.REPEAT_KILL);
  88.             return new SeckillResult<>(false, execution);
  89.         } catch (SeckillCloseException e2) {
  90.             // 秒杀关闭
  91.             SeckillExecution execution = new SeckillExecution(seckillId, SeckillStatEnum.END);
  92.             return new SeckillResult<>(false, execution);
  93.         } catch (SeckillException e) {
  94.             // 不能判断的异常
  95.             SeckillExecution execution = new SeckillExecution(seckillId, SeckillStatEnum.INNER_ERROR);
  96.             return new SeckillResult<>(false, execution);
  97.         }
  98.         // 如果有异常就是秒杀失败
  99.     }
  101.     /**
  102.      * 获取服务器端时间,防止用户篡改客户端时间提前参与秒杀
  103.      *
  104.      * @return 时间的json数据
  105.      */
  106.     @RequestMapping(value = "/time/now", method = RequestMethod.GET)
  107.     @ResponseBody
  108.     public SeckillResult<LocalDateTime> time() {
  109.         LocalDateTime localDateTime = LocalDateTime.now();
  110.         return new SeckillResult<>(true, localDateTime);
  111.     }
  114. }

建立一个全局ajax请求返回类,返回json类型

SeckillResult:

  1. package com.suny.dto;
  3. /**
  4.  * 封装所有的ajax请求返回类型,方便返回json
  5.  * Created by 孙建荣 on 17-5-24.下午10:18
  6.  */
  7. public class SeckillResult<T> {
  9.     private boolean success;
  11.     private T data;
  13.     private String error;
  15.     public SeckillResult() {
  16.     }
  18.     public SeckillResult(boolean success, T data) {
  19.         this.success = success;
  20.         this.data = data;
  21.     }
  23.     public SeckillResult(boolean success, String error) {
  24.         this.success = success;
  25.         this.error = error;
  26.     }
  28.     public boolean isSuccess() {
  29.         return success;
  30.     }
  32.     public void setSuccess(boolean success) {
  33.         this.success = success;
  34.     }
  36.     public T getData() {
  37.         return data;
  38.     }
  40.     public void setData(T data) {
  41.         this.data = data;
  42.     }
  44.     public String getError() {
  45.         return error;
  46.     }
  48.     public void setError(String error) {
  49.         this.error = error;
  50.     }
  52.     @Override
  53.     public String toString() {
  54.         return "SeckillResult{" +
  55.                 "状态=" + success +
  56.                 ", 数据=" + data +
  57.                 ", 错误消息='" + error + '\'' +
  58.                 '}';
  59.     }
  60. }

页面的编写

因为项目的前端页面都是由Bootstrap开发的,所以我们要先去下载Bootstrap或者是使用在线的CDN.
-Bootstrap中文官网
-Bootstrap中文文档
使用在线CDN引入的方法:

  1. <!-- 最新版本的 Bootstrap 核心 CSS 文件 -->
  2. <link rel="stylesheet" href="https://cdn.bootcss.com/bootstrap/3.3.7/css/bootstrap.min.css" integrity="sha384-BVYiiSIFeK1dGmJRAkycuHAHRg32OmUcww7on3RYdg4Va+PmSTsz/K68vbdEjh4u" crossorigin="anonymous">
  4. <!-- 可选的 Bootstrap 主题文件（一般不用引入） -->
  5. <link rel="stylesheet" href="https://cdn.bootcss.com/bootstrap/3.3.7/css/bootstrap-theme.min.css" integrity="sha384-rHyoN1iRsVXV4nD0JutlnGaslCJuC7uwjduW9SVrLvRYooPp2bWYgmgJQIXwl/Sp" crossorigin="anonymous">
  7. <!-- 最新的 Bootstrap 核心 JavaScript 文件 -->
  8. <script src="https://cdn.bootcss.com/bootstrap/3.3.7/js/bootstrap.min.js" integrity="sha384-Tc5IQib027qvyjSMfHjOMaLkfuWVxZxUPnCJA7l2mCWNIpG9mGCD8wGNIcPD7Txa" crossorigin="anonymous"></script>

文档里面写的很详细,然后我这里是使用离线版本的,方便我们本地调试,避免出现什么别的因素干扰我们:

  • 首先下载JQuery,因为Bootstrap就是依赖JQuery的
  • 然后下载Bootstrap

  • 然后下载一个倒计时插件jquery.countdown.min.js
    -再下载一个操作Cookie插件jquery.cookie.min.js
    如图放置:
    资源图

  • 首先编写一个公共的头部jsp文件,位于WEB-INF下common中的head.jsp

    1. <meta name="viewport" content="width=device-width, initial-scale=1.0">
    2. <meta charset="utf-8">
    3. <link rel="stylesheet" href="${pageContext.request.contextPath}/resources/plugins/bootstrap-3.3.0/css/bootstrap.min.css" type="text/css">
    4. <link rel="stylesheet" href="${pageContext.request.contextPath}/resources/plugins/bootstrap-3.3.0/css/bootstrap-theme.min.css" type="text/css">
  • 然后编写一个公共的jstl标签库文件,位于WEB-INF下common中的tag.jsp
    1. <%@taglib prefix="c" uri="http://java.sun.com/jsp/jstl/core" %>
    2. <%@ taglib prefix="fmt" uri="http://java.sun.com/jsp/jstl/fmt" %>
    3. <%@ taglib prefix="fn" uri="http://java.sun.com/jsp/jstl/functions" %>

  • 编写列表页面,位于WEB-INF下common中的list.jsp

    1. <%@page contentType="text/html; charset=UTF-8" language="java" %>
    2. <%@include file="common/tag.jsp" %>
    3. <!DOCTYPE html>
    4. <html lang="zh-CN">
    5. <head>
    6.   <title>秒杀列表</title>
    7.   <%@include file="common/head.jsp" %>
    8. </head>
    9. <body>
    11. <div class="container">
    12.   <div class="panel panel-default">
    13.       <div class="panel-heading text-center">
    14.           <h2>秒杀列表</h2>
    15.       </div>
    17.       <div class="panel-body">
    18.           <table class="table table-hover">
    19.               <thead>
    20.               <tr>
    21.                   <td>名称</td>
    22.                   <td>库存</td>
    23.                   <td>开始时间</td>
    24.                   <td>结束时间</td>
    25.                   <td>创建时间</td>
    26.                   <td>详情页</td>
    27.               </tr>
    28.               </thead>
    29.               <tbody>
    30.               <c:forEach items="${list}" var="sk">
    31.                   <tr>
    32.                       <td>${sk.name}</td>
    33.                       <td>${sk.number}</td>
    34.                       <td><fmt:formatDate value="${sk.startTime}" pattern="yyyy-MM-dd HH:mm:ss"></fmt:formatDate></td>
    35.                                                <td><fmt:formatDate value="${sk.endTime}" pattern="yyyy-MM-dd HH:mm:ss"></fmt:formatDate></td>
    36.                                                <td><fmt:formatDate value="${sk.createTIme}" pattern="yyyy-MM-dd HH:mm:ss"></fmt:formatDate></td>
    37.                       <td><a class="btn btn-info" href="/seckill/${sk.seckillId}/detail" target="_blank">详情</a></td>
    38.                   </tr>
    39.               </c:forEach>
    40.               </tbody>
    41.           </table>
    42.       </div>
    43.   </div>
    44. </div>
    45. </body>
    46. <script src="${pageContext.request.contextPath}/resources/plugins/jquery.js"></script>
    47. <script src="${pageContext.request.contextPath}/resources/plugins/bootstrap-3.3.0/js/bootstrap.min.js"></script>
    48. </html>
    50. `
    • 编写列表页面,位于WEB-INF下common中的detail.jsp,秒杀详情页面
      ```jsp
      <%—
      Created by IntelliJ IDEA.
      User: jianrongsun
      Date: 17-5-25
      Time: 下午5:03
      To change this template use File | Settings | File Templates.
      —%>
      <%@ page contentType=”text/html;charset=UTF-8” language=”java” %>
      <%@include file=”common/tag.jsp” %>


      秒杀商品详情页面
      <%@include file=”common/head.jsp” %>




      ${seckill.name}