springboot springmvc攔截器 攔截POST、PUT、DELETE請求參數和響應數據，並記錄操做日誌

1.操做日誌實體類

@Document(collection = "operation_log")
@Getter
@Setter
@ToString
public class OperationLog extends BaseEntityWithId {
  private String userId; // 操做人
  private String resource; // 操做的資源
  private String requestMethod; // 請求方式
  private String beanName; // 操做的類
  private String methodName; // 操做的模塊
  private String requestParams; // 請求的參數
  private String responseData; // 返回數據
}

2.攔截器

package com.vian.admin.config;

import com.alibaba.fastjson.JSON;
import com.vian.admin.entity.OperationLog;
import com.vian.admin.event.OperationLogEvent;
import com.vian.core.configuration.event.EventPublisher;
import com.vian.microservice.security.SecurityUtils;
import lombok.extern.slf4j.Slf4j;
import org.aspectj.lang.JoinPoint;
import org.aspectj.lang.annotation.AfterReturning;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Before;
import org.aspectj.lang.annotation.Pointcut;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.web.context.request.RequestContextHolder;
import org.springframework.web.context.request.ServletRequestAttributes;

import javax.servlet.http.HttpServletRequest;


@Aspect
@Component
@Slf4j
public class RequestLogAspect {
  @Autowired private EventPublisher eventPublisher;
  private ThreadLocal<OperationLog> logThreadLocal = new ThreadLocal<>();
  //攔截web下全部方法
  @Pointcut("execution(* com.vian.admin.web..*.*(..))")
  public void pointcut() {
    log.info("攔截請求start");
  }

  @Before("pointcut()")
  public void doBefore(JoinPoint joinPoint) {

    ServletRequestAttributes attributes =
        (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
    HttpServletRequest request = attributes.getRequest();
    String beanName = joinPoint.getSignature().getDeclaringTypeName();
    String methodName = joinPoint.getSignature().getName();
    String uri = request.getRequestURI();
    String userId = SecurityUtils.getCurrentUserId();
    //get方法不記錄日誌
    if ("GET".equals(request.getMethod())) {
      return;
    }
    //請求參數
    Object[] paramsArray = joinPoint.getArgs();
    log.info(
        "請求日誌攔截：userId={}, uri={}, method={}, request={}",
        userId,
        uri,
        request.getMethod(),
        paramsArray);
    // 組裝日誌數據
    OperationLog optLog = new OperationLog();
    optLog.setUserId(userId);
    optLog.setResource(uri);
    optLog.setRequestMethod(request.getMethod());
    optLog.setBeanName(beanName);
    optLog.setMethodName(methodName);
    optLog.setRequestParams(argsArrayToString(paramsArray));
    logThreadLocal.set(optLog);
  }

  @AfterReturning(returning = "result", pointcut = "pointcut()")
  public void doAfterReturning(Object result) {
    try {
      // 處理完請求，從線程變量中獲取日誌數據，並記錄到db
      OperationLog optLog = logThreadLocal.get();
      if (null != optLog) {
        optLog.setResponseData(JSON.toJSONString(result));
        eventPublisher.publish(new OperationLogEvent(this, optLog));
      }
    } catch (Exception e) {
      log.error("***操做請求日誌記錄失敗doAfterReturning()***", e);
    } finally {
      // 清除threadlocal
      logThreadLocal.remove();
    }
  }

  /**
   * 請求參數拼裝
   *
   * @param paramsArray
   * @return
   */
  private String argsArrayToString(Object[] paramsArray) {
    String params = "";
    if (paramsArray != null && paramsArray.length > 0) {
      for (int i = 0; i < paramsArray.length; i++) {
        Object jsonObj = JSON.toJSON(paramsArray[i]);
        params += jsonObj.toString() + " ";
      }
    }
    return params.trim();
  }
}

測試結果：