golang实现简单的jaeger-demo

朴灿烈づ我的快乐病毒、 2022-03-16 03:46 381阅读 0赞

参考地址：[https://github.com/yurishkuro/opentracing-tutorial/tree/master/go][https_github.com_yurishkuro_opentracing-tutorial_tree_master_go]

jaeger是一个比较有名的分布式链路追踪系统，底层用golang实现，兼容opentracing标准，这里利用其go-client来实现一个最简单的demo，仅供参考。

**1. 安装必要的包**：

"github.com/opentracing/opentracing-go"
    "github.com/uber/jaeger-client-go"
    "github.com/uber/jaeger-client-go/config"

**2. 安装部署jaeger整套：**

这里利用jaeger提供的docker，集成了整套环境，利用内存存储：docker hub地址：[https://hub.docker.com/r/jaegertracing/all-in-one][https_hub.docker.com_r_jaegertracing_all-in-one]

直接运行一下命令启动docker：

docker run -d --name jaeger \
      -e COLLECTOR_ZIPKIN_HTTP_PORT=9411 \
      -p 5775:5775/udp \
      -p 6831:6831/udp \
      -p 6832:6832/udp \
      -p 5778:5778 \
      -p 16686:16686 \
      -p 14268:14268 \
      -p 9411:9411 \
      jaegertracing/all-in-one:1.9

运行ok后我们docker ps看一下是否正常运行：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpeXVubG9uZzQx_size_16_color_FFFFFF_t_70][]

现在可以访问localhost:16686来查看jaeger的UI界面：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpeXVubG9uZzQx_size_16_color_FFFFFF_t_70 1][]

**3. 编写demo**

先编写一个初始化jaeger tracer的initJaeger方法：

此时我们要在reporter中配置jaeger Agent的ip与端口，以便将tracer的信息发布到agent中。

配置LocalAgentHostPort参数为127.0.0.1:6381，6381接口是接受压缩格式的thrift协议数据。

采样率暂且设置为1。

func initJaeger(service string) (opentracing.Tracer, io.Closer) {
    	cfg := &config.Configuration{
    		Sampler: &config.SamplerConfig{
    			Type:  "const",
    			Param: 1,
    		},
    		Reporter: &config.ReporterConfig{
    			LogSpans: true,
    			LocalAgentHostPort:"127.0.0.1:6831",
    		},
    	}
    	tracer, closer, err := cfg.New(service, config.Logger(jaeger.StdLogger))
    	if err != nil {
    		panic(fmt.Sprintf("ERROR: cannot init Jaeger: %v\n", err))
    	}
    	return tracer, closer
    }

然后我们在main函数中创建调用InitJaeger，并创建一个root span，调用两个函数，分别表示调用两个分布式服务。

我们用ContextWithSpan来创建一个新的ctx，将span的信息与context关联，传到foo3中时，需要创建一个子span，父span是ctx中的span。

我们在foo3中调用StartSpanFromContext时，忽略了第二个参数，这是利用子span创建的新的context，当我们在foo3中再调用别的比如foo5时，我们应该使用新的context，而不是传入的ctx。

注意StartSpanFromContext会用到opentracing.SetGlobalTracer()来启动新的span，所以在main函数中需要调用。

func foo3(req string, ctx context.Context) (reply string){
    	//1.创建子span
    	span, _ := opentracing.StartSpanFromContext(ctx, "span_foo3")
    	defer func() {
    		//4.接口调用完，在tag中设置request和reply
    		span.SetTag("request", req)
    		span.SetTag("reply", reply)
    		span.Finish()
    	}()
    
    	println(req)
    	//2.模拟处理耗时
    	time.Sleep(time.Second/2)
    	//3.返回reply
    	reply = "foo3Reply"
    	return
    }
    //跟foo3一样逻辑
    func foo4(req string, ctx context.Context) (reply string){
    	span, _ := opentracing.StartSpanFromContext(ctx, "span_foo4")
    	defer func() {
    		span.SetTag("request", req)
    		span.SetTag("reply", reply)
    		span.Finish()
    	}()
    
    	println(req)
    	time.Sleep(time.Second/2)
    	reply = "foo4Reply"
    	return
    }
    
    func main() {
    	tracer, closer := initJaeger("jaeger-demo")
    	defer closer.Close()
    	opentracing.SetGlobalTracer(tracer)//StartspanFromContext创建新span时会用到
    
    	span := tracer.StartSpan("span_root")
    	ctx := opentracing.ContextWithSpan(context.Background(), span)
    	r1 := foo3("Hello foo3", ctx)
    	r2 := foo4("Hello foo4", ctx)
    	fmt.Println(r1, r2)
    	span.Finish()
    }

**4. 运行结果：**

运行完提交的span信息会被log打印出来：

2019/02/26 13:21:44 Initializing logging reporter
    Hello foo3
    2019/02/26 13:21:45 Reporting span 8acae1d479b9829:12f2820e87c75e51:8acae1d479b9829:1
    Hello foo4
    2019/02/26 13:21:45 Reporting span 8acae1d479b9829:7cca0d1cc894735:8acae1d479b9829:1
    foo3Reply foo4Reply
    2019/02/26 13:21:45 Reporting span 8acae1d479b9829:8acae1d479b9829:0:1
    
    Process finished with exit code 0

同时jaeger UI上会发现对应的记录：

可以发现有很明显的分层，时间耗时也很明显，接口先后调用也很清晰。

![20190226132409186.png][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpeXVubG9uZzQx_size_16_color_FFFFFF_t_70 2][]

NEXT~~~~~

**进阶版：我们现在只是在同一个服务中实现了jaeger的demo，如果在分布式的服务中，如何实现jaeger呢？**

**请参考：[opentracing: jaeger在grpc中的简单实现][opentracing_ jaeger_grpc]**

[https_github.com_yurishkuro_opentracing-tutorial_tree_master_go]: https://github.com/yurishkuro/opentracing-tutorial/tree/master/go
[https_hub.docker.com_r_jaegertracing_all-in-one]: https://hub.docker.com/r/jaegertracing/all-in-one
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpeXVubG9uZzQx_size_16_color_FFFFFF_t_70]: /images/20220316/323b148cd37241b4a9f0572ade220551.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpeXVubG9uZzQx_size_16_color_FFFFFF_t_70 1]: /images/20220316/1fd67014d1cd400db50f760e56258db9.png
[20190226132409186.png]: /images/20220316/d1fd811f97e54ab1b9802ccdf3758728.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpeXVubG9uZzQx_size_16_color_FFFFFF_t_70 2]: /images/20220316/bfb131cd9eb046e1850783d2046efb37.png
[opentracing_ jaeger_grpc]: https://blog.csdn.net/liyunlong41/article/details/88043604