AOP是一種與語言無關的程序思想、編程範式。項目業務邏輯中,將通用的模塊以水平切割的方式進行分離統一處理,經常使用於日誌、權限控制、異常處理等業務中。java
如下示例是基於Spring Boot實戰系列(2)數據存儲之Jpa操做MySQL chapter2-1可在Github獲取源碼git
項目根目錄 pom.xml
添加依賴 spring-boot-starter-aop
github
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-aop</artifactId>
</dependency>
複製代碼
@Aspect
: 切面,由通知和切入點共同組成,這個註解標註在類上表示爲一個切面。@Joinpoint
: 鏈接點,被AOP攔截的類或者方法,在前置通知中有介紹使用@Joinpoint
獲取類名、方法、請求參數。Advice
: 通知的幾種類型
@Before
: 前置通知,在某切入點@Pointcut
以前的通知@After
: 後置通知,在某切入點@Pointcut
以後的通知不管成功或者異常。@AfterReturning
: 返回後通知,方法執行return以後,能夠對返回的數據作加工處理。@Around
: 環繞通知,在方法的調用前、後執行。@AfterThrowing
: 拋出異常通知,程序出錯跑出異常會執行該通知方法。@Pointcut
: 切入點,從哪裏開始。例如從某個包開始或者某個包下的某個類等。目錄 aspect
下 新建 httpAspect.java
類,在收到請求以後先記錄請求的相關參很多天志信息,請求成功完成以後打印響應信息,請求處理報錯打印報錯日誌信息。web
httpAspect.java
spring
package com.angelo.aspect;
import com.google.gson.Gson;
import com.google.gson.GsonBuilder;
import org.aspectj.lang.JoinPoint;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.*;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
import org.springframework.web.context.request.RequestContextHolder;
import org.springframework.web.context.request.ServletRequestAttributes;
import javax.servlet.http.HttpServletRequest;
import java.util.HashMap;
import java.util.Map;
@Aspect
@Component
public class HttpAspect {
// 打印日誌模塊
private final static Logger logger = LoggerFactory.getLogger(HttpAspect.class);
// 下面會一一介紹...
複製代碼
定義切入的入口在哪裏,封裝一個公共的方法實現複用編程
httpAspect.java
json
/** * 定義一個公共的方法,實現服用 * 攔截UserController下面的全部方法 * 攔截UserController下面的userList方法裏的任何參數(..表示攔截任何參數)寫法:@Before("execution(public * com.angelo.controller.UserController.userList(..))") */
@Pointcut("execution(public * com.angelo.controller.UserController.*(..))")
public void log() {
}
複製代碼
攔截方法以前的一段業務邏輯,獲取請求的一些信息,其中用到了Gson
處理對象轉json輸出app
httpAspect.java
curl
@Before("log()")
public void doBefore(JoinPoint joinPoint) {
ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
HttpServletRequest request = attributes.getRequest();
Map params = new HashMap();
params.put("url", request.getRequestURL()); // 獲取請求的url
params.put("method", request.getMethod()); // 獲取請求的方式
params.put("ip", request.getRemoteAddr()); // 獲取請求的ip地址
params.put("className", joinPoint.getSignature().getDeclaringTypeName()); // 獲取類名
params.put("classMethod", joinPoint.getSignature().getName()); // 獲取類方法
params.put("args", joinPoint.getArgs()); // 請求參數
// 輸出格式化後的json字符串
Gson gson = new GsonBuilder().setPrettyPrinting().create();
logger.info("REQUEST: {}", gson.toJson(params));
}
複製代碼
攔截方法以後的一段業務邏輯函數
httpAspect.java
@After("log()")
public void doAfter() {
logger.info("doAfter");
}
複製代碼
環繞通知是在方法的先後的一段邏輯操做,能夠修改目標方法的返回值,第一個參數是org.aspectj.lang.ProceedingJoinPoint
類型,注意這裏要調用執行目標方法proceed()
獲取值返回,否則會形成空指針異常。在環繞通知裏面也能夠捕獲錯誤返回。
httpAspect.java
@Around("log()")
public Object doAround(ProceedingJoinPoint point) {
try {
Object o = point.proceed();
System.out.println("方法環繞proceed,結果是 :" + o);
logger.info("doAround1");
return o;
} catch (Throwable e) {
// e.printStackTrace();
logger.info("doAround2");
return null;
}
}
複製代碼
在切入點完成以後的返回通知,此時就不會拋出異常通知,除非返回後通知的業務邏輯報錯。
httpAspect.java
/** * 獲取響應返回值 * @param object */
@AfterReturning(returning = "object", pointcut = "log()")
public void doAfterReturning(Object object) {
// logger.info("RESPONSE: {}", object); 會打印出一個對象,想打印出具體內容須要在定義模型處加上toString()
logger.info("RESPONSE: {}", object.toString());
}
複製代碼
拋出異常後的通知,此時返回後通知@AfterReturning
就不會執行。
httpAspect.java
@AfterThrowing(pointcut = "log()")
public void doAfterThrowing() {
logger.error("doAfterThrowing: {}", " 異常狀況!");
}
複製代碼
try {
// @Before 執行前通知
// 執行目標方法
// @Around 執行環繞通知 成功走finall,失敗走catch
} finally {
// @After 執行後置通知
// @AfterReturning 執行返回後通知
} catch(e) {
// @AfterThrowing 拋出異常通知
}
複製代碼
測試以前先對controller/UserController.java
文件的userList
方法增長了exception
參數
/** * 查詢用戶列表 * @return */
@RequestMapping(value = "/user/list/{exception}")
public List<User> userList(@PathVariable("exception") Boolean exception) {
if (exception) {
throw new Error("測試拋出異常!");
}
return userRepository.findAll();
}
複製代碼
curl 127.0.0.1:8080/user/list/false
正常狀況返回值以下所示:
curl 127.0.0.1:8080/user/list/true
異常狀況返回值以下所示:
經過以上兩種狀況測試能夠看到環繞通知在正常、異常兩種狀況均可以執行到。
做者:五月君
連接:www.imooc.com/article/259…
來源:慕課網
Github: Spring Boot實戰系列