链路追踪

Tracing 中间件使用 OpenTelemetry 实现了链路追踪。

配置

Tracing 中间件中提供了一个配置方法 SetTracerProvider()。

SetTracerProvider

  1. package otel
  2. ...
  3. func SetTracerProvider(tp trace.TracerProvider) {
  4.     global.SetTracerProvider(tp)
  5. }

SetTracerProvider 用于设置 tracing 的链路追踪程序的提供者，该方法接收一个 trace.TracerProvider。

使用方法

server 中使用 tracing 采集数据

  1. package server
  3. func initTracer() func() {
  4.     // 创建一个 jaeger 的 pipeline,其他收集方式可以查看 opentelemetry 文档
  5.     flush, err := jaeger.InstallNewPipeline(
  6.         jaeger.WithCollectorEndpoint("http://localhost:14268/api/traces"),
  7.         jaeger.WithSDKOptions(
  8.             sdktrace.WithSampler(sdktrace.AlwaysSample()),
  9.             sdktrace.WithResource(resource.NewWithAttributes(
  10.                 semconv.ServiceNameKey.String("kratos-trace"),
  11.                 attribute.String("exporter", "jaeger"),
  12.                 attribute.Float64("float", 312.23),
  13.             )),
  14.         ),
  15.     )
  16.     if err != nil {
  17.         log.Fatal(err)
  18.     }
  19.     return flush
  20. }
  21. // NewGRPCServer new a gRPC server.
  22. func NewGRPCServer(c *conf.Server, executor *service.ExecutorService) *grpc.Server {
  23.     flush := initTracer()
  24.     defer flush()
  25.     //tr := otel.Tracer("component-main")
  26.     var opts = []grpc.ServerOption{
  27.         grpc.Middleware(
  28.             middleware.Chain(
  29.                 tracing.Server(),
  30.             ),
  31.         ),
  32.     }
  33.    // ...
  34. }

client 中使用 tracing 采集数据

  2. func initTracer() func() {
  3.     // 创建一个 jaeger 的 pipeline,其他收集方式可以查看 opentelemetry 文档
  4.     flush, err := jaeger.InstallNewPipeline(
  5.         jaeger.WithCollectorEndpoint("http://localhost:14268/api/traces"),
  6.         jaeger.WithSDKOptions(
  7.             sdktrace.WithSampler(sdktrace.AlwaysSample()),
  8.             sdktrace.WithResource(resource.NewWithAttributes(
  9.                 semconv.ServiceNameKey.String("kratos-trace"),
  10.                 attribute.String("exporter", "jaeger"),
  11.                 attribute.Float64("float", 312.23),
  12.             )),
  13.         ),
  14.     )
  15.     if err != nil {
  16.         log.Fatal(err)
  17.     }
  18.     return flush
  19. }
  20. func grpcCli() (*grpc.ClientConn, error) {
  21.     return grpc.DialInsecure(
  22.         context.Background(),
  23.         grpc.WithMiddleware(
  24.             tracing.Client(),
  25.         ),
  26.     )
  27. }

References