注解实现全局日志记录

注解实现全局日志记录

1：自定义注解
2：切面获取参数
3：请求添加注解

1：自定义注解

import java.lang.annotation.*;

/**
 * ClassName Crmlog
 * AOP日志记录 自定义注解类
 */
@Target({ElementType.PARAMETER, ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface syslog {
    /**
     * 日志描述
     */
    String description()  default "";
}

2：切面获取参数

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.serializer.SerializerFeature;
import com.wk.annotation.syslog;
import com.wk.pojo.CrmLogMessage;
import com.wk.service.TestService;
import com.wk.utils.SnowflakeIdWorker;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.ArrayUtils;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.Signature;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Pointcut;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.core.annotation.Order;
import org.springframework.stereotype.Component;
import org.springframework.web.context.request.RequestContextHolder;
import org.springframework.web.context.request.ServletRequestAttributes;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.lang.reflect.Method;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;


//切面类  http://my.oschina.net/yangzg/blog/343945
/*
 * 特别注意： Spring的配置文件中添加：
 *
 * <aop:aspectj-autoproxy />
 * spring-mvc-dispatcher.xml中天机
 * <!--通知spring使用cglib而不是jdk的来生成代理方法 AOP可以拦截到Controller-->
 * <aop:aspectj-autoproxy proxy-target-class="true"/>
 *
 * <aop:config>节点中proxy-target-class="true"不为true时。
 * 当登录的时候会报这个异常java.lang.NoSuchMethodException: $Proxy54.login()，
 */

@Slf4j
@Aspect
@Component
public class SysLogAspect {
    SnowflakeIdWorker snowflakeIdWorker = new SnowflakeIdWorker(10, 10);
    @Autowired
    TestService testService;
    // 定义切入点
    @Pointcut("@annotation(com.wk.annotation.syslog)")
    public void syslog() {
        int a = 0;
    }

    /**
     * 环绕通知 用于拦截指定内容，记录用户的操作
     */
    @Around(value = "@annotation(syslog)")
    @Order(0)
    public Object interceptorApplogic(ProceedingJoinPoint pj, syslog syslog) throws Throwable {
        long start = System.currentTimeMillis();
        ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
        HttpServletRequest request = attributes.getRequest();
        String requestURI = request.getRequestURI();
        String description = syslog.description();
        Object[] args = pj.getArgs();
        Signature signature = pj.getSignature();
        List<Object> list = new ArrayList<>();
        if (ArrayUtils.isNotEmpty(args)) {
            for (Object arg : args) {
                if (arg instanceof HttpServletResponse) {
                    continue;
                } else if (arg instanceof HttpServletRequest) {
                    String source = ((HttpServletRequest) arg).getHeader("source");
                } else {
                    list.add(arg);
                }
            }
        }
        String input = JSONArray.toJSONString(list, SerializerFeature.WriteNullStringAsEmpty);
        System.out.println("input:" + input);
        Object proceed = null;
        try {
            proceed = pj.proceed(args);
        } catch (Throwable throwable) {
            throwable.printStackTrace();
        } finally {
            long end = System.currentTimeMillis();
            String output = JSONArray.toJSONString(proceed, SerializerFeature.WriteNullStringAsEmpty);
            System.out.println("output:" + output);
            CrmLogMessage log = new CrmLogMessage();
            log.setContent(input);
            log.setLogid(snowflakeIdWorker.workerId);
            log.setDateTime(end - start);
            log.setResult(output);
            log.setRequestUrl(requestURI);
            log.setRemarks(description);
            System.out.println("CrmLogMessage:" + log.toString());
            testService.insert(log);
        }


        return proceed;
    }

}

3：请求添加注解

@syslog(description = "拦截接口")
    @GetMapping("/b")
    public String b(String param,HttpServletRequest request){
        System.out.println(" b= 1");
        String t=testService.getLog("input");
        System.out.println(" c= 1");
        return "hello";
    }

验证获取参数