aop实现日志的保持操作
📢📢📢📣📣📣
哈喽！大家好，我是「奇点」，江湖人称 singularity。刚工作几年，想和大家一同进步🤝🤝
一位上进心十足的【Java ToB端大厂领域博主】！😜😜😜
喜欢java和python，平时比较懒，能用程序解决的坚决不手动解决😜😜😜✨ 如果有对【java】感兴趣的【小可爱】，欢迎关注我
❤️❤️❤️感谢各位大可爱小可爱！❤️❤️❤️
————————————————如果觉得本文对你有帮助，欢迎点赞，欢迎关注我，如果有补充欢迎评论交流，我将努力创作更多更好的文章。
————————————————版权声明：本文为博主原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。
简单回顾SpringAOP的相关知识点
首先我们简单回归一下相关的知识点：
SpringAOP的相关的知识点包括源码解析，为了加深印象，这边再做一个简短的回顾：
- 切面（Aspect）：也就是我们定义的专注于提供辅助功能的模块，比如安全管理，日志信息等。
- 连接点（JoinPoint）：切面代码可以通过连接点切入到正常业务之中，图中每个方法的每个点都是连接点。
- 切入点（PointCut）：一个切面不需要通知所有的连接点，而在连接点的基础之上增加切入的规则，选择需要增强的点，最终真正通知的点就是切入点。
- 通知方法（Advice）：就是切面需要执行的工作，主要有五种通知：before，after，afterReturning，afterThrowing，around。
- 织入（Weaving）：将切面应用到目标对象并创建代理对象的过程，SpringAOP选择再目标对象的运行期动态创建代理对
- 引入（introduction）：在不修改代码的前提下，引入可以在运行期为类动态地添加方法或字段。
通知的五种类型
- 前置通知Before：目标方法调用之前执行的通知。
- 后置通知After：目标方法完成之后，无论如何都会执行的通知。
- 返回通知AfterReturning：目标方法成功之后调用的通知。
- 异常通知AfterThrowing：目标方法抛出异常之后调用的通知。
- 环绕通知Around：可以看作前面四种通知的综合。
切入点表达式
上面提到：连接点增加切入规则就相当于定义了切入点，当然切入点表达式分为很多种，这里主要学习execution和annotation表达式。
execution
- 写法：execution(访问修饰符 返回值 包名.包名……类名.方法名(参数列表))
- 例：execution(public void com.smday.service.impl.AccountServiceImpl.saveAccount())
- 访问修饰符可以省略，返回值可以使用通配符*匹配。
- 包名也可以使用*匹配，数量代表包的层级，当前包可以使用..标识，例如* *..AccountServiceImpl.saveAccount()
- 类名和方法名也都可以使用*匹配：* *..*.*()
- 参数列表使用..可以标识有无参数均可，且参数可为任意类型。
全通配写法：* *…*.*(…)
通常情况下，切入点应当设置在业务层实现类下的所有方法：* com.xxx.service.impl.*.*(..)。
@annotation
匹配连接点被它参数指定的Annotation注解的方法。也就是说，所有被指定注解标注的方法都将匹配。
@annotation(com.xx.annotation.Log)：指定Log注解方法的连接点。
AOP应用场景
- 记录日志
- 监控性能
- 权限控制
- 事务管理
demo
1、引入依赖
如果你使用的是SpringBoot，那么只需要引入：spring-boot-starter-aop，框架已经将spring-aop和aspectjweaver整合进去。
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-aop</artifactId>
</dependency>
/**
* Controller层的日志封装
*/
@Data
@ToString
public class WebLog implements Serializable {
private static final long serialVersionUID = 1L;
// 操作描述
private String description;
// 操作时间
private Long startTime;
// 消耗时间
private Integer timeCost;
// URL
private String url;
// URI
private String uri;
// 请求类型
private String httpMethod;
// IP地址
private String ipAddress;
// 请求参数
private Object params;
// 请求返回的结果
private Object result;
// 操作类型
private String methodType;
}
自定义注解@Log
@Target({ElementType.PARAMETER,ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface Log {
/**
* 描述
*/
String description() default "";
/**
* 方法类型 INSERT DELETE UPDATE OTHER
*/
MethodType methodType() default MethodType.OTHER;
}
接口
@RestController
public class HelloController {
@PostMapping("/hello")
@Log(description = "hello post",methodType = MethodType.INSERT)
public String hello(@RequestBody User user) {
return "hello";
}
@GetMapping("/hello")
@Log(description = "hello get")
public String hello(@RequestParam("name") String username, String hobby) {
int a = 1 / 0;
return "hello";
}
}
定义切面Aspect与切点Pointcut
用@Aspect注解标注标识切面，用@PointCut定义切点。
/**
* 定义切面
*/
@Aspect
@Component
public class LogAspect {
private static final Logger log = LoggerFactory.getLogger(LogAspect.class);
/**
* web层切点
* 1. @Pointcut("execution(public * com.hyh.web.*.*(..))") web层的所有方法
* 2. @Pointcut("@annotation(com.hyh.annotation.Log)") Log注解标注的方法
*/
@Pointcut("@annotation(com.hyh.annotation.Log)")
public void webLog() {
}
}
定义通知方法Advice
/**
* 定义切面
*/
@Aspect
@Component
public class LogAspect {
private static final Logger log = LoggerFactory.getLogger(LogAspect.class);
/**
* web层切点
* 1. @Pointcut("execution(public * com.hyh.web.*.*(..))") web层的所有方法
* 2. @Pointcut("@annotation(com.hyh.annotation.Log)") Log注解标注的方法
*/
@Pointcut("@annotation(com.hyh.annotation.Log)")
public void webLog() {
}
/**
* 环绕通知
*/
@Around("webLog()")
public Object doAround(ProceedingJoinPoint joinPoint) throws Throwable {
//获取请求对象
HttpServletRequest request = getRequest();
WebLog webLog = new WebLog();
Object result = null;
try {
log.info("=================前置通知=====================");
long start = System.currentTimeMillis();
result = joinPoint.proceed();
log.info("=================返回通知=====================");
long timeCost = System.currentTimeMillis() - start;
// 获取Log注解
Log logAnnotation = getAnnotation(joinPoint);
// 封装webLog对象
webLog.setMethodType(logAnnotation.methodType().name());
webLog.setDescription(logAnnotation.description());
webLog.setTimeCost((int) timeCost);
webLog.setStartTime(start);
webLog.setIpAddress(request.getRemoteAddr());
webLog.setHttpMethod(request.getMethod());
webLog.setParams(getParams(joinPoint));
webLog.setResult(result);
webLog.setUri(request.getRequestURI());
webLog.setUrl(request.getRequestURL().toString());
log.info("{}", JSONUtil.parse(webLog));
} catch (Throwable e) {
log.info("==================异常通知=====================");
log.error(e.getMessage());
throw new Throwable(e);
}finally {
log.info("=================后置通知=====================");
}
return result;
}
/**
* 获取方法上的注解
*/
private Log getAnnotation(ProceedingJoinPoint joinPoint) {
Method method = ((MethodSignature) joinPoint.getSignature()).getMethod();
return method.getAnnotation(Log.class);
}
/**
* 获取参数 params:{"name":"天乔巴夏"}
*/
private Object getParams(ProceedingJoinPoint joinPoint) {
// 参数名
String[] paramNames = getMethodSignature(joinPoint).getParameterNames();
// 参数值
Object[] paramValues = joinPoint.getArgs();
// 存储参数
Map<String, Object> params = new LinkedHashMap<>();
for (int i = 0; i < paramNames.length; i++) {
Object value = paramValues[i];
// MultipartFile对象以文件名作为参数值
if (value instanceof MultipartFile) {
MultipartFile file = (MultipartFile) value;
value = file.getOriginalFilename();
}
params.put(paramNames[i], value);
}
return params;
}
private MethodSignature getMethodSignature(ProceedingJoinPoint joinPoint) {
return (MethodSignature) joinPoint.getSignature();
}
private HttpServletRequest getRequest() {
ServletRequestAttributes requestAttributes =
(ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
return requestAttributes.getRequest();
}
}
测试
POST http://localhost:8081/hello
Content-Type: application/json
{ "id" : 1, "username" : "天乔巴夏", "age": 18 }
结果
=================前置通知=====================
=================返回通知=====================
{"ipAddress":"127.0.0.1","description":"hello post","httpMethod":"POST","params":{"user":{"id":1,"age":18,"username":"天乔巴夏"}},"uri":"/hello","url":"http://localhost:8081/hello","result":"hello","methodType":"INSERT","startTime":1605596028383,"timeCost":28}
=================后置通知=====================
下面是AfterReturing和AfterThrowing的示例
@Pointcut("@annotation(com.xx.xx.service.annotation.QueryLog)")
public void pointCut() {
}
@AfterReturning(value = "pointCut()", returning = "returnValue")
public void processWhenSuccess(JoinPoint joinPoint, Object returnValue) {
try {
Object params = getParams(joinPoint);
String requestParams = JsonUtil.toJSONString(params);
log.error("请求参数{}", requestParams);
String result = JsonUtil.toJSONString(returnValue);
Object queryDTO = ((LinkedHashMap) params).get("querySchemaDTO");
if (queryDTO instanceof QuerySchemaDTO) {
QuerySchemaDTO schemaDTO = (QuerySchemaDTO) queryDTO;
QueryLogDTO queryLogDTO = getQueryLogDTO(result, schemaDTO, null);
asyncSaveLog(queryLogDTO);
}
} catch (Exception e) {
log.error("存储查询日志出错{}", e);
}
}@AfterThrowing(value = "pointCut()", throwing = "exception")
public void processWhenException(JoinPoint joinPoint, Exception exception) throws Exception {
try {
Object params = getParams(joinPoint);
String requestParams = JsonUtil.toJSONString(params);
log.error("请求参数{}", requestParams);
Object queryDTO = ((LinkedHashMap) params).get("querySchemaDTO");
if (queryDTO instanceof QuerySchemaDTO) {
QuerySchemaDTO schemaDTO = (QuerySchemaDTO) queryDTO;
QueryLogDTO queryLogDTO = getQueryLogDTO(null, schemaDTO, exception);
asyncSaveLog(queryLogDTO);
}
} catch (Exception e) {
log.error("存储查询日志出错{}", e);
}
throw exception;
}原文地址：https://blog.csdn.net/qq_29235677/article/details/136257526
免责声明：本站文章内容转载自网络资源，如本站内容侵犯了原著者的合法权益，可联系本站删除。更多内容请关注自学内容网（zxcms.com）！