springboot整合AOP,实现log操作日志

发布时间：2024-12-10 00:58

与志同道合的朋友合作实现目标 #生活乐趣# #社交圈子#

添加依赖

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-aop</artifactId>

</dependency>

编写注解

package com.ly.common.annotation;

import com.ly.common.enums.BusinessType;

import com.ly.common.enums.OperatorType;

import java.lang.annotation.*;

/**

@Target({ ElementType.PARAMETER, ElementType.METHOD })

@Retention(RetentionPolicy.RUNTIME)

@Documented

public @interface Log

{

/**

String title() default "";

/**

BusinessType businessType() default BusinessType.OTHER;

/**

OperatorType operatorType() default OperatorType.MANAGE;

/**

boolean isSaveRequestData() default true;

}

编写aop

package com.ly.provider.aspectj;

import com.ly.common.annotation.Log;

import com.ly.common.enums.BusinessStatus;

import com.ly.common.utils.ServletUtils;

import com.ly.common.utils.json.JsonUtils;

import com.ly.provider.sys.Service.SysOperLogService;

import com.ly.provider.sys.entity.SysOperLog;

import org.aspectj.lang.JoinPoint;

import org.aspectj.lang.Signature;

import org.aspectj.lang.annotation.*;

import org.aspectj.lang.reflect.MethodSignature;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Component;

import java.lang.reflect.Method;

import java.util.Map;

/**

@Aspect

@Component

public class LogAspect

{

private static final Logger log = LoggerFactory.getLogger(LogAspect.class);

@Autowired

private SysOperLogService sysOperLogService;

// 配置织入点

@Pointcut("@annotation(com.ly.common.annotation.Log)")

public void logPointCut()

{

}

@Before("logPointCut()")

public void dobefore(){

log.info("====>切面之前会执行");

}

/**

@After("logPointCut()")

public void doAfter(){

log.info("====>切面执行之后");

}

@AfterReturning(value = "logPointCut()",returning = "result")

public void AfterReturning(Object result){

log.info("====>执行结果返回值："+result.toString() );

}

/**

@AfterReturning(pointcut = "logPointCut()")

public void doBefore(JoinPoint joinPoint)

{

handleLog(joinPoint, null);

}

/**

@AfterThrowing(value = "logPointCut()", throwing = "e")

public void doAfter(JoinPoint joinPoint, Exception e)

{

handleLog(joinPoint, e);

}

protected void handleLog(final JoinPoint joinPoint, final Exception e)

{

try

{

// 获得注解

Log controllerLog = getAnnotationLog(joinPoint);

if (controllerLog == null)

{

return;

}

// 获取当前的用户

//SysUser currentUser = ShiroUtils.getUser();

// *========数据库日志=========*//

SysOperLog operLog = new SysOperLog();

operLog.setStatus(BusinessStatus.SUCCESS.ordinal());

// 请求的地址

String ip = "192.168.24.63";

operLog.setOperIp(ip);

operLog.setOperUrl(ServletUtils.getRequest().getRequestURI());

operLog.setOperName("liyu");

// if (currentUser != null)

// {

// operLog.setOperName(currentUser.getLoginName());

// if (StringUtils.isNotNull(currentUser.getDept())

// && StringUtils.isNotEmpty(currentUser.getDept().getDeptName()))

// {

// operLog.setDeptName(currentUser.getDept().getDeptName());

// }

if (e != null)

{

operLog.setStatus(BusinessStatus.FAIL.ordinal());

operLog.setErrorMsg(e.getMessage().toString());

}

// 设置方法名称

String className = joinPoint.getTarget().getClass().getName();

String methodName = joinPoint.getSignature().getName();

operLog.setMethod(className + "." + methodName + "()");

// 处理设置注解上的参数

getControllerMethodDescription(controllerLog, operLog);

// 保存数据库

// AsyncManager.me().execute(AsyncFactory.recordOper(operLog));

sysOperLogService.insertSysOperLog(operLog);

}

catch (Exception exp)

{

// 记录本地异常日志

log.error("==LogAspect异常==");

log.error("异常信息:{}", exp.getMessage());

exp.printStackTrace();

}

/**

public void getControllerMethodDescription(Log log, SysOperLog operLog) throws Exception

{

// 设置action动作

operLog.setBusinessType(log.businessType().ordinal());

// 设置标题

operLog.setTitle(log.title());

// 设置操作人类别

operLog.setOperatorType(log.operatorType().ordinal());

// 是否需要保存request，参数和值

if (log.isSaveRequestData())

{

// 获取参数的信息，传入到数据库中。

setRequestParam(operLog);

}

/**

private void setRequestParam(SysOperLog operLog) throws Exception

{

Map<String, String[]> map = ServletUtils.getRequest().getParameterMap();

String params = JsonUtils.ObjToJsonStr(map);

int len=params.length();

operLog.setOperParam(params);

}

/**

private Log getAnnotationLog(JoinPoint joinPoint) throws Exception

{

Signature signature = joinPoint.getSignature();

MethodSignature methodSignature = (MethodSignature) signature;

Method method = methodSignature.getMethod();

if (method != null)

{

return method.getAnnotation(Log.class);

}

return null;

}

/**

@Log(title = "文章列表", businessType = BusinessType.INSERT)

@RequestMapping("/list")

public String list(@RequestParam(defaultValue = "1") int page ,@RequestParam(defaultValue = "10") int limit,ModelMap mmap){

Map<String,Object> params = new HashMap<String,Object>();

params.put("page",page);

params.put("limit",limit);

Query query = new Query(params);

List<Article> list = articleService.queryList(query);

mmap.addAttribute("articles",list);

return "/article/articleList";

}

访问上图的api，注意：假如你的注解

@Log(title = "文章列表", businessType = BusinessType.INSERT)和LogAspect不在同一个项目或者同一个包，有可能上面的注解语句失效，调试的时候进入不了LogAspect，那是因为程序没有扫描到你的切面类，处理方法是在启动类里面添加logAspect所在的包的的路径，代码如下

package com.ly.provider;

import org.springframework.boot.SpringApplication;

import org.springframework.boot.autoconfigure.SpringBootApplication;

import org.springframework.context.annotation.ComponentScan;

@SpringBootApplication

@ComponentScan("com.ly.*")

public class ProviderApplication {

public static void main(String[] args) {

SpringApplication.run(ProviderApplication.class, args);

}

网址：springboot整合AOP,实现log操作日志 https://www.yuejiaxmz.com/news/view/429590

⬅️上一篇：利用weixin://dl/bu