链路追踪学习三:跨服务,跨进程追踪
【摘要】 traceId首先,我们要了解,跨服务追踪需要有个traceId标识,以及其他需要传递的链路数据:carrier := opentracing.HTTPHeadersCarrier{} //声明一个数据载体err := span.Tracer().Inject(span.Context(), opentracing.HTTPHeaders, carrier) //将span的数据格式化进载...
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),
)最后结果:
【版权声明】本文为华为云社区用户原创内容，转载时必须标注文章的来源（华为云社区）、文章链接、文章作者等基本信息， 否则作者和本社区有权追究责任。如果您发现本社区中有涉嫌抄袭的内容，欢迎发送邮件进行举报，并提供相关证据，一经查实，本社区将立刻删除涉嫌侵权内容，举报邮箱：
cloudbbs@huaweicloud.com
- 点赞
- 收藏
- 关注作者
评论（0）