写了个牛逼的日志切面,甩锅更方便了( 二 )

<>();//参数名String[] paramNames =((MethodSignature)proceedingJoinPoint.getSignature()).getParameterNames();//参数值Object[] paramValues = proceedingJoinPoint.getArgs();for (int i = 0; i < paramNames.length; i++) {Object value = http://kandian.youth.cn/index/paramValues[i];//如果是文件对象if (value instanceof MultipartFile) {MultipartFile file = (MultipartFile) value;value = file.getOriginalFilename();//获取文件名}requestParams.put(paramNames[i], value);}return requestParams;}}高并发下请求日志切面写完以后对自己的代码很满意 , 但是想着可能还有完善的地方就和朋友交流了一下 。 emmmm
写了个牛逼的日志切面,甩锅更方便了文章插图
果然还有继续优化的地方 每个信息都打印一行 , 在高并发请求下确实会出现请求之间打印日志串行的问题 , 因为测试阶段请求数量较少没有出现串行的情况 , 果然生产环境才是第一发展力 , 能够遇到更多 bug , 写更健壮的代码 解决日志串行的问题只要将多行打印信息合并为一行就可以了 , 因此构造一个对象

  • RequestInfo.java
@Datapublic class RequestInfo {private String ip;private String url;private String httpMethod;private String classMethod;private Object requestParams;private Object result;private Long timeCost;}
  • 环绕通知方法体
@Around("requestServer()")public Object doAround(ProceedingJoinPoint proceedingJoinPoint) throws Throwable {long start = System.currentTimeMillis();ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();HttpServletRequest request = attributes.getRequest();Object result = proceedingJoinPoint.proceed();RequestInfo requestInfo = new RequestInfo();requestInfo.setIp(request.getRemoteAddr());requestInfo.setUrl(request.getRequestURL().toString());requestInfo.setHttpMethod(request.getMethod());requestInfo.setClassMethod(String.format("%s.%s", proceedingJoinPoint.getSignature().getDeclaringTypeName(),proceedingJoinPoint.getSignature().getName()));requestInfo.setRequestParams(getRequestParamsByProceedingJoinPoint(proceedingJoinPoint));requestInfo.setResult(result);requestInfo.setTimeCost(System.currentTimeMillis() - start);LOGGER.info("Request Info: {}", JSON.toJSONString(requestInfo));return result;}【写了个牛逼的日志切面,甩锅更方便了】将 url、http request 这些信息组装成 RequestInfo 对象 , 再序列化打印对象打印序列化对象结果而不是直接打印对象是因为序列化有更直观、更清晰 , 同时可以借助在线解析工具对结果进行解析
写了个牛逼的日志切面,甩锅更方便了文章插图
是不是还不错
在解决高并发下请求串行问题的同时添加了对异常请求信息的打印 , 通过使用 @AfterThrowing 注解对抛出异常的方法进行处理
  • RequestErrorInfo.java
@Datapublic class RequestErrorInfo {private String ip;private String url;private String httpMethod;private String classMethod;private Object requestParams;private RuntimeException exception;}
  • 异常通知环绕体
@AfterThrowing(pointcut = "requestServer()", throwing = "e")public void doAfterThrow(JoinPoint joinPoint, RuntimeException e) {ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();HttpServletRequest request = attributes.getRequest();RequestErrorInfo requestErrorInfo = new RequestErrorInfo();requestErrorInfo.setIp(request.getRemoteAddr());requestErrorInfo.setUrl(request.getRequestURL().toString());requestErrorInfo.setHttpMethod(request.getMethod());requestErrorInfo.setClassMethod(String.format("%s.%s", joinPoint.getSignature().getDeclaringTypeName(),joinPoint.getSignature().getName()));requestErrorInfo.setRequestParams(getRequestParamsByJoinPoint(joinPoint));requestErrorInfo.setException(e);LOGGER.info("Error Request Info: {}", JSON.toJSONString(requestErrorInfo));}对于异常 , 耗时是没有意义的 , 因此不统计耗时 , 而是添加了异常的打印
最后放一下完整日志请求切面代码:
@Component@Aspectpublic class RequestLogAspect {private final static Logger LOGGER = LoggerFactory.getLogger(RequestLogAspect.class);@Pointcut("execution(* your_package.controller..*(..))")public void requestServer() {}@Around("requestServer()")public Object doAround(ProceedingJoinPoint proceedingJoinPoint) throws Throwable {long start = System.currentTimeMillis();ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();HttpServletRequest request = attributes.getRequest();Object result = proceedingJoinPoint.proceed();RequestInfo requestInfo = new RequestInfo();requestInfo.setIp(request.getRemoteAddr());requestInfo.setUrl(request.getRequestURL().toString());requestInfo.setHttpMethod(request.getMethod());requestInfo.setClassMethod(String.format("%s.%s", proceedingJoinPoint.getSignature().getDeclaringTypeName(),proceedingJoinPoint.getSignature().getName()));requestInfo.setRequestParams(getRequestParamsByProceedingJoinPoint(proceedingJoinPoint));requestInfo.setResult(result);requestInfo.setTimeCost(System.currentTimeMillis() - start);LOGGER.info("Request Info: {}", JSON.toJSONString(requestInfo));return result;}@AfterThrowing(pointcut = "requestServer()", throwing = "e")public void doAfterThrow(JoinPoint joinPoint, RuntimeException e) {ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();HttpServletRequest request = attributes.getRequest();RequestErrorInfo requestErrorInfo = new RequestErrorInfo();requestErrorInfo.setIp(request.getRemoteAddr());requestErrorInfo.setUrl(request.getRequestURL().toString());requestErrorInfo.setHttpMethod(request.getMethod());requestErrorInfo.setClassMethod(String.format("%s.%s", joinPoint.getSignature().getDeclaringTypeName(),joinPoint.getSignature().getName()));requestErrorInfo.setRequestParams(getRequestParamsByJoinPoint(joinPoint));requestErrorInfo.setException(e);LOGGER.info("Error Request Info: {}", JSON.toJSONString(requestErrorInfo));}/*** 获取入参* @param proceedingJoinPoint** @return* */private Map getRequestParamsByProceedingJoinPoint(ProceedingJoinPoint proceedingJoinPoint) {//参数名String[] paramNames = ((MethodSignature)proceedingJoinPoint.getSignature()).getParameterNames();//参数值Object[] paramValues = proceedingJoinPoint.getArgs();return buildRequestParam(paramNames, paramValues);}private Map getRequestParamsByJoinPoint(JoinPoint joinPoint) {//参数名String[] paramNames = ((MethodSignature)joinPoint.getSignature()).getParameterNames();//参数值Object[] paramValues = joinPoint.getArgs();return buildRequestParam(paramNames, paramValues);}private Map buildRequestParam(String[] paramNames, Object[] paramValues) {Map requestParams = new HashMap