traceId
首先,我们要了解,跨服务追踪需要有个traceId标识,以及其他需要传递的链路数据:
代码语言：javascript复制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等方式将数据传递,在调用方接收:
代码语言：javascript复制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),
)最后结果:
本文为仙士可原创文章,转载无需和我联系,但请注明来自仙士可博客www.php20.cn
