skywalking09 - 异步线程链路续接(上)

x33g5p2x  于2021-12-21 转载在 其他  
字(1.9k)|赞(0)|评价(0)|浏览(1291)

不知道你是不是也出现过,明明打了@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

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

总结

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

相关文章