gRPC Java服务与.NET服务的Trace上下文传播及链路对齐问题

背景 #

现有Java核心服务与.NET服务通过gRPC通信：Java服务接收.NET服务的gRPC请求，处理后返回响应。Java服务已通过OpenTelemetry Java Agent做自动埋点，.NET服务为手动埋点，二者属于同一生产应用，需要实现Trace上下文正确传播，让Java侧的Trace与.NET侧的Trace完全对齐。

尝试手动实现拦截器提取Trace上下文，但提取的上下文始终为null，代码如下：

public class ServerHeadInterceptor implements ServerInterceptor
{
    private final Tracer tracer = GlobalOpenTelemetry.getTracer("my-tracer");

    public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall(ServerCall<ReqT, RespT> call, Metadata headers, ServerCallHandler<ReqT, RespT> next)
    {
        TextMapPropagator propagator = GlobalOpenTelemetry.getPropagators().getTextMapPropagator();

        Context extractedContext = propagator.extract(Context.current(), headers, new TextMapGetter<Metadata>()
        {
            @Override
            public Iterable<String> keys(Metadata carrier)
            {
                return carrier.keys();
            }

            @Nullable
            @Override
            public String get(@Nullable Metadata carrier, String key)
            {
                Metadata.Key<String> traceParent = Metadata.Key.of(key, Metadata.ASCII_STRING_MARSHALLER);
                String value = carrier.get(traceParent);
                System.out.println("VALUE :" + value);
                return value;
            }
        });

        Span span = tracer.spanBuilder("my-span").setSpanKind(SpanKind.CONSUMER).setParent(extractedContext).startSpan();

        try(Scope scope = span.makeCurrent())
        { 
            return new ForwardingServerCallListener.SimpleForwardingServerCallListener<ReqT>(next.startCall(call, headers)) {};
        }
        finally
        {
            span.end();
        }
    }
}

待解决问题 #

1. 如何从入站gRPC请求中正确提取Trace上下文，并基于该上下文创建Span？
2. OpenTelemetry Java Agent是否提供该场景下的自动上下文传播功能？
3. 针对.NET服务发来的多个gRPC请求，能否通过提取每个请求的Trace上下文创建Span，实现全链路Trace对齐？

注：使用Grafana Tempo作为Trace导出器

解答 #

问题1：正确提取Trace上下文并创建Span #

你的代码存在几个关键问题导致提取失败，修正方案如下：

• 修复键名匹配问题：gRPC的Metadata会自动将键转为小写存储，而OpenTelemetry默认使用traceparent、tracestate这类小写标准键名。需确保get方法中用小写键查询，同时.NET侧要发送符合W3C Trace Context标准的头。
• 修正代码语法错误：原代码存在引号未闭合、方法调用缺括号等语法问题，会导致代码无法正常执行。
• 调整Span类型：gRPC服务端Span应使用SpanKind.SERVER而非CONSUMER，符合OpenTelemetry的语义规范。

修正后的核心逻辑示例：

TextMapGetter<Metadata> getter = new TextMapGetter<>() {
    @Override
    public Iterable<String> keys(Metadata carrier) {
        return carrier.keys();
    }

    @Override
    public String get(Metadata carrier, String key) {
        if (carrier == null) return null;
        // 统一转为小写匹配gRPC Metadata的存储规则
        Metadata.Key<String> metadataKey = Metadata.Key.of(key.toLowerCase(), Metadata.ASCII_STRING_MARSHALLER);
        return carrier.get(metadataKey);
    }
};

Context extractedContext = propagator.extract(Context.current(), headers, getter);

// 创建服务端Span，自动继承提取到的上下文
Span span = tracer.spanBuilder("grpc-server-handle")
        .setSpanKind(SpanKind.SERVER)
        .setParent(extractedContext)
        .startSpan();

问题2：OpenTelemetry Java Agent的自动功能 #

是的，OpenTelemetry Java Agent原生支持gRPC服务端的自动上下文传播和Span创建，无需手动编写拦截器。

只要满足以下条件即可自动生效：

1. 使用v1.20+版本的Java Agent，且正确配置Tempo导出器、服务名等参数。
2. .NET侧发送的gRPC请求头符合W3C Trace Context标准（携带traceparent、tracestate）。
3. Java服务使用的gRPC库属于Agent支持列表（如io.grpc:grpc-netty、io.grpc:grpc-protobuf等主流依赖）。

启用Agent后，它会自动注入gRPC服务端拦截器，自动提取请求头中的Trace上下文、创建对应SERVER Span，并将上下文传递给后续业务代码。

问题3：多请求的Trace对齐 #

完全可以实现。每个gRPC请求的Metadata会携带独立的traceparent（包含唯一的Trace ID和Span ID），不管是手动实现拦截器还是使用Java Agent的自动功能，都能做到：

• 每个请求对应一个独立的SERVER Span，继承.NET侧发起Span的Trace ID。
• 全链路Trace会包含.NET客户端Span、Java服务端Span及Java内部子Span，在Grafana Tempo中可完整查看整条链路的调用关系。

内容的提问来源于stack exchange，提问作者abhinand07