@Aspect
public class TraceAspect {
    private static final Logger log = LoggerFactory.getLogger(TraceAspect.class);
    @Pointcut("execution(* com.xxx.server.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.xxx.server.rest.resource.impl.*"/>
        <!-- 必须包含切面的路径 -->
        <include within="com.xxx.trace.client.aspect.*"/>
    </weaver>
    <aspects>
        <!-- weave in just these aspects -->
        <aspect name="com.xxx.trace.client.aspect.TraceAspect"/>
    </aspects>
</aspectj>

<dependency>
    <groupId>org.aspectj</groupId>
    <artifactId>aspectjweaver</artifactId>
    <version>1.8.9</version>
</dependency>
<dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-aop</artifactId>
    <version>${spring-version}</version>
</dependency>

<context:load-time-weaver aspectj-weaving="autodetect"/>

-javaagent:/path/to/spring-instrument-4.3.3.RELEASE.jar
-javaagent:/path/to/aspectjweaver-1.8.9.jar

-javaagent:/path/to/aspectjweaver-1.8.9.jar

JAVA_OPTS="-javaagent:/path/to/spring-instrument-4.3.3.RELEASE.jar -javaagent:/path/to/aspectjweaver-1.8.9.jar"

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 {
// ...
}

tracingFilter=com.xxx.trace.client.dubbo.TracingFilter

/**
 * 在调用 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();
    }
}

<name> 应用名 </name>

<import resource="classpath:xxx-config.xml"/>

// job 执行仅仅处理失败的日志（成功的不做处理，所以只需要构造失败的日志）, 参数依次为 EventType(事件类型)、job 的 id 号、操作耗时、失败、具体自定义的日志内容
LOGGER.info(EventLog.buildEventLog(EventType.job_execute, "application_1477705439920_0544", 10, EventLog.MONITOR_STATUS_FAILED, "我是mock job exec失败日志").toString());

// 参数依次为 EventType(事件类型)、第三方名称、操作耗时、成功还是失败、具体自定义的日志内容
LOGGER.info(EventLog.buildEventLog(EventType.thirdparty_call, "xx1", 100, EventLog.MONITOR_STATUS_FAILED, "我是mock third 失败日志").toString());
LOGGER.info(EventLog.buildEventLog(EventType.thirdparty_call, "xx1", 100, EventLog.MONITOR_STATUS_SUCCESS, "我是mock third 成功日志").toString());
LOGGER.info(EventLog.buildEventLog(EventType.thirdparty_call, "xx2", 100, EventLog.MONITOR_STATUS_SUCCESS, "我是mock third 成功日志").toString());
LOGGER.info(EventLog.buildEventLog(EventType.thirdparty_call, "xx2", 100, EventLog.MONITOR_STATUS_FAILED, "我是mock third 失败日志").toString());