日志追踪系统实现

@Aspect
public class TraceAspect {
    private static final Logger log = LoggerFactory.getLogger(TraceAspect.class);
    @Pointcut("execution(* com.fkhwl.fkhserver.rest.resource.impl..*.*(..))")
    public void profileMethod() {

    }
    @Around("profileMethod()")
    public Object profile(ProceedingJoinPoint jp) {
        Object result = "";
        String methodName = jp.getSignature().getName();
        log.error("前置通知");
        //执行目标方法
        try {
            //前置通知
            log.error("The method " + methodName + " begins with " + Arrays.asList(jp.getArgs()));
            result = jp.proceed();
            //返回通知
            log.error("The method " + methodName + " ends with " + Arrays.asList(jp.getArgs()));
        } catch (Throwable e) {
            //异常通知
            log.error("The method " + methodName + " occurs expection : " + e);
            throw new RuntimeException(e);
        }
        log.error("get MDC {}", MDC.get(Span.TRACE_ID));
        return result;
    }
}

<?xml version="1.0" encoding="UTF-8"?>
<aspectj>
    <weaver>
        <!-- only weave classes in your application-specific packages -->
        <include within="com.fkhwl.fkhserver.rest.resource.impl.*"/>
        <!-- 必须包含切面的路径 -->
        <include within="com.fkhwl.trace.client.aspect.*"/>
    </weaver>
    <aspects>
        <!-- weave in just these aspects -->
        <aspect name="com.fkhwl.trace.client.aspect.TraceAspect"/>
    </aspects>
</aspectj>

import com.alibaba.dubbo.common.extension.Activate;
import com.alibaba.dubbo.rpc.Filter;
@Activate 
// 无条件自动激活
public class XxxFilter implements Filter {
    // ...
}

import com.alibaba.dubbo.common.extension.Activate;
import com.alibaba.dubbo.rpc.Filter;
@Activate("xxx") // 当配置了xxx参数, 并且参数为有效值时激活, 比如配了cache="lru", 自动激活CacheFilter. 
public class XxxFilter implements Filter {
    // ...
}

import com.alibaba.dubbo.common.extension.Activate;
import com.alibaba.dubbo.rpc.Filter;
@Activate(group = {Constants.PROVIDER, Constants.CONSUMER})
// 只对提供方激活, group可选"provider"或"consumer"
public class XxxFilter implements Filter {
    // ...
}

/** 
 * 在调用service的接口之前, 加入一些dubbo的隐式参数 
 * 2017-12-13 17:34 dong4j 
 */  
@Aspect  
@Component  
public class DubboServiceContextAop {  
  
    @Pointcut("execution(* com.xxx.xxx.service.*.*(..))")  
    public void serviceApi() {  
    }  
  
    @Before("serviceApi()")  
    public void dubboContext(JoinPoint jp) {  
        Map<String, String> context = new HashMap<>();  
        // todo you want do  
        RpcContext.getContext().setAttachments(context);  
    }   
} 

public class DubboContextFilter implements Filter {  
    @Override  
    public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException {  
        String var= RpcContext.getContext().getAttachment(从Aop中放入的);  
        //todo 其他相关处理  
        return invoker.invoke(invocation);  
    }  
} 

// 远程调用
xxxService.xxx();
// 本端是否为消费端, 这里会返回true
boolean isConsumerSide = RpcContext.getContext().isConsumerSide();
// 获取最后一次调用的提供方IP地址
String serverIP = RpcContext.getContext().getRemoteHost();
// 获取当前服务配置信息, 所有配置信息都将转换为URL的参数
String application = RpcContext.getContext().getUrl().getParameter("application");
// 注意: 每发起RPC调用, 上下文状态会变化
yyyService.yyy();

public class XxxServiceImpl implements XxxService {
public void xxx() {
    // 本端是否为提供端, 这里会返回true
    boolean isProviderSide = RpcContext.getContext().isProviderSide();
    // 获取调用方IP地址
    String clientIP = RpcContext.getContext().getRemoteHost();
    // 获取当前服务配置信息, 所有配置信息都将转换为URL的参数
    String application = RpcContext.getContext().getUrl().getParameter("applicatio
    n");
    // 注意: 每发起RPC调用, 上下文状态会变化
    yyyService.yyy();
    // 此时本端变成消费端, 这里会返回false
    boolean isProviderSide = RpcContext.getContext().isProviderSide();
    }
}

@Slf4j
public class LoggerFilter extends AbstractRequestLoggingFilter {
    @Override
    protected void doFilterInternal(HttpServletRequest request, HttpServletResponse response,
                                    final FilterChain filterChain)
        throws ServletException, IOException {
        final String traceId = "" + new SnowflakeId(0).generate();
        MDC.put(Span.TRACE_ID, traceId);
    
        ...
        super.doFilterInternal(request, response, filterChain);
        ...
        log.error(ApiLog.buildApiLog(EventType.invoke_interface, request.getRequestURI(), request.getHeader("token"), response.getStatus(), EventLog.MONITOR_STATUS_SUCCESS, "我是mock api成功日志").toString());
        // 请求处理完成后清理 MDC 中的值
        MDC.remove(Span.TRACE_ID);
    }
    @Override
    protected void beforeRequest(HttpServletRequest request, String message) {
    }
    
    @Override
    protected void afterRequest(HttpServletRequest request, String message) {
    }
}

@Component
@Slf4j
public class ApplicationEventHandle implements ApplicationListener, ApplicationContextAware {
    @Autowired
    private TraceConfig traceConfig;
    // 注入 ServletContext
    @Autowired
    private ServletContext servletContext;


    /**
     * Sets application context.
     * 获取应用上下文, 从而获取 speing 管理的 bean
     * @param applicationContext the application context
     * @throws BeansException the beans exception
     */
    @Override
    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {    }
    
    /**
     * On application event.
     * 监听应用启动事件
     * @param applicationEvent the application event
     */
    @Override
    public void onApplicationEvent(ApplicationEvent applicationEvent) {
        if (applicationEvent instanceof ContextRefreshedEvent) {
            ContextRefreshedEvent contextRefreshedEvent = (ContextRefreshedEvent) applicationEvent;
            //root application context 没有parent, 他就是老大.
            if (contextRefreshedEvent.getApplicationContext().getParent() == null) {
                //需要执行的逻辑代码, 当spring容器初始化完成后就会执行该方法. 
                log.error("spring 容器初始化完成: {}", applicationEvent.getClass());
    
                // 获取 ServletContext 容器未初始化完成, 使用这种方式会报空指针
                // WebApplicationContext webApplicationContext = ContextLoader.getCurrentWebApplicationContext();
                // ServletContext servletContext = webApplicationContext.getServletContext();
                DynamicChangeLogLevel.initZookeeperNode(traceConfig.getZookeeperHost(), servletContext
                    .getServletContextName());
            }
        } // 应用启动, 需要在代码动态添加监听器才可捕获
        else if (applicationEvent instanceof ContextStartedEvent) {
            log.error("应用启动事件: {}", applicationEvent.getClass());
        }
        // 应用停止(context.stop();)
        else if (applicationEvent instanceof ContextStoppedEvent) {
            log.error("应用停止事件: {}", applicationEvent.getClass());
            // 防止动态修改日志级别时内存溢出
            LoggerContext loggerContext = (LoggerContext) LoggerFactory.getILoggerFactory();
            loggerContext.stop();
        }
        // 应用关闭(强制 stop)
        else if (applicationEvent instanceof ContextClosedEvent) {
            log.error("应用关闭事件: {}", applicationEvent.getClass());
        } else {
            log.error("其他事件: {}", applicationEvent.getClass());
        }
    }
}