skywalking09 - 异步线程链路续接（上）

不知道你是不是也出现过，明明打了@Trace，但是死活从http请求的链路进来看不到，反而，它还独自成一条链路，这样一来，根本连不成一个链路来追踪问题了。

断掉的链路

异步代码

此处，用了线程池去异步执行一个实现Runnable接口的类。

    @Trace
    public void trace() throws InterruptedException {
        Thread.sleep(10);
        doNothing();
        executor.submit(new MyRunnable());
    }

以及该接口具体实现

public class MyRunnable implements Runnable{

    @Override
    public void run() {
        System.out.println(TraceContext.traceId());
        doNothing();
    }

    @Trace
    private void doNothing(){
        return;
    }
}

链路断开示意图

理想中，我们自然也是希望异步线程中@Trace加注的方法也进入对应的链路，但是很遗憾，链路断成两条了：

MyRunnable中的doNothing并没有在/trace/local这个http请求中打印出来。

连上的链路

链路连上示意图

我们会发现，链路仍然有两条存在，但是，/trace/local这个http请求中打印出来多了两个Span，一个是异步线程，一个是添加了@Trace的自定义的方法。而且，这两条链路的链路流水号是同一个。

实现方式

• @TraceCrossThread
• @Async
• apm-jdk-threading-plugin

三种方式都可以实现，稍微做点比较。

@TraceCrossThread

@TraceCrossThread为skywalking提供的工具包中的注解，你可以认为其有一定的侵入性。使用方式则是在那个线程类上加上该注解，在类加载时，其构造方法会被代理agent做一次增强，具体的源码下一节说。

@TraceCrossThread
public class MyRunnable implements Runnable{

    @Override
    public void run() {
        System.out.println(TraceContext.traceId());
        doNothing();

    }
}

@Async

@Async为spring-context包下的注解，对于java服务端来说，这个注解基本可以算无侵入了，毕竟是spring体系。不过使用方式和平时需要实现一个Runnable接口或继承Thread类差别挺大，个人觉得方便，但是在古董项目中、亦或是说服那些一年学习经验十年使用经验的老古董来说，推广起来还是比较头疼的。当然，如果是一个巨石的老项目，不推荐这样来改造了。

@Service
public class TraceService implements InitializingBean {

    @Trace
    @Async
    public void traceAsync() throws InterruptedException {
        Thread.sleep(10);
        doNothing();

    }

    @Trace
    public void trace() throws InterruptedException {
        Thread.sleep(10);
        doNothing();
        executor.submit(new MyRunnable());
    }
}

关于这个注解的详细使用可以见：JAVA多线程以及Spring异步注解@Async。效果图如下，其会多一个SpringAsync的链路，当然其链路流水号也是相同的：

apm-jdk-threading-plugin

apm-jdk-threading-plugin这是官方提供的一个插件，是真正的无侵入了，使用方式也很简单，这个插件位于${skywalking_dir}/agent/bootstrap-plugins目录下，我们需要做的就是将其复制到${skywalking_dir}/agent/plugins目录下即可。

另外，还需要对代理的配置进行修改${skywalking_dir}/agent/config/agent.config，告诉代理对那些包下的线程池进行增强,在其底部添加这样的配置：

jdkthreading.threading_class_prefixes=com.aaa.bbb,com.bbb.ccc

当有多个包的时候，可以用英文的逗号进行分隔。

总结

多线程可能会导致链路断开，我们的链路续接不上，很多问题就没有办法查，要根据合适的方式，将链路接上。