java - Spring Boot Jaeger 为给定的 TraceId 创建新的 Span

Question

所以我正在使用 Jaeger 和 OpenTracing 来跟踪我的 Spring Boot 微服务之间的请求。我已经设置了所有必要的配置并添加了依赖项:

<dependency>
    <groupId>io.opentracing.contrib</groupId>
    <artifactId>opentracing-spring-jaeger-web-starter</artifactId>
    <version>2.0.3</version>
</dependency>

目前一切正常。我在我的 Jaeger UI 中看到了所有的痕迹和跨度，没问题。

但现在我面临着向特定跟踪添加新跨度的挑战，这已经完成了。可以这样想。客户端调用其中一项服务并开始跟踪。工作完成后，我在我的 Jaeger UI 中看到了痕迹。但是现在调用客户端想要向特定跟踪添加一些额外的跟踪数据。就像来自其他服务的跟踪信息一样，不在我的微服务范围内。我添加了一个过滤器，因此我可以提取跟踪 ID 并将其发送给客户端。现在客户端发出一个包含附加跟踪信息和跟踪 ID 的请求。然后应将这些信息作为附加跨度添加到已完成的跟踪中。

现在回答我的问题。有没有一种方法可以创建跨度并将其添加到跟踪中，而跟踪 ID 仅作为字符串？

我已经尝试过 Zipkin，我可以这样做:

Span span = new SpanBuilder()
                .name(someName)
                .traceId(traceId)
                .parentId(traceId)
                .id(someId)
                .kind(Kind.CLIENT)
                .build()

然后可以通过在端口 9411 上向我的 zipkin 服务器发出 POST 请求来添加该跨度，这神奇地将此跨度添加到具有给定 ID 的跟踪中。

使用 OpenTracing 我可以做到:

Span span = tracer.buildSpan(someName)
                .asChildOf(**traceSpan**)
                .withStartTimestamp(someTime)
                .ignoreActiveSpan()
                .start();

不幸的是，这种方法需要跨度形式的跟踪来创建新跨度作为该跟踪的子级。鉴于我只能提供跟踪 ID，我不知道如何获得该跟踪所需的跨度。我真的需要调用我的 Jaeger 查询来获取所需的跟踪跨度，还是有其他我没有想到的方法？

真的很想得到一些帮助。

干杯!

Answer 1

您需要将 trace-id 从一台服务器发送到另一台服务器。我将在此处列出一种实现代码的方法，假设您已经在服务 1 上创建了一个原始跨度并创建了一个跟踪器实例 (JaegerTracer)。

首先，您需要从 service1 的 span 中获取 span-id:

JaegerSpan span = tracer.buildSpan("service1")
String spanId = span.context().toTraceId()

现在，您可以将此字符串 (spanId) 传播到您的其他服务。例如:如果您使用的是 http/post 或 kafka，则需要遵循一些协议(protocol)，例如:w3c .但是以根的方式

import io.jaegertracing.internal.JaegerSpan;
import io.jaegertracing.internal.JaegerSpanContext;
import io.jaegertracing.internal.propagation.TextMapCodec;
import io.jaegertracing.internal.propagation.TextMapCodec.Builder;
//...
// assuming you've extracted your trace-id as string from your messaging system
// kafka header, http header, grpc metadata, wherever...
TextMap carrier = new TextMapAdapter(Map.of("uber-trace-id", traceId));
TextMapCodec codec = New Builder().build();

// I guess this line answer your question (get spanContext from trace-id)
JaegerSpanContext sc = codec.extract(carrier);
JaegerSpan sp = tracer.buildSpan("service2").asChildOf(sc).start();