本文為Java高并發秒殺API之Service層課程筆記，
編輯器：IDEA
java版本：java8
前文：秒殺系統環境搭建與DAO層設計
秒殺業務介面與實作
DAO層：介面設計、SQL撰寫
Service：業務，DAO拼接等邏輯
代碼和SQL分離，方便review，
service介面設計
目錄如下：
首先是SecKillService介面的設計：
/**
* 業務介面：站在使用者角度設計介面
* 三個方面：
* 方法定義粒度 - 方便呼叫
* 引數 - 簡練直接
* 回傳型別 - return（型別、例外）
*/
public interface SecKillService {
/**
* 查詢所有秒殺記錄
* @return
*/
List<seckill> getSecKillList();
SecKill getById(long seckillId);
/**
* 秒殺開啟時，輸出秒殺介面地址
* 否則輸出系統時間和秒殺時間
* @param seckillId
*/
Exposer exportSecKillUrl(long seckillId);
// 執行秒殺操作驗證MD5秒殺地址，拋三個例外（有繼承關系）
// 是為了更精確的拋出例外
SeckillExecution executeSeckill(long seckillId, long userPhone, String md5)
throws SeckillException, RepeatKillException,SeckillCloseException;
}
exportSecKillUrl函式用來暴露出介面的地址，用一個專門的dto類Exposer來實作：
/**
* 暴露秒殺地址DTO
*/
public class Exposer {
// 是否開啟秒殺
private boolean exposed;
// 加密措施
private String md5;
private long seckillId;
// 系統當前時間
private long now;
// 秒殺開啟結束時間
private long start;
private long end;
// constructor getter setter
}
這里有一個md5，是為了構造秒殺地址，防止提前猜出秒殺地址，執行作弊手段，
MD5是一個安全的散列演算法，輸入兩個不同的明文不會得到相同的輸出值，根據輸出值，不能得到原始的明文，即其程序不可逆；所以要解密MD5沒有現成的演算法，只能用窮舉法，
executeSeckill函式表示執行秒殺，應該回傳執行的結果相關資訊：
/**
* 封裝秒殺執行后結果
*/
public class SeckillExecution {
private long seckillId;
// 秒殺結果狀態
private int state;
// 狀態資訊
private String stateInfo;
// 秒殺成功物件
private SuccessKilled successKilled;
// constructor getter setter
}
執行程序中可能會拋出例外，這里面用到了幾個例外：SeckillException, RepeatKillException, SeckillCloseException，
SeckillException.java，這個是其他兩個的父類，除了那兩個精確的例外，都可以回傳這個例外，
// 秒殺相關業務例外
public class SeckillException extends RuntimeException {
public SeckillException(String message) {
super(message);
}
public SeckillException(String message, Throwable cause) {
super(message, cause);
}
}
RepeatKillException是重復秒殺例外，一個用戶一件商品只能秒殺一次：
// 重復秒殺例外，運行期例外
public class RepeatKillException extends SeckillException {
public RepeatKillException(String message) {
super(message);
}
public RepeatKillException(String message, Throwable cause) {
super(message, cause);
}
}
同理，SeckillCloseException是秒殺關閉例外，秒殺結束了還在搶，回傳例外，
// 秒殺關閉例外，如時間到了，庫存沒了
public class SeckillCloseException extends SeckillException {
public SeckillCloseException(String message) {
super(message);
}
public SeckillCloseException(String message, Throwable cause) {
super(message, cause);
}
}
service介面實作
首先開啟掃描，
spring-service.xml
<!--?xml version="1.0" encoding="UTF-8"?-->
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context" xsi:schemalocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context https://www.springframework.org/schema/context/spring-context.xsd">
<!--掃描service包下使用注解的型別-->
<context:component-scan base-package="cn.orzlinux.service">
</context:component-scan></beans>
SecKillServiceImpl實作類實作了SecKillService介面的方法：指定日志物件，DAO物件，
@Service
public class SecKillServiceImpl implements SecKillService {
// 使用指定類初始化日志物件，在日志輸出的時候，可以列印出日志資訊所在類
private Logger logger = LoggerFactory.getLogger(this.getClass());
// 需要兩個 dao的配合
// 注入service依賴
@Resource
private SecKillDao secKillDao;
@Resource
private SuccessKilledDao successKilledDao;
//...
}
查詢比較簡單，直接呼叫DAO方法：
@Override
public List<seckill> getSecKillList() {
// 這里因為只有四條秒殺商品
return secKillDao.queryAll(0,4);
}
@Override
public SecKill getById(long seckillId) {
return secKillDao.queryById(seckillId);
}
暴露秒殺介面函式：
/**
* 秒殺開啟時，輸出秒殺介面地址
* 否則輸出系統時間和秒殺時間
*
* @param seckillId
*/
@Override
public Exposer exportSecKillUrl(long seckillId) {
SecKill secKill = secKillDao.queryById(seckillId);
if(secKill == null) {
// 查不到id，false
return new Exposer(false,seckillId);
}
Date startTime = secKill.getStartTime();
Date endTime = secKill.getEndTime();
Date nowTime = new Date();
if(nowTime.getTime()<starttime.gettime() ||="" nowtime.gettime()="">endTime.getTime()) {
return new Exposer(false,seckillId, nowTime.getTime(),
startTime.getTime(),endTime.getTime());
}
// 不可逆
String md5 = getMD5(seckillId);
return new Exposer(true,md5,seckillId);
}
getMD5是一個自定義函式：
// 加入鹽、混淆效果，如瞎打一下:
private final String slat="lf,ad.ga.dfgm;adrktpqerml[fasedfa]";
private String getMD5(long seckillId) {
String base = seckillId+"/orzlinux.cn/"+slat;
// spring已有實作
String md5 = DigestUtils.md5DigestAsHex(base.getBytes(StandardCharsets.UTF_8));
return md5;
}
如果直接對密碼進行散列，那么黑客可以對通過獲得這個密碼散列值，然后通過查散列值字典（例如MD5密碼破解網站），得到某用戶的密碼，加Salt可以一定程度上解決這一問題，所謂加Salt方法，就是加點”佐料”，其基本想法是這樣的：當用戶首次提供密碼時（通常是注冊時），由系統自動往這個密碼里撒一些“佐料”，然后再散列，而當用戶登錄時，系統為用戶提供的代碼撒上同樣的“佐料”，然后散列，再比較散列值，已確定密碼是否正確，這里的“佐料”被稱作“Salt值”，這個值是由系統隨機生成的，并且只有系統知道，
執行秒殺函式，這里面牽扯到編譯例外和運行時例外，
例外
編譯時例外：編譯成位元組碼程序中可能出現的例外，
運行時例外：將位元組碼加載到記憶體、運行類時出現的例外，
例外體系結構：
* java.lang.Throwable
* |-----java.lang.Error:一般不撰寫針對性的代碼進行處理，
* |-----java.lang.Exception:可以進行例外的處理
* |------編譯時例外(checked)
* |-----IOException
* |-----FileNotFoundException
* |-----ClassNotFoundException
* |------運行時例外(unchecked,RuntimeException)
* |-----NullPointerException
* |-----ArrayIndexOutOfBoundsException
* |-----ClassCastException
* |-----NumberFormatException
* |-----InputMismatchException
* |-----ArithmeticException
使用try-catch-finally處理編譯時例外，是得程式在編譯時就不再報錯，但是運行時仍可能報錯，相當于我們使用try-catch-finally將一個編譯時可能出現的例外，延遲到運行時出現，開發中，由于運行時例外比較常見，所以我們通常就不針對運行時例外撰寫try-catch-finally了，針對于編譯時例外，我們說一定要考慮例外的處理，
executeSeckill.java
@Override
public SeckillExecution executeSeckill(long seckillId, long userPhone, String md5) throws
SeckillException, RepeatKillException, SeckillException {
if(md5==null || !md5.equals(getMD5(seckillId))) {
// 秒殺的資料被重寫修改了
throw new SeckillException("seckill data rewrite");
}
// 執行秒殺邏輯：減庫存、加記錄購買行為
Date nowTime = new Date();
// 減庫存
int updateCount = secKillDao.reduceNumber(seckillId,nowTime);
try {
if(updateCount<=0) {
// 沒有更新記錄,秒殺結束
throw new SeckillCloseException("seckill is closed");
} else {
// 記錄購買行為
int insertCount = successKilledDao.insertSuccessKilled(seckillId,userPhone);
if(insertCount<=0) {
// 重復秒殺
throw new RepeatKillException("seckill repeated");
} else {
//秒殺成功
SuccessKilled successKilled = successKilledDao.queryByIdWithSeckill(seckillId,userPhone);
//return new SeckillExecution(seckillId,1,"秒殺成功",successKilled);
return new SeckillExecution(seckillId, SecKillStatEnum.SUCCESS,successKilled);
}
}
} catch (SeckillCloseException | RepeatKillException e1){
throw e1;
} catch (Exception e) {
logger.error(e.getMessage(),e);
// 所有編譯期例外轉化為運行期例外，這樣spring才能回滾
throw new SeckillException("seckill inner error"+e.getMessage());
}
}
SeckillCloseException和RepeatKillException都繼承了運行時例外，所以這些操作把例外都轉化為了運行時例外，這樣spring才能回滾，資料庫的修改才不會紊亂，
這里有一個操作就是列舉的使用，
//return new SeckillExecution(seckillId,1,"秒殺成功",successKilled);
return new SeckillExecution(seckillId, SecKillStatEnum.SUCCESS,successKilled);
用第一行的方式割裂了狀態和狀態資訊，很不優雅，而且后續要更改的話，這些代碼分散在各個代碼中，不易修改，所以用列舉代替，
package cn.orzlinux.enums;
/**
* 使用列舉表述常量資料欄位
*/
public enum SecKillStatEnum {
SUCCESS(1,"秒殺成功"),
END(0,"秒殺結束"),
REPEAT_KILL(-1,"重復秒殺"),
INNER_ERROR(-2,"系統例外"),
DATA_REWRITE(-3,"資料篡改")
;
private int state;
private String stateInfo;
SecKillStatEnum(int state, String stateInfo) {
this.state = state;
this.stateInfo = stateInfo;
}
public int getState() {
return state;
}
public String getStateInfo() {
return stateInfo;
}
public static SecKillStatEnum stateOf(int index) {
for(SecKillStatEnum statEnum:values()) {
if(statEnum.getState()==index) {
return statEnum;
}
}
return null;
}
}
宣告式事務
spring早期使用方式（2.0）：ProxyFactoryBean + XML
后來：tx:advice+aop命名空間，一次配置永久生效，
注解@Transactional，注解控制，（推薦）
支持事務方法嵌套，
何時回滾事務？拋出運行期例外，小心try/catch
具體配置：
在spring-service.xml添加：
<!--配置事務管理器-->
<bean id="transationManager" >
<!--注入資料庫連接池-->
<property name="dataSource" ref="dataSource">
</property></bean>
<!--配置基于注解的宣告式事務-->
<!--默認使用注解管理事務行為-->
<tx:annotation-driven transaction-manager="transationManager">
在SecKillServiceImpl.java檔案添加注解
@Override
@Transactional
public SeckillExecution executeSeckill(long seckillId, long userPhone, String md5) throws SeckillException, RepeatKillException, SeckillException
...
使用注解控制事務方法的優點：
- 開發團隊達成一致約定，明確標注事務方法的編程風格
- 保證事務方法的執行時間盡可能短，不要穿插其它網路操作，要剝離到事務外部
- 不是所有的方法都需要事務
集成測驗
在resource檔案夾下新建logback.xml，日志的組態檔：
<!--?xml version="1.0" encoding="UTF-8"?-->
<configuration>
<appender name="STDOUT" >
<layout >
<pattern>[%d{yyyy-MM-dd' 'HH:mm:ss.sss}] [%C] [%t] [%L] [%-5p] %m%n</pattern>
</layout>
</appender>
<root level="DEBUG">
<appender-ref ref="STDOUT">
</appender-ref></root>
</configuration>
SecKillServiceTest.java
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration({
"classpath:spring/spring-dao.xml",
"classpath:/spring/spring-service.xml"
})
public class SecKillServiceTest {
private final Logger logger = LoggerFactory.getLogger(this.getClass());
@Autowired
private SecKillService secKillService;
@Test
public void getSecKillList() {
List<seckill> list = secKillService.getSecKillList();;
logger.info("list={}",list);
// 輸出資訊： [main] [89] [DEBUG] JDBC Connection [com.mchange.v2.c3p0.impl.NewProxyConnection@5443d039] will not be managed by Spring
//[DEBUG] ==> Preparing: select seckill_id,name,number,start_time,end_time,create_time from seckill order by create_time DESC limit 0,?;
//[DEBUG] ==> Parameters: 4(Integer)
//[DEBUG] <== Total: 4
//[DEBUG]
// ------------------Closing non transactional SqlSession ---------------------
// [org.apache.ibatis.session.defaults.DefaultSqlSession@66c61024]
//[INFO ] list=[SecKill{seckillId=1000, name='1000秒殺iphone13', number=99, startTime=Tue Oct 05 02:00:00 CST 2021, endTime=Wed Oct 06 02:00:00 CST 2021, createTime=Tue Oct 05 10:01:47 CST 2021}, SecKill{seckillId=1001, name='500秒殺iphone12', number=200, startTime=Tue Oct 05 02:00:00 CST 2021, endTime=Wed Oct 06 02:00:00 CST 2021, createTime=Tue Oct 05 10:01:47 CST 2021}, SecKill{seckillId=1002, name='300秒殺iphone11', number=300, startTime=Tue Oct 05 02:00:00 CST 2021, endTime=Wed Oct 06 02:00:00 CST 2021, createTime=Tue Oct 05 10:01:47 CST 2021}, SecKill{seckillId=1003, name='100秒殺iphone6', number=400, startTime=Tue Oct 05 02:00:00 CST 2021, endTime=Wed Oct 06 02:00:00 CST 2021, createTime=Tue Oct 05 10:01:47 CST 2021}]
}
@Test
public void getById() {
long id = 1000;
SecKill secKill = secKillService.getById(id);
logger.info("seckill={}",secKill);
// seckill=SecKill{seckillId=1000, name='1000秒殺iphone13', n...}
}
@Test
public void exportSecKillUrl() {
long id = 1000;
Exposer exposer = secKillService.exportSecKillUrl(id);
logger.info("exposer={}",exposer);
//exposer=Exposer{exposed=true, md5='c78a6784f8e8012796c934dbb3f76c03',
// seckillId=1000, now=0, start=0, end=0}
// 表示在秒殺時間范圍內
}
@Test
public void executeSeckill() {
long id = 1000;
long phone = 10134256781L;
String md5 = "c78a6784f8e8012796c934dbb3f76c03";
// 重復測驗會拋出例外，junit會認為測驗失敗，要把例外捕獲一下更好看
try {
SeckillExecution seckillExecution = secKillService.executeSeckill(id,phone,md5);
logger.info("result: {}",seckillExecution);
} catch (RepeatKillException | SeckillCloseException e) {
logger.error(e.getMessage());
// 再運行一次： [ERROR] seckill repeated
}
// 有事務記錄
// Committing JDBC transaction on Connection [com.mchange.v2.c3p0.impl.NewProxyConnection@4b40f651]
//[2021-10-05 16:45:00.000] [org.springframework.jdbc.datasource.DataSourceTransactionManager] [main] [384] [DEBUG] Releasing JDBC Connection [com.mchange.v2.c3p0.impl.NewProxyConnection@4b40f651] after transaction
//result: SeckillExecution{seckillId=1000, state=1, stateInfo='秒殺成功', successKilled=SuccessKilled{seckillId=1000, userPhone=10134256781, state=0, createTime=Wed Oct 06 00:45:00 CST 2021}}
}
// 集成測驗完整邏輯實作
@Test
public void testSeckillLogic() {
long id = 1001;
Exposer exposer = secKillService.exportSecKillUrl(id);
if(exposer.isExposed()) {
logger.info("exposer={}",exposer);
long phone = 10134256781L;
String md5 = exposer.getMd5();
// 重復測驗會拋出異常，junit會認為測驗失敗，要把例外捕獲一下更好看
try {
SeckillExecution seckillExecution = secKillService.executeSeckill(id,phone,md5);
logger.info("result: {}",seckillExecution);
} catch (RepeatKillException | SeckillCloseException e) {
logger.error(e.getMessage());
// 再運行一次： [ERROR] seckill repeated
}
} else {
// 秒殺未開啟
logger.warn("exposer={}",exposer);
}
}
}
本文同步發布于orzlinux.cn
轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/305583.html
標籤：其他