通过Jaeger上报Go应用数据

方式一：通过Jaeger SDK上报数据

此处以依赖管理工具Go Modules为例，您可以通过Jaeger SDK埋点直接将数据上报到链路追踪服务端。若使用其他依赖管理工具，请按实际情况操作。

1. 引入jaeger-client-go。

   go get github.com/uber/jaeger-client-go

2. 创建Tracer对象。
   说明 请将<endpoint>替换成链路追踪控制台概览页面上相应客户端和相应地域的接入点。关于获取接入点信息的方法，请参见本文前提条件。

   func NewJaegerTracer(service string) (opentracing.Tracer, io.Closer) {
   
       sender := transport.NewHTTPTransport(
          // 设置网关，网关因地域而异。
           "<endpoint>",
       )
      tracer, closer:= jaeger.NewTracer(service,
              jaeger.NewConstSampler(true),
              jaeger.NewRemoteReporter(sender))
      return tracer, closer
   }

3. 创建span实例对象和数据透传。

   • 如果没有parentSpan：

     // 创建Span。
     span := tracer.StartSpan("myspan")
     // 设置Tag。
     clientSpan.SetTag("mytag", "123")
     // 透传traceId。
     tracer.Inject(span.Context(), opentracing.HTTPHeaders, opentracing.HTTPHeadersCarrier(req.Header))
     ...
     defer  span.Finish()

   • 如果有parentSpan：

     // 从HTTP/RPC对象解析出spanCtx。
     spanCtx, _ := tracer.Extract(opentracing.HTTPHeaders, opentracing.HTTPHeadersCarrier(r.Header))
     span := tracer.StartSpan("myspan", opentracing.ChildOf(spanCtx))
     ...
     defer  span.Finish()

   更多详细使用方法，请参见Go Doc。

方式二：通过Jaeger Agent上报数据

1. 启动Jaeger Agent。具体操作，请参见安装Jaeger Agent。
2. 引入jaeger-client-go。

   go get github.com/uber/jaeger-client-go

3. 创建Tracer对象。

   func NewJaegerTracer(serviceName string) (opentracing.Tracer, io.Closer) {
      sender, _ := jaeger.NewUDPTransport("",0)
      tracer, closer:= jaeger.NewTracer(serviceName,
           jaeger.NewConstSampler(true),
           jaeger.NewRemoteReporter(sender))
       return tracer, closer
   }

4. 创建span实例对象和数据透传。

   • 如果没有parentSpan：

     // 创建Span。
     span := tracer.StartSpan("myspan")
     // 设置Tag。
     clientSpan.SetTag("mytag", "123")
     // 透传traceId。
     tracer.Inject(span.Context(), opentracing.HTTPHeaders, opentracing.HTTPHeadersCarrier(req.Header))
     ...
     defer  span.Finish()

   • 如果有parentSpan：

     // 从HTTP/RPC对象解析出spanCtx。
     spanCtx, _ := tracer.Extract(opentracing.HTTPHeaders, opentracing.HTTPHeadersCarrier(r.Header))
     span := tracer.StartSpan("myspan", opentracing.ChildOf(spanCtx))
     ...
     defer  span.Finish()

   更多详细使用方法，请参见Go Doc。

使用示例

通过Jaeger SDK直接上报

1. 获取接入点信息。具体操作方法，请参见本文前提条件。
2. 运行以下命令，下载示例文件。

   wget https://arms-apm-cn-hangzhou.oss-cn-hangzhou.aliyuncs.com/demo/tracing-demo.zip && unzip tracing-demo.zip

3. 打开示例文件夹中的examples/settings.go文件，配置TracingAnalysisEndpoint，将图示①替换为步骤1中获取的接入点信息。
   
4. 使用go mod tidy命令整理依赖。
5. 使用go run tracingdemo命令运行示例。

通过Jaeger Agent上报

1. 获取接入点信息。具体操作方法，请参见本文前提条件。
2. 运行以下命令，下载示例文件。

   wget https://arms-apm-cn-hangzhou.oss-cn-hangzhou.aliyuncs.com/demo/tracing-demo.zip && unzip tracing-demo.zip

3. 启动Jaeger Agent。具体操作，请参见安装Jaeger Agent。
4. 打开示例文件夹中的examples/settings.go文件，将AgentSwitch修改为true。
   
5. 使用go mod tidy命令整理依赖。
6. 使用go run tracingdemo命令运行示例。

常见问题

2021/06/28 21:11:54 ERROR: error when flushing the buffer: error from collector: 403
2021/06/28 21:11:54 ERROR: error when flushing the buffer: error from collector: 403

A：出现上述报错，说明输入的接入点信息不正确。请更正并重试。

更多信息