Golang Web应用集成Jaeger_分布式链路追踪实战

2次阅读

需在main()开头调initjaeger初始化全局tracer,http中间件用httpheaderscarrier解析header并childof创建span,确保reporter网络连通且span.finish()同goroutine执行。

Golang Web应用集成Jaeger_分布式链路追踪实战

Go 服务里怎么初始化 Jaeger tracer? 说明:不是加个包就能用,tracer 初始化顺序和全局变量绑定方式直接影响所有 span 的上下文传递。常见错误是把 tracer 声明成局部变量,或在 HTTP handler 里重复创建。

实操建议:

立即学习go语言免费学习笔记(深入)”;

  • jaeger.NewTracer() 创建一次,通过 opentracing.SetGlobalTracer() 注册为全局实例
  • 初始化必须在 main() 开头、任何 handler 启动前完成,否则中间件拿不到 tracer
  • 推荐封装成函数,比如 initJaeger(serviceName String),避免配置硬编码
func initJaeger(serviceName string) {     cfg := config.Configuration{         ServiceName: serviceName,         Sampler: &config.SamplerConfig{             Type:  "const",             Param: 1,         },         Reporter: &config.ReporterConfig{             LocalAgentHostPort: "localhost:6831",         },     }     tracer, _, _ := cfg.NewTracer(config.Logger(jaeger.StdLogger))     opentracing.SetGlobalTracer(tracer) }

HTTP 中间件如何自动注入 trace context? 说明:手动在每个 handler 里调 opentracing.StartSpanFromContext() 不现实,也容易漏掉;但直接用 req.Context() 取 span 又常为空——因为没从 HTTP header 解析 uber-trace-id

实操建议:

立即学习go语言免费学习笔记(深入)”;

  • opentracing.HTTPHeadersCarrierreq.Header 提取 trace 上下文
  • 必须调 tracer.Extract(),再传给 tracer.StartSpanWithOptions()ChildOf() 选项
  • 中间件里别用 req.Context() 直接 start span,它没继承上游 trace
func tracingMiddleware(next http.Handler) http.Handler {     return http.HandlerFunc(func(w http.ResponseWriter, req *http.Request) {         var spanCtx opentracing.SpanContext         if carrier := opentracing.HTTPHeadersCarrier(req.Header); len(carrier) > 0 {             spanCtx, _ = opentracing.GlobalTracer().Extract(                 opentracing.HTTPHeaders, carrier)         } <pre class='brush:php;toolbar:false;'>    span := opentracing.GlobalTracer().StartSpan(         "http-server",         ext.RPCServerOption(spanCtx),         ext.HTTPUrlFilter(req.URL.String()),     )     defer span.Finish()      ctx := opentracing.ContextWithSpan(req.Context(), span)     next.ServeHTTP(w, req.WithContext(ctx)) })

}

为什么 Span 没发到 Jaeger ui?常见链路断点在哪? 说明:本地跑通不代表链路能上报,90% 的问题出在 reporter 配置、网络连通性、或 span 生命周期管理上。比如 defer span.Finish() 被提前回收,或 tracer 关闭后还在发 span。

实操建议:

立即学习go语言免费学习笔记(深入)”;

  • 检查 LocalAgentHostPort 是否可连(telnet localhost 6831),docker 环境注意宿主机网络模式
  • 开启 Reporter.LocalAgentHostPort 日志:设 Loggerjaeger.StdLogger,看是否报 failed to write span
  • 避免在 goroutine 里异步 finish span,除非显式拷贝了 span 上下文;span.Finish() 必须在同 goroutine 执行
  • jaeger.NewConstSampler(false) 测试采样率影响,确认不是被全量丢弃

gin / echo 等框架怎么无缝接入? 说明:这些框架有自己的 context 和中间件机制,直接套用 net/http 示例会丢失 span 上下文,尤其 gin 的 c.Request 是只读副本,改 c.Request = c.Request.WithContext(...) 无效。

实操建议:

立即学习go语言免费学习笔记(深入)”;

  • gin:用 c.Request = c.Request.WithContext(opentracing.ContextWithSpan(c.Request.Context(), span)),但更稳妥是自定义 gin.HandlerFunc 封装 span 逻辑
  • echo:必须在中间件中调 c.SetRequest(c.Request().WithContext(...)),否则后续 handler 拿不到 context
  • 统一原则:框架的 request 对象不能只读取,要确保修改后的 context 能透传到业务 handler
// gin 示例关键行 c.Request = c.Request.WithContext(     opentracing.ContextWithSpan(c.Request.Context(), span), )

tracer 初始化时机、HTTP header 解析逻辑、reporter 连通性验证这三处最容易被跳过。尤其是本地开发时用 localhost,部署到 kubernetes 却忘了改 LocalAgentHostPort 为 service 名,trace 就静默消失了。

text=ZqhQzanResources