traceId
首先,我们要了解,跨服务追踪需要有个traceId标识,以及其他需要传递的链路数据:
carrier := opentracing.HTTPHeadersCarrier{} //声明一个数据载体 err := span.Tracer().Inject(span.Context(), opentracing.HTTPHeaders, carrier) //将span的数据格式化进载体 for key, value := range carrier { fmt.Printf("traceId: %v => %v \\n", key, value) }
获取traceId以及组装父span做调用
获取到载体数据后,可通过http header,rpc等方式将数据传递,在调用方接收:
var carrierHeader http.Header carrierHeader = http.Header(carrier) //carrier为调用的数据,格式化为header carrier := opentracing.HTTPHeadersCarrier{} carrier.Set("uber-trace-id", traceId) //记录traceId tracer := opentracing.GlobalTracer() //声明tracer wireContext, err := tracer.Extract( opentracing.HTTPHeaders, opentracing.HTTPHeadersCarrier(header), ) parentSpan := opentracing.StartSpan( "request-server", ext.RPCServerOption(wireContext)) //将carrier获得的数据存入新声明的span,这个span即为父span defer parentSpan.Finish() //结束后完成该span ctx = opentracing.ContextWithSpan(context.Background(), parentSpan) //通过该span获取上下文,之后的子span基于该上下文 //创建子span span, _ := jaegerTool.WithSpan(ctx, "writeLog") defer span.Finish() //结束后调用完成 span.LogFields( log.String("log", data), )
最后结果:
