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

就像@Totalys 所说的那样，但需要进行一些修改，与键“uber-trace-id”关联的值应该是context().toString() 而不是context().toTraceId

Answer 2

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

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

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

现在，您可以将此字符串 (spanId) 传播到您的其他服务。 例如：如果您使用的是 http/post 或 kafka，则需要遵循一些协议，例如：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();