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

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



最后结果:

仙士可博客



仙士可博客
请先登录后发表评论
  • 最新评论
  • 总共0条评论
  • 本站由白俊遥博客程序搭建
    © 2017-1-17 php20.cn 版权所有 ICP证:闽ICP备17001387号
  • 本网站由: 提供cdn加速/云存储服务
  • 联系邮箱:1067197739@qq.com