Jaeger-分布式链路追踪系统

简单介绍

Jaeger是Uber开源的分布式链路追踪系统，其设计借鉴了Dapper和OpenZipkin，常用于监控和分布式系的故障排查，其主要的特性如下

• 分布式上下文传播
• 分布式事务监控
• root原因分析
• 服务依赖性分析
• 性能/延迟优化

jaeger提供了可视化界面，可以很直观的观察数据链路

基本概念

• tracer：表示一条链路
• span：表示一个操作，隶属于tracer

系统架构

快速开始

1. docker方式

   docker run -d --name jaeger \
     -e COLLECTOR_ZIPKIN_HOST_PORT=:9411 \
     -e COLLECTOR_OTLP_ENABLED=true \
     -p 6831:6831/udp \
     -p 6832:6832/udp \
     -p 5778:5778 \
     -p 16686:16686 \
     -p 4317:4317 \
     -p 4318:4318 \
     -p 14250:14250 \
     -p 14268:14268 \
     -p 14269:14269 \
     -p 9411:9411 \
     jaegertracing/all-in-one:1.42

2. 二进制

下载链接：https://www.jaegertracing.io/download/

wget https://github.com/jaegertracing/jaeger/releases/download/v1.42.0/jaeger-1.42.0-darwin-arm64.tar.gz

jaeger-all-in-one --collector.zipkin.host-port=:9411

3. 访问UI界面

   http://localhost:16686

   

4. 获取案例并运行

   git clone https://github.com/jaegertracing/jaeger.git
   cd jaeger
   go run ./examples/hotrod/main.go all

5. 自定义实现

   package main
   
   import (
   	"context"
   	"fmt"
   	"github.com/opentracing/opentracing-go"
   	"github.com/opentracing/opentracing-go/log"
   	"github.com/uber/jaeger-client-go"
   	"github.com/uber/jaeger-client-go/config"
   	"io"
   	"time"
   )
   
   func main() {
       //初始化一个tracer
   	tracer, closer := initJaeger("hello-world")
       //设置全局tracer
   	opentracing.SetGlobalTracer(tracer)
       //创建一个名叫say-hello的操作
   	span := tracer.StartSpan("say-hello")
       //通过上面的span创建一个ctx，在后面我们可以通过其走同一条完整链路
   	ctx := opentracing.ContextWithSpan(context.Background(), span)
   	hello(ctx)
   	sayHi := opentracing.SpanFromContext(ctx)
   	sayHi.SetTag("Hi", "Hi")
   	sayHi.Finish()
   	defer func() {
   		span.Finish()
   		closer.Close()
   	}()
   }
   
   func hello(ctx context.Context) {
       //再次创建一个span，注意这个是say-hello的子span
   	span, ctx := opentracing.StartSpanFromContext(ctx, "hello hello")
   	defer span.Finish()
   	span.LogFields(log.String("key", "loggggggg"))
   	span.SetTag("tag", "tagValue")
   	sleep() //do something
   }
   
   // initJaeger returns an instance of Jaeger Tracer that samples 100% of traces and logs all spans to stdout.
   func initJaeger(service string) (opentracing.Tracer, io.Closer) {
   	cfg := &config.Configuration{
   		ServiceName: service,
   		Sampler: &config.SamplerConfig{
   			Type:  "const",
   			Param: 1,
   		},
   		Reporter: &config.ReporterConfig{
   			LogSpans:           true,
   			LocalAgentHostPort: "10.10.100.28:6831", //指定本地代理ip端口
   		},
   	}
   	tracer, closer, err := cfg.NewTracer(config.Logger(jaeger.StdLogger))
   	if err != nil {
   		panic(fmt.Sprintf("ERROR: cannot init Jaeger: %v\n", err))
   	}
   	return tracer, closer
   }
   
   func sleep() {
   	time.Sleep(2 * time.Second)
   }

相关资料

1. 官方文档：https://www.jaegertracing.io/docs/1.42/
2. github：https://github.com/jaegertracing/jaeger
3. 教程：https://github.com/yurishkuro/opentracing-tutorial/tree/master/go