1. 程式人生 > >【JAVA高併發秒殺API之DAO層】課程筆記

【JAVA高併發秒殺API之DAO層】課程筆記

最近在慕課網上學習了【JAVA高併發秒殺API】系列課程,在此整理課程內容!

課程收穫:1、學習瞭如何通過maven建立web專案,pom.xml 檔案依賴管理。

                   2、學習如何整合spring+mybatis

                   3、學習了相關配置檔案的書寫。

一、使用maven建立web專案

建立過程省略。。。

建立完畢,目錄結構如下:


相關說明:src/main/java下面放 java程式碼

                  src/main/resources下面放 配置檔案等。

                  src/test/是相關 單元測試的檔案。

                  可以新建一個src/test/sql/  下面存放 建立資料庫和表格的SQL原始碼

首先需要修改web.xml中的servlet版本:

                  version="3.0"                   metadata-complete="true">         <!-- 修改servlet版本 -->   </web-app>

建立完畢之後需要填寫pom.xml檔案,常用的依賴包已經配置在pom.xml之中,具體如下:

  <modelVersion>4.0.0</modelVersion>
  <groupId>org.seckill</groupId>   <artifactId>seckill</artifactId>   <packaging>war</packaging>   <version>0.0.1-SNAPSHOT</version>   <name>seckill Maven Webapp</name>   <dependencies>     <dependency>         <!-- 使用junit4 -->
      <groupId>junit</groupId>       <artifactId>junit</artifactId>       <version>4.11</version>       <scope>test</scope>     </dependency>     <!-- 補全專案的依賴 -->     <!-- 1:日誌 java日誌:slf4j, log4j, logback, common-logging             slf4j 是規範/介面             日誌實現:log4j, logback, common-logging             使用:slf4j + logback     -->     <dependency>         <groupId>org.slf4j</groupId>         <artifactId>slf4j-api</artifactId>         <version>1.7.12</version>     </dependency>     <dependency>         <groupId>ch.qos.logback</groupId>         <artifactId>logback-core</artifactId>         <version>1.1.2</version>     </dependency>     <dependency>         <groupId>ch.qos.logback</groupId>         <artifactId>logback-classic</artifactId>         <version>1.1.2</version>     </dependency>     <!-- 2:資料庫相關依賴 -->         <dependency>         <groupId>mysql</groupId>         <artifactId>mysql-connector-java</artifactId>         <version>5.1.38</version>         <scope>runtime</scope>     </dependency>     <!-- 資料庫連線池c3p0 -->     <dependency>         <groupId>c3p0</groupId>         <artifactId>c3p0</artifactId>         <version>0.9.1.2</version>     </dependency>     <!-- DAO框架Mybatis依賴 -->     <dependency>         <groupId>org.mybatis</groupId>         <artifactId>mybatis</artifactId>         <version>3.2.8</version>     </dependency>     <!-- Mybatis自身實現的spring整合依賴 -->     <dependency>         <groupId>org.mybatis</groupId>         <artifactId>mybatis-spring</artifactId>         <version>1.2.3</version>     </dependency>     <!-- 3:servlet web相關依賴 -->     <dependency>         <groupId>taglibs</groupId>         <artifactId>standard</artifactId>         <version>1.1.2</version>     </dependency>     <dependency>         <groupId>jstl</groupId>         <artifactId>jstl</artifactId>         <version>1.2</version>     </dependency>     <dependency>         <groupId>com.fasterxml.jackson.core</groupId>         <artifactId>jackson-databind</artifactId>         <version>2.7.4</version>     </dependency>     <dependency>         <groupId>javax.servlet</groupId>         <artifactId>javax.servlet-api</artifactId>         <version>3.1.0</version>     </dependency>     <!-- 4:spring依賴 -->     <!-- 1) spring核心 -->     <dependency>         <groupId>org.springframework</groupId>         <artifactId>spring-core</artifactId>         <version>4.2.6.RELEASE</version>     </dependency>     <dependency>         <groupId>org.springframework</groupId>         <artifactId>spring-beans</artifactId>         <version>4.2.6.RELEASE</version>     </dependency>     <dependency>         <groupId>org.springframework</groupId>         <artifactId>spring-context</artifactId>         <version>4.2.6.RELEASE</version>     </dependency>     <!-- 2) spring DAO層依賴 -->     <dependency>         <groupId>org.springframework</groupId>         <artifactId>spring-jdbc</artifactId>         <version>4.2.6.RELEASE</version>     </dependency>     <dependency>         <groupId>org.springframework</groupId>         <artifactId>spring-tx</artifactId>         <version>4.2.6.RELEASE</version>     </dependency>     <!-- 3) spring web相關依賴 -->     <dependency>         <groupId>org.springframework</groupId>         <artifactId>spring-web</artifactId>         <version>4.2.6.RELEASE</version>     </dependency>     <dependency>         <groupId>org.springframework</groupId>         <artifactId>spring-webmvc</artifactId>         <version>4.2.6.RELEASE</version>     </dependency>     <!-- 4) spring test相關依賴 -->     <dependency>         <groupId>org.springframework</groupId>         <artifactId>spring-test</artifactId>         <version>4.2.6.RELEASE</version>     </dependency>   </dependencies> </project> 至此,一個整合spring+mybatis 的 web專案基本搭建完畢!!

二、連線資料庫相關配置

如下圖,在src/main/resources 下建立jdbc.properties 檔案(驅動、url、使用者名稱、密碼等設定)

在src/main/resources 下建立mybatis-config.xml 檔案(配置mybatis全域性屬性

在src/main/resources下新建資料夾spring和mapper:spring下主要存spring相關配置檔案,mapper主要存DAO的相關對映。

在src/main/resources/spring/下建立檔案spring-dao.xml 檔案(配置連線資料庫,整合mybatis配置)

jdbc.properties檔案內容:(注意變數名必須這樣寫,不能自定義)

jdbc.driverClass=com.mysql.jdbc.Driver jdbc.jdbcUrl=jdbc:mysql://localhost:3306/seckill?useUnicode=true&characterEncoding=utf8 jdbc.user=tao jdbc.password=password mybatis-config.xml檔案內容:
<?xml version="1.0" encoding="UTF-8" ?> <!DOCTYPE configuration   PUBLIC "-//mybatis.org//DTD Config 3.0//EN" <configuration> <!-- 配置全域性屬性 -->     <settings>         <!-- 使用jdbc的getGeneratedKeys獲取資料庫自增主鍵值 -->         <setting name="useGeneratedKeys" value="true"/>         <!-- 使用列別名替換列名   預設:true -->         <setting name="useColumnLabel" value="true"/>         <!-- 開啟駝峰命名自動轉換 -->         <setting name="mapUnderscoreToCamelCase" value="true"/>     </settings> </configuration> spring-dao.xml檔案內容:(注意:classpath指代的是src/main/java和src/main/resources)
<?xml version="1.0" encoding="UTF-8"?>  <!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Strict//EN" 
"http://www.w3.org/2002/xmlspec/dtd/2.10/xmlspec.dtd">  
    <!-- 配置整合mybatis過程 -->     <!-- 1:配置資料庫相關引數  properties的屬性:${url} -->     <context:property-placeholder location="classpath:jdbc.properties"/>     <!-- 2:資料庫的連線池 -->      <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource" destroy-method="close">         <!-- 配置連線池屬性 -->         <property name="driverClass" value="${jdbc.driverClass}"></property>         <property name="jdbcUrl" value="${jdbc.jdbcUrl}"></property>           <property name="user" value="${jdbc.user}"></property>           <property name="password" value="${jdbc.password}"></property>          <!--連線池中保留的最小連線數。-->           <property name="minPoolSize" value="10"></property>           <!--連線池中保留的最大連線數。Default: 15 -->           <property name="maxPoolSize" value="30"></property>          <!--關閉連線後不自動commit -->          <property name="autoCommitOnClose" value="false"></property>         <!-- 獲取連線超時時間 -->         <property name="checkoutTimeout" value="1000"></property>         <!--定義在從資料庫獲取新連線失敗後重復嘗試的次數。Default: 30 -->           <property name="acquireRetryAttempts" value="2" />       </bean>       <!-- 3:配置SqlSessionFactory物件 -->     <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">           <!-- 注入c3p0資料庫連線池 -->         <property name="dataSource" ref="dataSource" />           <!-- 配置mybatis全域性配置檔案:mybatis-config.xml -->            <property name="configLocation" value="classpath:mybatis-config.xml"></property>         <!-- 掃描entity包,使用別名 -->         <property name="typeAliasesPackage" value="org.seckill.entity"></property>         <!-- 掃描sql配置檔案:mapper需要的xml檔案 -->             <property name="mapperLocations" value="classpath:mapper/*.xml"></property>        </bean>       <!-- 4:配置掃描Dao介面包,動態實現Dao介面,注入到spring容器中 -->     <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">         <!-- 注入sqlSessionFactroy -->           <property name="sqlSessionFactoryBeanName" value="sqlSessionFactory"></property>         <!-- 給出掃描Dao介面包 -->          <property name="basePackage" value="org.seckill.dao" />          </bean>   </beans> 注意:程式碼中高亮部分相關檔案的位置可以根據具體專案進行填寫 至此,基本配置完畢!

三、編寫DAO以及DAO對映

在編寫DAO之前,需要建立資料庫表格(建立過程省略。。。) 相關SQL語句:schema.sql檔案 -- 資料庫初始化指令碼 -- 建立資料庫 CREATE DATABASE seckill; -- 使用資料庫 use seckill; -- 建立秒殺庫存表 CREATE TABLE seckill(     seckill_id bigint NOT NULL AUTO_INCREMENT COMMENT '商品庫存id',     name varchar(120) NOT NULL COMMENT '商品名稱',     number int NOT NULL COMMENT '庫存數量',     create_time timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '建立時間',     start_time DATETIME NOT NULL COMMENT '秒殺開啟時間',     end_time DATETIME NOT NULL COMMENT '秒殺結束時間',     PRIMARY KEY(seckill_id),     key idx_start_time(start_time),     key idx_end_time(end_time),     key idx_create_time(create_time) )ENGINE=InnoDB AUTO_INCREMENT=1000 DEFAULT CHARSET=utf8 COMMENT='秒殺庫存表'; -- 初始化資料 insert into      seckill(name, number, start_time, end_time)  values     ('1000元秒殺iphon6', 100, '2015-11-01 00:00:00', '2015-11-02 00:00:00'),     ('500元秒殺ipadmini2', 200, '2016-06-24 00:00:00', '2016-06-25 00:00:00'),     ('300元秒殺小米手機', 300, '2016-06-26 00:00:00', '2015-06-27 00:00:00'),     ('1999元秒殺ipadAir', 400, '2016-06-29 00:00:00', '2016-06-30 00:00:00'),     ('5999元秒殺macbook', 500, '2016-06-29 00:00:00', '2016-06-30 00:00:00'); -- 秒殺成功明細表 -- 使用者登入相關的資訊 CREATE TABLE success_killed(     seckill_id bigint NOT NULL COMMENT '商品庫存id',     user_phone bigint NOT NULL COMMENT '使用者手機號',     state tinyint NOT NULL DEFAULT -1 COMMENT '狀態標識:-1:無效  0:成功  1:已付款',     create_time    timestamp NOT NULL COMMENT '建立時間',     PRIMARY KEY (seckill_id, user_phone),     KEY idx_create_time(create_time) )ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='秒殺成功明細表'; 這裡有兩個表:seckill和success_killed表。 我們需要兩個包:(1)org.seckill.entity包(儲存實體) (2)org.seckill.dao包(儲存與實體對應的DAO) 主要分三步:首先在src/main/java下的 org.seckill.entity 包建立實體                     然後在src/main/java下的 org.seckill.dao 包建立對應的DAO                     最後在src/main/resources下的mapper資料夾下建立對應的 XXXDao.xml 配置檔案(SQL語句寫在配置檔案中)

第一步:建立實體 Seckill. java檔案: package org.seckill.entity; import java.util.Date; public class Seckill {     private long seckillId;     private String name;     private int number;     private Date createTime;     private Date startTime;     private Date endTime;     public long getSeckillId() {         return seckillId;     }     public void setSeckillId(long seckillId) {         this.seckillId = seckillId;     }     public String getName() {         return name;     }     public void setName(String name) {         this.name = name;     }     public int getNumber() {         return number;     }     public void setNumber(int number) {         this.number = number;     }     public Date getCreateTime() {         return createTime;     }     public void setCreateTime(Date createTime) {         this.createTime = createTime;     }     public Date getStartTime() {         return startTime;     }     public void setStartTime(Date startTime) {         this.startTime = startTime;     }     public Date getEndTime() {         return endTime;     }     public void setEndTime(Date endTime) {         this.endTime = endTime;     }     //複寫toString()方法     @Override     public String toString() {         return "Seckill [seckillId=" + seckillId + ", name=" + name                 + ", number=" + number + ", createTime=" + createTime                 + ", startTime=" + startTime + ", endTime=" + endTime + "]";     } } SuccessKilled.java檔案: package org.seckill.entity; import java.util.Date; public class SuccessKilled {     private long seckillId;     private long userPhone;     private short state;        //狀態標識:-1:無效  0:成功  1:已付款     private Date createTime;     //多對一:多個SuccessKilled對應一個Seckill     private Seckill seckill;     public long getSeckillId() {         return seckillId;     }     public void setSeckillId(long seckillId) {         this.seckillId = seckillId;     }     public long getUserPhone() {         return userPhone;     }     public void setUserPhone(long userPhone) {         this.userPhone = userPhone;     }     public short getState() {         return state;     }     public void setState(short state) {         this.state = state;     }     public Date getCreateTime() {         return createTime;     }     public void setCreateTime(Date createTime) {         this.createTime = createTime;     }     public Seckill getSeckill() {         return seckill;     }     public void setSeckill(Seckill seckill) {         this.seckill = seckill;     }     @Override     public String toString() {         return "SuccessKilled [seckillId=" + seckillId + ", userPhone="                 + userPhone + ", state=" + state + ", createTime=" + createTime                 + "]";     } } 第二步:建立DAO 注意:當DAO類中的方法有多個形參的時候,需要通過註解@Param("XXX")來告訴Mybatis需要的引數 SeckillDao.java檔案: package org.seckill.dao; import java.util.Date; import java.util.List; import org.apache.ibatis.annotations.Param; import org.seckill.entity.Seckill; public interface SeckillDao {     /**      * 減庫存      * @param seckillId      * @param killTime      * @return 如果返回>1, 表示更新的記錄行數      */     int reduceNumber(@Param("seckillId") long seckillId, @Param("killTime") Date killTime);     /**      * 根據ID查詢秒殺物件      * @param seckillId      * @return      */     Seckill queryById(long seckillId);     /**      * 根據偏移量查詢秒殺商品列表      * @param offset      * @param limit      * @return      */     List<Seckill> queryAll(@Param("offset") int offset, @Param("limit") int limit); } SuccessKilledDao.java檔案: package org.seckill.dao; import org.apache.ibatis.annotations.Param; import org.seckill.entity.SuccessKilled; public interface SuccessKilledDao {     /**      * 插入購買明細,可過濾重複      * @param seckillId