2025年spring aop日志（springaop实现日志管理）

大家好，我是讯享网，很高兴认识大家。
 1 package com.gcx.annotation;  2  3 import java.lang.reflect.Method;  4 import java.util.Date;  5 import java.util.UUID;  6  7 import javax.annotation.Resource;  8 import javax.servlet.http.HttpServletRequest;  9 import javax.servlet.http.HttpSession;  10  11 import org.aspectj.lang.JoinPoint;  12 import org.aspectj.lang.ProceedingJoinPoint;  13 import org.aspectj.lang.annotation.After;  14 import org.aspectj.lang.annotation.AfterReturning;  15 import org.aspectj.lang.annotation.AfterThrowing;  16 import org.aspectj.lang.annotation.Around;  17 import org.aspectj.lang.annotation.Aspect;  18 import org.aspectj.lang.annotation.Before;  19 import org.aspectj.lang.annotation.Pointcut;  20 import org.slf4j.Logger;  21 import org.slf4j.LoggerFactory;  22 import org.springframework.stereotype.Component;  23  24 import com.gcx.entity.SystemLog;  25 import com.gcx.entity.User;  26 import com.gcx.service.SystemLogService;  27 import com.gcx.util.JsonUtil;  28  29 /  30  * @author 杨建  31  * @E-mail: email  32  * @version 创建时间：2015-10-19 下午4:29:05  33  * @desc 切点类  34 /  35  36 @Aspect  37 @Component  38 public class SystemLogAspect {  39  40 //注入Service用于把日志保存数据库   41 @Resource //这里我用resource注解，一般用的是@Autowired，他们的区别如有时间我会在后面的博客中来写  42 private SystemLogService systemLogService;
  43
  44 private static final Logger logger = LoggerFactory.getLogger(SystemLogAspect. class);
  45
  46 //Controller层切点   47 @Pointcut(“execution ( com.gcx.controller...(..))”)
  48 public void controllerAspect() {
  49  }
  50
  51 /  52  * 前置通知 用于拦截Controller层记录用户的操作  53  *  54  * @param joinPoint 切点  55 */  56 @Before(“controllerAspect()”)  57 public void doBefore(JoinPoint joinPoint) {  58 System.out.println(“==========执行controller前置通知===============”);  59 if(logger.isInfoEnabled()){  60 logger.info(“before ” + joinPoint);  61  }  62  }
  63
  64 //配置controller环绕通知,使用在方法aspect()上注册的切入点  65 @Around(“controllerAspect()”)  66 public void around(JoinPoint joinPoint){  67 System.out.println(“==========开始执行controller环绕通知===============”);  68 long start = System.currentTimeMillis();  69 try {  70  ((ProceedingJoinPoint) joinPoint).proceed();  71 long end = System.currentTimeMillis();  72 if(logger.isInfoEnabled()){  73 logger.info(“around ” + joinPoint + “ Use time : ” + (end - start) + “ ms!”);  74  }  75 System.out.println(“==========结束执行controller环绕通知===============”);  76 } catch (Throwable e) {  77 long end = System.currentTimeMillis();  78 if(logger.isInfoEnabled()){  79 logger.info(“around ” + joinPoint + “ Use time : ” + (end - start) + “ ms with exception : ” + e.getMessage());  80  }  81  }  82  }  83
  84 /  85  * 后置通知 用于拦截Controller层记录用户的操作  86  *  87  * @param joinPoint 切点  88 /
  89 @After(“controllerAspect()”)
  90 public void after(JoinPoint joinPoint) {
  91
  92 / HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();
  93  HttpSession session = request.getSession(); /  94 //读取session中的用户
  95 // User user = (User) session.getAttribute(“user”);
  96 //请求的IP
  97 //String ip = request.getRemoteAddr();  98 User user = new User();  99 user.setId(1); 100 user.setName(“张三”); 101 String ip = “127.0.0.1”; 102 try {
 103
 104 String targetName = joinPoint.getTarget().getClass().getName();
 105 String methodName = joinPoint.getSignature().getName();
 106 Object[] arguments = joinPoint.getArgs();
 107 Class targetClass = Class.forName(targetName);
 108 Method[] methods = targetClass.getMethods(); 109 String operationType = “”; 110 String operationName = “”; 111 for (Method method : methods) {
 112 if (method.getName().equals(methodName)) {
 113 Class[] clazzs = method.getParameterTypes();
 114 if (clazzs.length == arguments.length) {
 115 operationType = method.getAnnotation(Log.class).operationType(); 116 operationName = method.getAnnotation(Log.class).operationName(); 117 break;
 118  }
 119  }
 120  } 121 //========控制台输出=========//
 122 System.out.println(“=====controller后置通知开始=====”);
 123 System.out.println(“请求方法:” + (joinPoint.getTarget().getClass().getName() + “.” + joinPoint.getSignature().getName() + “()”)+“.”+operationType);
 124 System.out.println(“方法描述:” + operationName);
 125 System.out.println(“请求人:” + user.getName());
 126 System.out.println(“请求IP:” + ip);
 127 //========数据库日志=========*//
 128 SystemLog log = new SystemLog();
 129  log.setId(UUID.randomUUID().toString()); 130  log.setDescription(operationName);
 131 log.setMethod((joinPoint.getTarget().getClass().getName() + “.” + joinPoint.getSignature().getName() + “()”)+“.”+operationType);
 132 log.setLogType((long)0);
 133  log.setRequestIp(ip);
 134 log.setExceptioncode( null);
 135 log.setExceptionDetail( null);
 136 log.setParams( null);
 137  log.setCreateBy(user.getName());
 138 log.setCreateDate(new Date());
 139 //保存数据库  140  systemLogService.insert(log);
 141 System.out.println(“=====controller后置通知结束=====”);
 142 } catch (Exception e) {
 143 //记录本地异常日志  144 logger.error(“==后置通知异常==”);
 145 logger.error(“异常信息:{}”, e.getMessage());
 146  }
 147  } 148
 149 //配置后置返回通知,使用在方法aspect()上注册的切入点 150 @AfterReturning(“controllerAspect()”) 151 public void afterReturn(JoinPoint joinPoint){ 152 System.out.println(“=====执行controller后置返回通知=====”);
 153 if(logger.isInfoEnabled()){ 154 logger.info(“afterReturn ” + joinPoint); 155  } 156  } 157
 158 / 159  * 异常通知 用于拦截记录异常日志 160  * 161  * @param joinPoint 162  * @param e 163 /
 164 @AfterThrowing(pointcut = “controllerAspect()”, throwing=“e”)
 165 public void doAfterThrowing(JoinPoint joinPoint, Throwable e) {
 166 /HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();
 167  HttpSession session = request.getSession();
 168  //读取session中的用户
 169  User user = (User) session.getAttribute(WebConstants.CURRENT_USER);
 170  //获取请求ip
 171  String ip = request.getRemoteAddr(); / 172 //获取用户请求方法的参数并序列化为JSON格式字符串  173
 174 User user = new User(); 175 user.setId(1); 176 user.setName(“张三”); 177 String ip = “127.0.0.1”; 178
 179 String params = “”;
 180 if (joinPoint.getArgs() != null && joinPoint.getArgs().length &gt; 0) {
 181 for ( int i = 0; i &lt; joinPoint.getArgs().length; i++) {
 182 params += JsonUtil.getJsonStr(joinPoint.getArgs()[i]) + “;”;
 183  }
 184  }
 185 try {
 186
 187 String targetName = joinPoint.getTarget().getClass().getName();
 188 String methodName = joinPoint.getSignature().getName();
 189 Object[] arguments = joinPoint.getArgs();
 190 Class targetClass = Class.forName(targetName);
 191 Method[] methods = targetClass.getMethods(); 192 String operationType = “”; 193 String operationName = “”; 194 for (Method method : methods) {
 195 if (method.getName().equals(methodName)) {
 196 Class[] clazzs = method.getParameterTypes();
 197 if (clazzs.length == arguments.length) {
 198 operationType = method.getAnnotation(Log.class).operationType(); 199 operationName = method.getAnnotation(Log.class).operationName(); 200 break;
 201  }
 202  }
 203  } 204 /========控制台输出=========/
 205 System.out.println(“=====异常通知开始=====”);
 206 System.out.println(“异常代码:” + e.getClass().getName());
 207 System.out.println(“异常信息:” + e.getMessage());
 208 System.out.println(“异常方法:” + (joinPoint.getTarget().getClass().getName() + “.” + joinPoint.getSignature().getName() + “()”)+“.”+operationType);
 209 System.out.println(“方法描述:” + operationName);
 210 System.out.println(“请求人:” + user.getName());
 211 System.out.println(“请求IP:” + ip);
 212 System.out.println(“请求参数:” + params);
 213 /==========数据库日志=========/
 214 SystemLog log = new SystemLog(); 215  log.setId(UUID.randomUUID().toString()); 216  log.setDescription(operationName);
 217  log.setExceptioncode(e.getClass().getName());
 218 log.setLogType((long)1);
 219  log.setExceptionDetail(e.getMessage());
 220 log.setMethod((joinPoint.getTarget().getClass().getName() + “.” + joinPoint.getSignature().getName() + “()”));
 221  log.setParams(params);
 222  log.setCreateBy(user.getName());
 223 log.setCreateDate(new Date());
 224  log.setRequestIp(ip);
 225 //保存数据库  226  systemLogService.insert(log);
 227 System.out.println(“=====异常通知结束=====”);
 228 } catch (Exception ex) {
 229 //记录本地异常日志  230 logger.error(“==异常通知异常==”);
 231 logger.error(“异常信息:{}”, ex.getMessage());
 232  }
 233 /==========记录本地异常日志==========*/
 234 logger.error(“异常方法:{}异常代码:{}异常信息:{}参数:{}”, joinPoint.getTarget().getClass().getName() + joinPoint.getSignature().getName(), e.getClass().getName(), e.getMessage(), params);
 235
 236  }
 237
 238 }
讯享网
2025年spring aop日志（springaop实现日志管理）

相关推荐
