基于Spring AOP實現(xiàn)日志自動打印功能
更新時間：2025年01月06日 09:52:05 作者：程序員谷美
這篇文章主要介紹了基于Spring AOP實現(xiàn)日志自動打印功能,文中通過代碼示例講解的非常詳細(xì),對大家的學(xué)習(xí)或工作有一定的幫助,需要的朋友可以參考下
概述
日志記錄是現(xiàn)代應(yīng)用程序開發(fā)中的重要組成部分。然而，在實際開發(fā)中，我們經(jīng)常面臨一些痛點(diǎn)：
- 重復(fù)打印出入?yún)?/strong>：在開發(fā)中經(jīng)常需要在每個方法中手動編寫日志代碼，這樣的工作不僅重復(fù)，而且使代碼顯得冗余和雜亂。
- 統(tǒng)一的追蹤標(biāo)識： 在排查問題時，我們經(jīng)常通過接口請求信息去查日志，這個時候我們一般需要一個traceId將所有請求串起來，這幾乎是每個方法都必須實現(xiàn)的功能：打印traceId。
- 接口requestId的返回： 為了方便上下游查問題，一般在接口設(shè)計時，響應(yīng)體都包含一個requestId字段，這個 requestId 字段，一般就是我們打印的traceId。如果我們每次都手動設(shè)置，需要對各種返回情況(如204、500)等進(jìn)行判斷，顯得代碼雜亂和臃腫。
- 接口耗時打印：我們需要記錄每個功能耗時的情況，方便性能問題排查。
使用 Spring AOP和Logback來封裝日志打印組件
1. 引入相關(guān)依賴
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-aop</artifactId>
</dependency>
<dependency>
<groupId>ch.qos.logback</groupId>
<artifactId>logback-classic</artifactId>
</dependency>
2. 創(chuàng)建Aop切面
import com.fasterxml.jackson.databind.ObjectMapper;
import com.gis.components.dto.Response;
import com.gis.components.dto.StatusCode;
import com.gis.components.exception.BizException;
import com.gis.components.exception.SysException;
import lombok.extern.slf4j.Slf4j;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Pointcut;
import org.aspectj.lang.reflect.MethodSignature;
import org.slf4j.MDC;
import org.springframework.core.annotation.AnnotationUtils;
import java.lang.reflect.Method;
import java.util.Arrays;
import java.util.UUID;
import java.util.function.Function;
@Slf4j
@Aspect
public class LogAspect {
private static ObjectMapper objectMapper = new ObjectMapper();
public static final String REQUEST_TRACE_ID = "REQUEST_TRACE_ID";
/**
* @LogTag 注解攔截器
* 在方法執(zhí)行前后記錄日志，并在出現(xiàn)異常時拋出RuntimeException。
* @param proceedingJoinPoint 切入點(diǎn)對象，提供了對目標(biāo)方法的控制權(quán)。
* @return 目標(biāo)方法的執(zhí)行結(jié)果。
*/
@Pointcut("execution(* com.yourpackage..*(..))")
public Object logExecution(ProceedingJoinPoint proceedingJoinPoint) {
return logExecutionInner(proceedingJoinPoint,e -> {
throw new RuntimeException(e);
});
}
/**
* 記錄方法執(zhí)行日志和處理異常。
* @param proceedingJoinPoint 切入點(diǎn)對象，用于獲取方法信息和執(zhí)行方法。
* @param exceptionHandler 異常處理函數(shù)，當(dāng)方法執(zhí)行過程中出現(xiàn)異常時交由異常處理函數(shù)處理
* @return 方法執(zhí)行的結(jié)果。
*/
private Object logExecutionInner(ProceedingJoinPoint proceedingJoinPoint, Function<Throwable,Object> exceptionHandler) {
long start = System.currentTimeMillis();
String traceId = null;
String currentTrace = MDC.get(REQUEST_TRACE_ID);
if(currentTrace == null || currentTrace.isEmpty()){
traceId = UUID.randomUUID().toString().replaceAll("-", "");
}else {
traceId = currentTrace;
}
MDC.put(REQUEST_TRACE_ID, traceId);
// 獲取方法聲明
MethodSignature signature = (MethodSignature) proceedingJoinPoint.getSignature();
Method method = signature.getMethod();
String s = proceedingJoinPoint.getSignature().toString();
log.info("START PROCESSING: {}",s);
// 方法入?yún)?
Object[] args = proceedingJoinPoint.getArgs();
try {
log.info("method[{}] request:{}",method.getName(), objectMapper.writeValueAsString(args));
// 執(zhí)行方法
Object result = proceedingJoinPoint.proceed();
Class returnType = signature.getReturnType();
if(returnType == Response.class || returnType.getGenericSuperclass() == Response.class){
((Response<?>) result).setRequestId(traceId);
}
log.info("method[{}] response:{}",method.getName(),objectMapper.writeValueAsString(result));
return result;
} catch (Throwable e){
log.info("method[{}] 執(zhí)行異常",method.getName(),e);
return exceptionHandler.apply(e);
}finally {
// 方法執(zhí)行時間
long executionTime = System.currentTimeMillis() - start;
log.info("END PROCESSING,cost:{} ms",executionTime);
MDC.remove(REQUEST_TRACE_ID);
}
}
}
通過上述代碼，你就能夠?qū)崿F(xiàn)切入點(diǎn)的方法的日志自動化打印、traceId自動打印、requestId自動填充的功能了。但還不夠通用，如果你想將上述功能封裝為一個包，提供給別人使用，該如何去做呢？請看下文。
使用自動裝配以及注解進(jìn)行擴(kuò)展
1. 取消LogAspect類上的@Component注解，通過配置類進(jìn)行創(chuàng)建bean對象。
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.EnableAspectJAutoProxy;
@Configuration
@EnableAspectJAutoProxy
public class LogAutoConfiguration {
@Bean
@ConditionalOnMissingBean(LogAspect.class)
public LogAspect catchLogAspect() {
return new LogAspect();
}
}
2. 創(chuàng)建注解
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
/**
* 日志注解，用于打印日志出入?yún)⒌裙δ?
*/
@Target({ElementType.METHOD,ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
public @interface LogTag {
/**
* 日志前綴
* @return
*/
String prefix() default "";
/**
* 是否將出入?yún)ο驤SON化打印
* @return true 表示轉(zhuǎn)化為JSON，false 表示打印原始入?yún)ⅰ?
*/
boolean printToJson() default true;
}
3.修改Aop切面代碼，改為攔截注解
import com.fasterxml.jackson.databind.ObjectMapper;
import com.gis.components.dto.Response;
import com.gis.components.dto.StatusCode;
import com.gis.components.exception.BizException;
import com.gis.components.exception.SysException;
import lombok.extern.slf4j.Slf4j;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Pointcut;
import org.aspectj.lang.reflect.MethodSignature;
import org.slf4j.MDC;
import org.springframework.core.annotation.AnnotationUtils;
import java.lang.reflect.Method;
import java.util.Arrays;
import java.util.UUID;
import java.util.function.Function;
@Slf4j
@Aspect
@Component
public class LogAspect {
private static ObjectMapper objectMapper = new ObjectMapper();
public static final String REQUEST_TRACE_ID = "REQUEST_TRACE_ID";
@Pointcut("@annotation(LogTag) || @within(LogTag)")
public void logPointcut() {
}
/**
* @LogTag 注解攔截器
* 在方法執(zhí)行前后記錄日志，并在出現(xiàn)異常時拋出RuntimeException。
* @param proceedingJoinPoint 切入點(diǎn)對象，提供了對目標(biāo)方法的控制權(quán)。
* @return 目標(biāo)方法的執(zhí)行結(jié)果。
*/
@Around("logPointcut()")
public Object logExecution(ProceedingJoinPoint proceedingJoinPoint) {
return logExecutionInner(proceedingJoinPoint,e -> {
throw new RuntimeException(e);
});
}
/**
* 記錄方法執(zhí)行日志和處理異常。
* @param proceedingJoinPoint 切入點(diǎn)對象，用于獲取方法信息和執(zhí)行方法。
* @param exceptionHandler 異常處理函數(shù)，當(dāng)方法執(zhí)行過程中出現(xiàn)異常時交由異常處理函數(shù)處理
* @return 方法執(zhí)行的結(jié)果。
*/
private Object logExecutionInner(ProceedingJoinPoint proceedingJoinPoint, Function<Throwable,Object> exceptionHandler) {
long start = System.currentTimeMillis();
String traceId = null;
String currentTrace = MDC.get(REQUEST_TRACE_ID);
if(currentTrace == null || currentTrace.isEmpty()){
traceId = UUID.randomUUID().toString().replaceAll("-", "");
}else {
traceId = currentTrace;
}
MDC.put(REQUEST_TRACE_ID, traceId);
// 獲取方法聲明
MethodSignature signature = (MethodSignature) proceedingJoinPoint.getSignature();
Method method = signature.getMethod();
// 獲取注解
LogTag logTag = AnnotationUtils.findAnnotation(method, LogTag.class);
if (logTag == null) {
logTag = AnnotationUtils.findAnnotation(signature.getDeclaringType(), LogTag.class);
}
String LOG_PRE = logTag.prefix();
String s = proceedingJoinPoint.getSignature().toString();
log.info("{} START PROCESSING: {}", LOG_PRE,s);
// 方法入?yún)?
Object[] args = proceedingJoinPoint.getArgs();
try {
log.info("{} method[{}] request:{}",LOG_PRE,method.getName(), logTag.printToJson() ? objectMapper.writeValueAsString(args) : Arrays.toString(args));
// 執(zhí)行方法
Object result = proceedingJoinPoint.proceed();
Class returnType = signature.getReturnType();
if(returnType == Response.class || returnType.getGenericSuperclass() == Response.class){
((Response<?>) result).setRequestId(traceId);
}
log.info("{} method[{}] response:{}",LOG_PRE,method.getName(),logTag.printToJson() ? objectMapper.writeValueAsString(result) : result);
return result;
} catch (Throwable e){
log.info("{} method[{}] 執(zhí)行異常",LOG_PRE,method.getName(),e);
return exceptionHandler.apply(e);
}finally {
// 方法執(zhí)行時間
long executionTime = System.currentTimeMillis() - start;
log.info("{} END PROCESSING,cost:{} ms", LOG_PRE,executionTime);
MDC.remove(REQUEST_TRACE_ID);
}
}
}
4. 配置自動裝載
在resource目錄下，新建META-INF文件夾，文件夾中新建文件spring.factories，文件內(nèi)容為：
org.springframework.boot.autoconfigure.EnableAutoConfiguration =com.xxx.log.LogAutoConfiguration
效果展示
到此這篇關(guān)于基于Spring AOP實現(xiàn)日志自動打印功能的文章就介紹到這了,更多相關(guān)Spring AOP日志自動打印內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
Java CompletableFuture如何實現(xiàn)超時功能
這篇文章主要為大家介紹了實現(xiàn)超時功能的基本思路以及CompletableFuture（之后簡稱CF）是如何通過代碼實現(xiàn)超時功能的,需要的小伙伴可以了解下2025-01-01
本文主要介紹了SpringBoot項目中集成Apollo的方法步驟,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2023-10-10
本篇總結(jié)的是Java多線程相關(guān)的面試題，后續(xù)會持續(xù)更新，希望我的分享可以幫助到正在備戰(zhàn)面試的實習(xí)生或者已經(jīng)工作的同行，如果發(fā)現(xiàn)錯誤還望大家多多包涵，不吝賜教，謝謝2021-07-07
作為一名經(jīng)驗豐富的開發(fā)者,在Java項目中執(zhí)行編譯后,可能會發(fā)現(xiàn)一個.java源文件有時會產(chǎn)生多個.class文件,從技術(shù)實現(xiàn)層面詳細(xì)剖析這一現(xiàn)象2025-04-04
從簡單到進(jìn)階解析Java調(diào)用Python的5種實用方案
在機(jī)器學(xué)習(xí)與大數(shù)據(jù)融合的今天,Java與Python的協(xié)同開發(fā)已成為企業(yè)級應(yīng)用的常見需求,本文將通過真實案例解析5種主流調(diào)用方案,需要的小伙伴可以了解下2025-09-09
深入學(xué)習(xí)Hibernate持久化對象的三個狀態(tài)
Hibernate中的對象有3中狀態(tài)，瞬時對象（TransientObjects）、持久化對象（PersistentObjects）和離線對象（DetachedObjects也叫做脫管對象），下面通過本文給大家分享Hibernate持久化對象的三個狀態(tài)，一起看看吧2017-09-09
這篇文章主要介紹了SpringBoot動態(tài)修改日志級別的操作，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-07-07
SpringBoot POST請求接收多個參數(shù)值為null問題
SpringBoot接口中POST請求接收J(rèn)SON數(shù)據(jù)時,使用簡單類型接收會報null,需要封裝成實體類或使用Map（并注明泛型）接收,并且使用@RequestBody注解2025-02-02
這篇文章主要介紹了MyBatis-Plus實現(xiàn)邏輯刪除功能解析,有時候并不需要真正的刪除數(shù)據(jù),而是想邏輯刪除,方便數(shù)據(jù)恢復(fù),MyBatis-Plus可以很方便的實現(xiàn)邏輯刪除的功能,需要的朋友可以參考下2023-11-11
Java中Word變量進(jìn)行添加、統(tǒng)計、獲取與刪除操作詳解
本文將介紹如何利用 Java 語言,借助 Spire.Doc for Java 庫,在不依賴 Microsoft Word 環(huán)境的情況下,對 Word 文檔中的變量進(jìn)行添加、統(tǒng)計、檢索和刪除操作,希望對大家有所幫助2026-05-05