import cn.hutool.extra.servlet.ServletUtil;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.alibaba.fastjson.support.spring.PropertyPreFilters;
import com.alibaba.nacos.api.naming.pojo.healthcheck.impl.Http;
import com.alibaba.nacos.shaded.com.google.gson.Gson;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.ArrayUtils;
import org.aspectj.lang.JoinPoint;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.Signature;
import org.aspectj.lang.annotation.After;
import org.aspectj.lang.annotation.AfterReturning;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Before;
import org.aspectj.lang.annotation.Pointcut;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.context.request.RequestContextHolder;
import org.springframework.web.context.request.ServletRequestAttributes;
import org.springframework.web.multipart.MultipartFile;
import org.springframework.web.multipart.MultipartHttpServletRequest;
import org.springframework.web.multipart.support.StandardMultipartHttpServletRequest;
import java.util.Arrays;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
import java.util.stream.Stream;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
@Aspect
@Component
@Slf4j
public class WebLogAspect {
@Before("pointCut()")
public void logRequestParams(JoinPoint joinPoint) {
log.info("------------- 请求参数打印 -------------");
try {
long time = System.currentTimeMillis();
ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
HttpServletRequest request = attributes.getRequest();
//打印请求地址
log.info("Request URL: {}", request.getRequestURL().toString());
//打印请求方式
log.info("Request Method: {}", request.getMethod());
//打印发起请求的ip地址
log.info("Request IP: {}", request.getRemoteAddr());
//打印请求方法
log.info("Class Method: {}.{}", joinPoint.getSignature().getDeclaringTypeName(), joinPoint.getSignature().getName());
//打印请求体
if (request.getMethod().equals("POST") || request.getMethod().equals("PUT")) {
Object[] args = joinPoint.getArgs();
List logArgs = Arrays.stream(args).filter(arg -> {
if (arginstanceof HttpServletRequest) {
return false;
}else if (arginstanceof HttpServletResponse) {
return false;
}else if (arginstanceof MultipartFile || arginstanceof MultipartFile[]) {
return false;
}else {
return true;
}
}).collect(Collectors.toList());
Object json = JSON.toJSON(logArgs);
log.info("Request Params: {}", json);
}else {
//打印请求参数
Map paramMap = ServletUtil.getParamMap(request);
log.info("Request Params: {}", paramMap);
}
log.info("参数打印耗时: {}ms", (System.currentTimeMillis() - time));
}catch (Exception e) {
log.error("参数打印发生异常", e);
}
}
@AfterReturning(pointcut ="pointCut()", returning ="result")
public void responseLog(JoinPoint joinPoint, Object result) {
log.info("------------- 返回结果打印 -------------");
try {
long time = System.currentTimeMillis();
Signature signature = joinPoint.getSignature();
String classMethod = signature.getName();
log.info("方法{}执行完毕，返回参数为：{}", classMethod, JSON.toJSON(result));
log.info("返回结果打印耗时: {}ms", (System.currentTimeMillis() - time));
}catch (Exception e) {
log.error("打印返回参数错误", e);
}
}
@Pointcut("execution(* com.*.*.controller..*.*(..))")
public void pointCut() {
}
}
