极简！一个注解就能创建Jaeger的Span

欢迎访问我的GitHub

https://域名/zq2599/blog_demos

内容：所有原创文章分类汇总及配套源码，涉及Java、Docker、Kubernetes、DevOPS等；

本篇概览

• 在《Jaeger开发入门(java版)》一文中，咱们编码实现了span的创建和上报，如下图红框，虽然代码量不大，但是把这些代码写在业务代码中，侵入性太强，很多程序员都不喜欢：

• 今天咱们试试AOP+自定义注解来解决上述问题，如下图，mock是个普通方法，添加了红框中的注解@MySpan，就会创建span然后上报到Jaeger，mock方法的代码没有任何改动：

• 通过上面两图的对比，可见注解非常简洁，接下来就实战上述手段，具体的步骤如下：

1. 新建web工程，里面有controller层，调用service层的服务Biz，服务Biz再调用另一个服务ChildBiz
2. 创建两个注解MySpan和MyChildSpan
3. 创建AOP类SpanAspect，负责处理所有被注解MySpan和MyChildSpan修饰的方法；
4. 把注解MySpan和MyChildSpan用在普通的服务Biz和ChildBiz上
5. 启动服务，验证功能；

源码下载

• 本篇实战中的完整源码可在GitHub下载到，地址和链接信息如下表所示(https://域名/zq2599/blog_demos)：

• 这个git项目中有多个文件夹，本篇的源码在spring-cloud-tutorials文件夹下，如下图红框所示：

• spring-cloud-tutorials文件夹下有多个子工程，本篇的代码是jaeger-annonation-demo，如下图红框所示：

编码

• 创建spring-cloud-tutorials的子工程jaeger-annonation-demo，其域名如下：

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://域名/POM/4.0.0"
         xmlns:xsi="http://域名/2001/XMLSchema-instance"
         xsi:schemaLocation="http://域名/POM/4.0.0 http://域名/xsd/maven-4.域名">
    <parent>
        <artifactId>spring-cloud-tutorials</artifactId>
        <groupId>域名ngcavalry</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>jaeger-annonation-demo</artifactId>

    <dependencies>
        <dependency>
            <groupId>域名ngcavalry</groupId>
            <artifactId>common</artifactId>
            <version>${域名ion}</version>
        </dependency>

        <dependency>
            <groupId>域名</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <dependency>
            <groupId>域名rib</groupId>
            <artifactId>opentracing-spring-jaeger-cloud-starter</artifactId>
        </dependency>

        <dependency>
            <groupId>域名ons</groupId>
            <artifactId>commons-lang3</artifactId>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>域名</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <configuration>
                    <layers>
                        <enabled>true</enabled>
                    </layers>
                </configuration>
            </plugin>
        </plugins>
    </build>
</project>

• 配置文件域名：

spring:
  application:
    name: jaeger-annonation-demo
opentracing:
  jaeger:
    enabled: true
    udp-sender:
      host: 127.0.0.1
      port: 6831
server:
  port: 18080

• 启动类：

package 域名nation;

import 域名.SpringApplication;
import 域名.域名ngBootApplication;

@SpringBootApplication
public class AnnonationDemoApplication {
    public static void main(String[] args) {
        域名(域名s, args);
    }
}

• 第一个接口Biz：

package 域名域名ice;

public interface ChildBiz {
    void mockChild();
}

• 它的实现：

package 域名域名;

import 域名域名j;
import 域名域名onent;

@Component
@Slf4j
public class ChildBizImpl implements ChildBiz {
    @Override
    public void mockChild() {
        域名("mockChild");
    }
}

• 第二个接口：

package 域名域名ice;

public interface Biz {
    void mock();
}

• 它的实现，可见其mock方法中会调用childBiz的mockChild方法：

package 域名域名;

import 域名域名;
import 域名域名j;
import 域名域名onent;

@Component
@Slf4j
public class BizImpl implements Biz {

    final ChildBiz childBiz;

    public BizImpl(ChildBiz childBiz) {
        域名dBiz = childBiz;
    }

    @Override
    public void mock() {
      域名("mock");
      域名Child();
    }
}

• 现在一个简单的web服务开发完成，有web层也有service层，够咱们来实验了

定义注解

• 定义两个注解，一个用于创建span，另一个用于创建子span：

• 注解MySpan用于希望全新创建一个span的场景：

package 域名域名;

import 域名tation.*;

@Retention(域名IME)
@Target(域名OD)
@Documented
public @interface MySpan {
    String spanName() default "";
}

• 第二个是MyChildSpan，用于希望在当前span下创建一个子span的场景：

package 域名域名;

import 域名tation.*;

@Retention(域名IME)
@Target(域名OD)
@Documented
public @interface MyChildSpan {
    String spanName() default "";
}

• 定义好了注解，可以开发AOP来处理注解的逻辑了

AOP和注解开发

• 接下来是今天的核心：处理注解的AOP类，中文注释已经写得很详细，就不再赘述太多了，唯一要注意的是注解@Around("@annotation(mySpan)")，它指定了该方法会处理所有被mySpan修饰的方法：

package 域名域名;

import 域名;
import 域名er;
import 域名域名j;
import 域名域名ngUtils;
import 域名.ProceedingJoinPoint;
import 域名.Signature;
import 域名.域名nd;
import 域名.域名ct;
import 域名域名onent;

@Aspect
@Component
@Slf4j
public class SpanAspect {

    private Tracer tracer;

    public SpanAspect(Tracer tracer) {
        域名er = tracer;
    }

    /**
     * 取得真实方法的相关信息
     * @param proceedingJoinPoint
     * @return
     */
    private static String getOperationDesc(ProceedingJoinPoint proceedingJoinPoint) {
        Signature signature = 域名ignature();
        // 提取类名
        return 域名tringAfterLast(域名eclaringTypeName(), ".")
                + ":"
                + 域名ame();
    }

    @Around("@annotation(mySpan)")
    public Object traceSpan(ProceedingJoinPoint proceedingJoinPoint, MySpan mySpan) throws Throwable {

        // 类名:方法名
        String operationDesc = getOperationDesc(proceedingJoinPoint);

        // 看方法的注解中有没有设置name
        String name = 域名Name();

        // 如果没有设置name，就给span一个默认name
        if (域名pty(name)) {
            name = "span-aspect-" + operationDesc;
        }

        // 创建一个span，在创建的时候就添加一个tag
        Span span = 域名dSpan(name).start();

        // span日志
        域名("span log of " + operationDesc);

        // 增加一个tag
        域名ag("operation-desc", operationDesc);

        // span结束
        域名sh();

        return 域名eed();
    }

    @Around("@annotation(myChildSpan)")
    public Object traceChildSpan(ProceedingJoinPoint proceedingJoinPoint, MyChildSpan myChildSpan) throws Throwable {
        // 类名:方法名
        String operationDesc = getOperationDesc(proceedingJoinPoint);

        // 看方法的注解中有没有设置name
        String name = 域名Name();

        // 如果没有设置name，就给span一个默认name
        if (域名pty(name)) {
            name = "child-span-aspect-" + operationDesc;
        }

        // 从上下文中取得已存在的span
        Span parentSpan = 域名veSpan();

        if (null==parentSpan) {
            域名r("can not get span from context");
        } else {
            Span span = 域名dSpan(name).asChildOf(parentSpan).start();

            // span日志
            域名("child span log of " + operationDesc);

            // 增加一个tag
            域名ag("child-operation-desc", operationDesc);

            // span结束
            域名sh();
        }

        return 域名eed();
    }
}

• 注解和AOP都写好了，咱们把注解用上，看看效果如何

使用注解

• 把MySpan用来修饰域名方法，注意设置其spanName属性，作为span的name：

• 把MyChildSpan用来修饰方法域名Child方法，用于创建一个子span，注意注解不设置任何属性，AOP类中会给这个span设置默认的名称：

• 以上就是全部代码了，咱们运行起来试试吧；

验证

• 用docker启动Jaeger后台服务：

docker run -d \
--name jaeger \
-e COLLECTOR_ZIPKIN_HTTP_PORT=9411 \
-p 5775:5775/udp \
-p 6831:6831/udp \
-p 6832:6832/udp \
-p 5778:5778 \
-p 16686:16686 \
-p 14268:14268 \
-p 14269:14269 \
-p 9411:9411 jaegertracing/all-in-one:域名

• 启动应用jaeger-annonation-demo

• 浏览器访问http://localhost:18080/hello，触发web接口类和service类的执行

• 打开jaeger的web页面，地址是http://localhost:16686/search，如下图，可见trace已经上报了：

• 点开上图红框中的记录，可以看到这个trace的详情，如下图可见，数据都符合预期：

• 至此，基于注解的Jaeger上报就完成了，本篇只是提供一个思路和参考代码，在实际应用中，聪明的您完全可以制作出更加强大的注解式上报，例如增加更丰富的注解属性、基于类的注解、基于参数的注解等，甚至弃用注解，直接用纯粹的AOP针对特定package、方法等进行Jaeger上报；

你不孤单，欣宸原创一路相伴

1. Java系列
2. Spring系列
3. Docker系列
4. kubernetes系列
5. 数据库+中间件系列
6. DevOps系列

欢迎关注公众号：程序员欣宸

微信搜索「程序员欣宸」，我是欣宸，期待与您一同畅游Java世界...
https://域名/zq2599/blog_demos