链路追踪学习三:跨服务,跨进程追踪

仙士可

发布于 2022-04-25 09:28:31

7520

发布于 2022-04-25 09:28:31

文章被收录于专栏：仙士可博客

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),
)

最后结果: