Java - Brave / Zipkin:当前跨度为零

Question

关于Java应用程序的小问题，请用Brave / Zipkin查询跟踪。

我有一段非常简单的代码(附加了代码+ maven pom，可以运行并复制问题)

import io.netty.handler.logging.LogLevel;
import org.springframework.http.client.reactive.ReactorClientHttpConnector;
import org.springframework.web.reactive.function.BodyInserters;
import org.springframework.web.reactive.function.client.WebClient;
import reactor.netty.http.client.HttpClient;
import reactor.netty.transport.logging.AdvancedByteBufFormat;
import zipkin2.reporter.AsyncReporter;
import zipkin2.reporter.brave.ZipkinSpanHandler;
import zipkin2.reporter.urlconnection.URLConnectionSender;
import brave.Tracing;
import brave.opentracing.BraveTracer;
import java.util.Map;

public class QuestionApplication {

    public static void main(String[] args) {
        final var sender        = URLConnectionSender.create("http://the-zipkin-instance.com:9411/api/v2/spans");
        final var spanReporter  = AsyncReporter.create(sender);
        final var tracing       = Tracing.newBuilder().localServiceName("thisIsTheClientApplicationWhoIsGeneratingTheFirstTraceId").addSpanHandler(ZipkinSpanHandler.create(spanReporter)).build();
        final var tracer        = BraveTracer.create(tracing).unwrap().tracer();
        final var webClient     = WebClient.create().mutate().clientConnector(new ReactorClientHttpConnector(HttpClient.create().wiretap("reactor.netty.http.client.HttpClient", LogLevel.INFO, AdvancedByteBufFormat.HEX_DUMP))).build();
        final var jsonPayload   = Map.of("key", "someKey", "value", "someValue");
        final var span = tracer.currentSpan();
        final var context = span.context();
        final var traceIdString = context.traceIdString();
        final var response      = webClient.post().uri("http://the-server.com/api/route").header("X-B3-TraceId", traceIdString).body(BodyInserters.fromValue(jsonPayload)).retrieve().bodyToMono(String.class).block();
        System.out.println(response);
    }

}

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.github</groupId>
    <artifactId>question</artifactId>
    <version>1.1</version>

    <properties>
        <java.version>11</java.version>
        <maven.compiler.source>11</maven.compiler.source>
        <maven.compiler.target>11</maven.compiler.target>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-webflux</artifactId>
            <version>2.5.4</version>
        </dependency>
        <dependency>
            <groupId>io.zipkin.reporter2</groupId>
            <artifactId>zipkin-sender-urlconnection</artifactId>
            <version>2.16.3</version>
        </dependency>
        <dependency>
            <groupId>io.opentracing.brave</groupId>
            <artifactId>brave-opentracing</artifactId>
            <version>1.0.0</version>
        </dependency>
    </dependencies>

</project>

在这里，使用上面的代码，我将获得一个java.lang.NullPointerException在线final var context = span.context();，因为span是空的final var span = tracer.currentSpan();。

这个应用程序是"client“应用程序，意味着第一个启动http调用，因此，我希望这小块主代码是第一个生成跟踪ID的，它将在其他十几个子系统中运行。

我可以问一下是什么问题，什么是这个NPE的根本原因，或者我应该说，创建这个跟踪ID的正确方法是什么，因为我是链的第一位。

谢谢

Answer 1

我不知道NPE生成了什么(技术上的)，但是SpanHandler注入和勇敢包装是奇怪的，因为跟踪是来自Brave。那么，最有可能的是，在这两行中，您没有注入创建良好跨度所必需的依赖关系。

Tracing.newBuilder().localServiceName("thisIsTheClientApplicationWhoIsGeneratingTheFirstTraceId").addSpanHandler(ZipkinSpanHandler.create(spanReporter)).build();
BraveTracer.create(tracing).unwrap().tracer();

在这里，我做了一个没有这些行的例子，它如您所期望的那样工作。通过父-子流结构，您可以通过注入和提取标头的跟踪来复制和分发它: X-B3-TraceId、X-B3-ParentSpanId、X-B3-SpanId、X-B3采样。

主代码

package com.stackoverflow.q69430794;

import brave.Span;
import brave.Tracing;
import zipkin2.reporter.AsyncReporter;
import zipkin2.reporter.okhttp3.OkHttpSender;

public class QuestionApplication {

    public static void main(String[] args) {
        
        var sender = OkHttpSender.newBuilder().endpoint("http://localhost:9411/api/v2/spans").build();
        var reporter = AsyncReporter.builder(sender).build();
        
        var tracing = Tracing.newBuilder().localServiceName("component-test").spanReporter(reporter).build();
        
        // Create parent span and his child --------------------
        
        // Parent
        tracing.tracer().startScopedSpan("parentSpan");
        Span span =  tracing.tracer().currentSpan();
        span.tag("key", "firstBiz");
        
        // Child
        tracing.tracer().startScopedSpanWithParent("childSpan", tracing.tracer().currentSpan().context());
        Span childSpan =  tracing.tracer().currentSpan();
        childSpan.tag("key", "secondBiz");
        childSpan.finish();
        System.out.println("id:" + childSpan.context().traceIdString());
        
        // Finish span
        span.finish();
        
        try {
            Thread.sleep(5000);
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        // -----------------------------------------------------
    }

}

pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.stackoverflow.q69430794</groupId>
    <artifactId>69430794</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>69430794</name>
    <description>Question # 69430794</description>

    <properties>
        <java.version>11</java.version>
        <maven.compiler.source>11</maven.compiler.source>
        <maven.compiler.target>11</maven.compiler.target>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-webflux</artifactId>
            <version>2.5.4</version>
        </dependency>
        <dependency>
            <groupId>io.zipkin.brave</groupId>
            <artifactId>brave</artifactId>
            <version>5.4.2</version>
        </dependency>
        <dependency>
            <groupId>io.zipkin.reporter2</groupId>
            <artifactId>zipkin-sender-okhttp3</artifactId>
            <version>2.7.9</version>
        </dependency>
        
    </dependencies>

</project>

我用了码头图像：

docker pull openzipkin/zipkin

Zipkin的痕迹

​