快捷導(dǎo)航

Spring?boot2.0?實(shí)現(xiàn)日志集成的方法(3)

更新時(shí)間：2022年04月21日 10:16:42 作者：劍圣無(wú)痕?

這篇文章主要介紹了Spring?boot2.0?實(shí)現(xiàn)日志集成的方法,基于上一篇將日志信息根據(jù)類(lèi)別輸出到不同的文件中，這篇文章將通過(guò)日志來(lái)監(jiān)控用戶(hù)的操作行為、請(qǐng)求的耗時(shí)情況，針對(duì)耗時(shí)久的請(qǐng)求進(jìn)行性能分析，提升系統(tǒng)性能，需要的小伙伴可以參考一下

前言

上一章Spring boot2.0 實(shí)現(xiàn)日志集成的方法(2)主要講解了將日志信息根據(jù)類(lèi)別輸出到不同的文件中，實(shí)際開(kāi)發(fā)中我們需要通過(guò)日志來(lái)監(jiān)控用戶(hù)的操作行為、請(qǐng)求的耗時(shí)情況，針對(duì)耗時(shí)久的請(qǐng)求進(jìn)行性能分析，提升系統(tǒng)性能。

具體實(shí)現(xiàn)

采用的Spring Aop切面技術(shù)來(lái)實(shí)現(xiàn)控用戶(hù)的操作行為、請(qǐng)求的耗時(shí)情況。

定義日志注解

@Target({ ElementType.METHOD })
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface LogAnnotation
{
    // 模塊
    String model() default "";

    // 功能
    String func() default "";

    //描述
    String desc() default "";
}

定義日志切面

@Aspect
@Component
public class LogAspect
{
    //請(qǐng)求監(jiān)控日志，輸出到不同日志文件
    public static Log logger = LogManager.getLogger("request-access");

    /**
     * 定義切面
     */
    @Pointcut("@annotation(com.test.aspect.LogAnnotation)")
    private void logPoinCut()
    {

    }
    
    /**
     * 
     * @param joinPoint
     */
    @Before(value = "logPoinCut()")
    public void doBefore(JoinPoint joinPoint)
    {
        String requestId =TraceIdUtil.getTraceId();
        logger.info("Start invoke requestID:[{}]",requestId);
    }
    
    @Around(value = "logPoinCut()")
    public Object doAround(ProceedingJoinPoint jp) throws Throwable
    {
        String requestId =TraceIdUtil.getTraceId();
        logger.info("Enter request start requestId :[{}]",requestId);
        ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder
                .getRequestAttributes();
        HttpServletRequest request = attributes.getRequest();
        MethodSignature signature = (MethodSignature) jp.getSignature();
        Method method = signature.getMethod();
        long startTime= System.currentTimeMillis();
        OperationLog operationLog = new OperationLog();
        LogAnnotation logAnnotation = method.getAnnotation(LogAnnotation.class);
        if (logAnnotation != null)
        {
            String model = logAnnotation.model();
            String func = logAnnotation.func();
            String desc = logAnnotation.desc();
            operationLog.setModel(model);
            operationLog.setFunc(func);
            operationLog.setDesc(desc);
        }

        String className = jp.getTarget().getClass().getName();
        String methodName = jp.getSignature().getName();
        String uri = request.getRequestURI();
        String ip = IpUtil.getIpAddr(request);
        operationLog.setClassName(className);
        operationLog.setMethodName(methodName);
        operationLog.setIp(ip);
        operationLog.setUri(uri);
        StringBuilder param = new StringBuilder();
        Object[] args = jp.getArgs();
        Object arg = null;
        for (int i = 0, j = args.length; i < j; i++)
        {
            arg = args[i];
            param.append("    ")
                    .append(arg == null ? null : args[i].toString());
            if (i != (j - 1))
            {
                param.append(",").append("\n");
            }
        }
        operationLog.setParam(param.toString());
        operationLog.setCreateDate(new Date());
        long endTime=System.currentTimeMillis()-startTime;
        //可以通過(guò)配置設(shè)置異常調(diào)用請(qǐng)求時(shí)間
        long costTime=3;
        operationLog.setCostTime(endTime);
        String logStr = JSON.toJSONString(operationLog);
         //將異常請(qǐng)求數(shù)據(jù)插入數(shù)據(jù)庫(kù)   
        if(endTime>costTime){
           //saveOpetionLog(operationLog);      
        }
        logger.info("invoke finish message:{}",logStr);
        Object obj = jp.proceed();
        return obj;
    }
    
    
    /**
     * 方法之后調(diào)用
     * @param joinPoint
     * @param returnValue 方法返回值
     */
    @AfterReturning(pointcut = "logPoinCut()")
    public void  doAfterReturning(JoinPoint joinPoint)
    {
        String requestId=TraceIdUtil.getTraceId();
        logger.info("End invoke request ID [{}]",requestId);
    }
}

基本使用

    @LogAnnotation(model="用戶(hù)管理",func="查詢(xún)用戶(hù)信息",desc="根據(jù)用戶(hù)名稱(chēng)")
    @GetMapping("getUserByName")
    public Result getUserByName(@RequestParam String name)
    {
        logger.info("getUserByName paramter name:[{}]",name);
        return Result.success(userService.getUserByName(name));
    }

輸出信息

{
     "className": "com.test.controller.UserController",
     "costTime": 19,
     "createDate": "2022/03/11 15:20:30",
     "createUser": "xx",
     "ip": "172.18.188.111",
     "methodName": "getUserByName",
     "param": "  zhangsan",
      "uri": "/user/getUserByName",
     "model":"用戶(hù)管理",
     "func":"查詢(xún)用戶(hù)信息",
     "desc":"根據(jù)用戶(hù)名稱(chēng)",
     "version": 0
}

對(duì)于一些敏感的信息需要進(jìn)行加密處理。針對(duì)異常的請(qǐng)求進(jìn)行分析和性能優(yōu)化。