怎么在SpringBoot中使用AOP技术操作日志
怎么在SpringBoot中使用AOP技术操作日志?相信很多没有经验的人对此束手无策,为此本文总结了问题出现的原因和解决方法,通过这篇文章希望你能解决这个问题。
一、基本概念
| 项目 | 描述 |
|---|---|
| Aspect(切面) | 跨越多个类的关注点的模块化,切面是通知和切点的结合。通知和切点共同定义了切面的全部内容——它是什么,在何时和何处完成其功能。事务处理和日志处理可以理解为切面 |
| Join point(连接点) | 程序执行过程中的一个点,如方法的执行或异常的处理 |
| Advice(通知) | 切面在特定连接点上采取的动作 |
| Pointcut(切点) | 匹配连接点的断言。通知与切入点表达式相关联,并在切入点匹配的任何连接点上运行(例如,具有特定名称的方法的执行)。切入点表达式匹配的连接点概念是AOP的核心,Spring默认使用AspectJ切入点表达式语言 |
| Introduction(引用) | 为类型声明其他方法或字段。Spring AOP允许您向任何建议的对象引入新的接口(和相应的实现)。例如,您可以使用介绍使bean实现IsModified接口,以简化缓存 |
| Target object(目标) | 由一个或多个切面通知的对象。也称为“通知对象”。由于Spring AOP是通过使用运行时代理实现的,所以这个对象始终是代理对象 |
| AOP proxy(代理) | AOP框架为实现切面契约(通知方法执行等)而创建的对象。在Spring框架中,AOP代理是JDK动态代理或CGLIB代理 |
| Weaving(织入) | 织入是将通知添加对目标类具体连接点上的过程,可以在编译时(例如使用AspectJ编译器)、加载时或运行时完成 |
Spring切面可以应用5种类型的通知:
前置通知(Before):在目标方法被调用之前调用通知
后置通知(After):在目标方法完成之后调用通知(无论是正常还是异常退出)
返回通知(After-returning):在目标方法成功执行之后调用通知
异常通知(After-throwing):在目标方法抛出异常后调用通知
环绕通知(Around):通知包裹了被通知的方法,在被通知的方法调用之前和调用之后执行自定义的行为
其执行的顺序为:
后续的基本应用,会将 环绕通知、前置通知、后置通知、返回通知、异常通知进行实现,并演示其执行顺序。
二、基本应用
声明通知大家可以将下面的代码复制出来,验证上面的执行顺序。
@Aspect
publicclassTest{
privatestaticintstep=0;
@Pointcut("@annotation(com.chenyanwu.erp.erpframework.annotation.Log)")//thepointcutexpression
privatevoidoperation(){}
@Before("operation()")
publicvoiddoBeforeTask(){
System.out.println(++step+"前置通知");
}
@After("operation()")
publicvoiddoAfterTask(){
System.out.println(++step+"后置通知");
}
@AfterReturning(pointcut="operation()",returning="retVal")
publicvoiddoAfterReturnningTask(ObjectretVal){
System.out.println(++step+"返回通知,返回值为:"+retVal.toString());
}
@AfterThrowing(pointcut="operation()",throwing="ex")
publicvoiddoAfterThrowingTask(Exceptionex){
System.out.println(++step+"异常通知,异常信息为:"+ex.getMessage());
}
/**
*环绕通知需要携带ProceedingJoinPoint类型的参数
*环绕通知类似于动态代理的全过程ProceedingJoinPoint类型的参数可以决定是否执行目标方法
*且环绕通知必须有返回值,返回值即目标方法的返回值
*/
//@Around("operation()")
publicObjectdoAroundTask(ProceedingJoinPointpjp){
Stringmethodname=pjp.getSignature().getName();
Objectresult=null;
try{
//前置通知
System.out.println("目标方法"+methodname+"开始,参数为"+Arrays.asList(pjp.getArgs()));
//执行目标方法
result=pjp.proceed();
//返回通知
System.out.println("目标方法"+methodname+"执行成功,返回"+result);
}catch(Throwablee){
//异常通知
System.out.println("目标方法"+methodname+"抛出异常:"+e.getMessage());
}
//后置通知
System.out.println("目标方法"+methodname+"结束");
returnresult;
}
}其中需要注意的是切入点:@Pointcut的表达式格式:
execution(modifiers-pattern? ret-type-pattern declaring-type-pattern? name-pattern(param-pattern)throws-pattern?)括号中各个pattern分别表示:
修饰符匹配(modifier-pattern?)
返回值匹配(ret-type-pattern)可以为*表示任何返回值,全路径的类名等
类路径匹配(declaring-type-pattern?)
方法名匹配(name-pattern)可以指定方法名 或者 代表所有, set 代表以set开头的所有方法
参数匹配((param-pattern))可以指定具体的参数类型,多个参数间用“,”隔开,各个参数也可以用“”来表示- 匹配任意类型的参数,如(String)表示匹配一个String参数的方法;(,String) 表示匹配有两个参数的方法,第一个参数可以是任意类型,而第二个参数是String类型;可以用(…)表示零个或多个任意参数
异常类型匹配(throws-pattern?)
其中后面跟着“?”的是可选项
示例:
1)execution(* (…))//表示匹配所有方法2)execution(public * com. savage.service.UserService.(…))//表示匹配com.savage.server.UserService中所有的公有方法3)execution(* com.savage.server….(…))//表示匹配com.savage.server包及其子包下的所有方法
三、日志管理实战
有了上面基本应用的理解,现在我们直接就贴代码:
1、依赖的jar包
org.springframework.boot spring-boot-starter-aop
2、自定义注解
@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public@interfaceLog{
Stringvalue()default"";
}3、实现切面
@Aspect
@Order(5)
@Component
publicclassLogAspect{
privateLoggerlogger=LoggerFactory.getLogger(LogAspect.class);
@Autowired
privateErpLogServicelogService;
@Autowired
ObjectMapperobjectMapper;
privateThreadLocalstartTime=newThreadLocal();
@Pointcut("@annotation(com.chenyanwu.erp.erpframework.annotation.Log)")
publicvoidpointcut(){
}
/**
*前置通知,在Controller层操作前拦截
*
*@paramjoinPoint切入点
*/
@Before("pointcut()")
publicvoiddoBefore(JoinPointjoinPoint){
//获取当前调用时间
startTime.set(newDate());
}
/**
*正常情况返回
*
*@paramjoinPoint切入点
*@paramrvt正常结果
*/
@AfterReturning(pointcut="pointcut()",returning="rvt")
publicvoiddoAfter(JoinPointjoinPoint,Objectrvt)throwsException{
handleLog(joinPoint,null,rvt);
}
/**
*异常信息拦截
*
*@paramjoinPoint
*@parame
*/
@AfterThrowing(pointcut="pointcut()",throwing="e")
publicvoiddoAfter(JoinPointjoinPoint,Exceptione)throwsException{
handleLog(joinPoint,e,null);
}
@Async
privatevoidhandleLog(finalJoinPointjoinPoint,finalExceptione,Objectrvt)throwsException{
//获得注解
Methodmethod=getMethod(joinPoint);
Loglog=getAnnotationLog(method);
if(log==null){
return;
}
Datenow=newDate();
//操作数据库日志表
ErpLogerpLog=newErpLog();
erpLog.setErrorCode(0);
erpLog.setIsDeleted(0);
//请求信息
HttpServletRequestrequest=ToolUtil.getRequest();
erpLog.setType(ToolUtil.isAjaxRequest(request)?"Ajax请求":"普通请求");
erpLog.setTitle(log.value());
erpLog.setHost(request.getRemoteHost());
erpLog.setUri(request.getRequestURI().toString());
//erpLog.setHeader(request.getHeader(HttpHeaders.USER_AGENT));
erpLog.setHttpMethod(request.getMethod());
erpLog.setClassMethod(joinPoint.getSignature().getDeclaringTypeName()+"."+joinPoint.getSignature().getName());
//请求的方法参数值
Object[]args=joinPoint.getArgs();
//请求的方法参数名称
LocalVariableTableParameterNameDiscovereru
=newLocalVariableTableParameterNameDiscoverer();
String[]paramNames=u.getParameterNames(method);
if(args!=null&¶mNames!=null){
StringBuilderparams=newStringBuilder();
params=handleParams(params,args,Arrays.asList(paramNames));
erpLog.setParams(params.toString());
}
StringretString=JsonUtil.bean2Json(rvt);
erpLog.setResponseValue(retString.length()>5000?JsonUtil.bean2Json("请求参数数据过长不与显示"):retString);
if(e!=null){
erpLog.setErrorCode(1);
erpLog.setErrorMessage(e.getMessage());
}
Datestime=startTime.get();
erpLog.setStartTime(stime);
erpLog.setEndTime(now);
erpLog.setExecuteTime(now.getTime()-stime.getTime());
erpLog.setUsername(MySysUser.loginName());
HashMapbrowserMap=ToolUtil.getOsAndBrowserInfo(request);
erpLog.setOperatingSystem(browserMap.get("os"));
erpLog.setBrower(browserMap.get("browser"));
erpLog.setId(IdUtil.simpleUUID());
logService.insertSelective(erpLog);
}
/**
*是否存在注解,如果存在就获取
*/
privateLoggetAnnotationLog(Methodmethod){
if(method!=null){
returnmethod.getAnnotation(Log.class);
}
returnnull;
}
privateMethodgetMethod(JoinPointjoinPoint){
Signaturesignature=joinPoint.getSignature();
MethodSignaturemethodSignature=(MethodSignature)signature;
Methodmethod=methodSignature.getMethod();
if(method!=null){
returnmethod;
}
returnnull;
}
privateStringBuilderhandleParams(StringBuilderparams,Object[]args,ListparamNames)throwsJsonProcessingException{
for(inti=0;i();
for(Objectkey:set){
list.add(((Map)args[i]).get(key));
paramList.add(key);
}
returnhandleParams(params,list.toArray(),paramList);
}else{
if(args[i]instanceofSerializable){
Class>aClass=args[i].getClass();
try{
aClass.getDeclaredMethod("toString",newClass[]{null});
//如果不抛出NoSuchMethodException异常则存在toString方法,安全的writeValueAsString,否则走Object的toString方法
params.append("").append(paramNames.get(i)).append(":").append(objectMapper.writeValueAsString(args[i]));
}catch(NoSuchMethodExceptione){
params.append("").append(paramNames.get(i)).append(":").append(objectMapper.writeValueAsString(args[i].toString()));
}
}elseif(args[i]instanceofMultipartFile){
MultipartFilefile=(MultipartFile)args[i];
params.append("").append(paramNames.get(i)).append(":").append(file.getName());
}else{
params.append("").append(paramNames.get(i)).append(":").append(args[i]);
}
}
}
returnparams;
}
} 4、对应代码添加注解
@Log("新增学生")
@RequestMapping(value="/create",method=RequestMethod.POST)
@ResponseBody
publicResultBeancreate(@RequestBody@ValidatedErpStudentitem){
if(service.insertSelective(item)==1){
//插入
insertErpSFamilyMember(item);
returnnewResultBean("");
}
returnnewResultBean(ExceptionEnum.BUSINESS_ERROR,"新增学生异常!","新增失败!","");
} 看完上述内容,你们掌握怎么在SpringBoot中使用AOP技术操作日志的方法了吗?如果还想学到更多技能或想了解更多相关内容,欢迎关注恰卡编程网行业资讯频道,感谢各位的阅读!
推荐阅读
-
vue动态添加删除输入框(springboot vue怎么让数据库显示出来)
springbootvue怎么让数据库显示出来?一般情况下是前端调阅后端接口,来获取到数据库的数据,后端哪里会把数据库的数据整理...
-
springboot实现基于aop的切面日志
本文实例为大家分享了springboot实现基于aop的切面日志的具体代码,供大家参考,具体内容如下通过aop的切面方式实现日志...
-
SpringBoot定时任务功能怎么实现
-
SpringBoot中的@Import注解怎么使用
-
SpringBoot整合Lombok及常见问题怎么解决
SpringBoot整合Lombok及常见问题怎么解决这篇文章主要...
-
springboot图片验证码功能模块怎么实现
springboot图片验证码功能模块怎么实现本篇内容主要讲解“s...
-
Springboot+SpringSecurity怎么实现图片验证码登录
-
SpringBoot注解的知识点有哪些
SpringBoot注解的知识点有哪些这篇“SpringBoot注...
-
SpringBoot2.x中management.security.enabled=false无效怎么解决
SpringBoot2.x中management.security.enabled=false无效怎么解决...
-
springboot怎么禁用某项健康检查
springboot怎么禁用某项健康检查今天小编给大家分享一下sp...
