如何从请求头提取B3追踪信息实现OpenTelemetry服务Span归属KrakenD网关

• OpenTelemetry Go SDK 默认启用的上下文传播器是W3C TraceContext协议，而KrakenD传递的是Zipkin B3协议的多Header格式追踪字段，默认传播器无法识别B3头，也就无法将网关生成的Span作为父节点关联，最终导致链路拆分。
• 你当前的手动拷贝Header的逻辑存在空指针风险：如果请求未携带对应X-B3头，r.Header[k][0]会直接触发数组越界panic。

1. 全局注册B3传播器 #

首先在服务初始化OpenTelemetry的逻辑中，导入B3传播器依赖并注册为全局传播器，支持多Header格式的B3协议解析：

import (
    "go.opentelemetry.io/contrib/propagators/b3"
    "go.opentelemetry.io/otel"
)

// 服务启动时的OTel初始化逻辑中增加
func initOtel() {
    // 注册B3多Header传播器，匹配KrakenD的X-B3-*前缀头格式
    b3Propagator := b3.New(b3.WithInjectEncoding(b3.B3MultipleHeader))
    otel.SetTextMapPropagator(b3Propagator)
    
    // 其余OTel初始化逻辑（TracerProvider、Exporter等保持不变）
}

2. 简化Handler中的上下文提取逻辑 #

propagation.HeaderCarrier本质就是http.Header的别名，无需手动遍历拷贝Header，直接传入原生请求头即可，同时避免空指针风险：

func (env *Env) getCommentForBlogRouter(w http.ResponseWriter, r *http.Request) {
    ctx := r.Context()

    // 直接用原生请求头作为载体提取上下文，无需手动拷贝
    propagator := otel.GetTextMapPropagator()
    ctx = propagator.Extract(ctx, propagation.HeaderCarrier(r.Header))

    tr := otel.Tracer("Handler: blog-comments")
    ctx, span := tr.Start(ctx, "handler span")
    defer span.End()

    blogId := r.URL.Query().Get("blog-id")
    span.SetAttributes(attribute.Key("blog-id").String(blogId))

    ctx, spanDB := tr.Start(ctx, "Select row")
    comments, err := env.comments.GetForBlog(blogId)
    spanDB.End()

    _, spanRes := tr.Start(ctx, "Sending Response")
    defer spanRes.End()

    if err != nil {
        fmt.Println(err)
        SendError(w, http.StatusInternalServerError, "Something went wrong")
        return
    }

    if comments == nil {
        comments = []models.Comment{}
    }
    SendResponse(w, http.StatusOK, map[string]interface{}{
        "data": comments,
    })
}

避免每个Handler都重复写上下文提取逻辑，封装为中间件全局挂载即可：

func OtelTracingMiddleware(next http.Handler) http.Handler {
    return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
        ctx := otel.GetTextMapPropagator().Extract(r.Context(), propagation.HeaderCarrier(r.Header))
        next.ServeHTTP(w, r.WithContext(ctx))
    })
}

// 路由注册时挂载中间件
r := chi.NewRouter()
r.Use(OtelTracingMiddleware)
// 后续注册的所有路由都会自动完成链路上下文提取

修改完成后重启服务发起请求，Jaeger中即可看到网关的Span作为父节点，业务服务的所有Span都归属到对应网关Span下，形成完整调用链路。

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