golang 链路追踪的实现示例

天际云行

分布式链路追踪（Distributed Tracing），也叫分布式链路跟踪，分布式跟踪，分布式追踪等等。

问题

场景1:调用链过长，查询很慢

web-gin由A负责，服务A由B负责，某个接口出现异常了，先查询日志看是哪个地方出错了，发现服务A调用失败，依次找到D
场景2:接口相应很慢

解决方法

(1)打日志:慢(可能不看懂其他人写的日志)
(2)ELK:可以解决，也是日志需要写入
(3)第三方链路追踪系统可以解决

链路追踪系统技术选型

java使用zipkin和skywalking比较多，而go使用jaeger多
zipkinjaegerskywalkingOpenTracing是是是客户端支持语言java、c#、php、python等java、c#、go、php、python等java、.Net Core、NodeJS、PHP、python存储ES、Mysql、Cassandra内存ES、kafka、Cassandra内存ES、H2、mysql、TIDB、shard sphere传输协议支持http、MQudp/httpgRPCui丰富程度低中中实现方式-代码侵入式拦截请求，侵入拦截请求，侵入字节码注入，无侵入扩展性高高中trace查询支持支持支持性能损失中中低选择jaeger:官方支持jaeger技术选型原则：客户端支持、综合考虑、什么语言开发的
安装jaeger

1. docker run \
   
2.   --rm \
   
3.   --name jaeger \
   
4.   -p6831:6831/udp \
   
5.   -p16686:16686 \
   
6.   jaegertracing/all-in-one:latest

复制代码

架构

Jaeger组成
1.Jaeger Client - 为不同语言实现了符合 OpenTracing 标准的 SDK。应用程序通过 API 写入数据，client library 把 trace 信息按照应用程序指定的采样策略传递给 jaeger-agent。
2.Agent - 它是一个监听在 UDP 端口上接收 span 数据的网络守护进程，它会将数据批量发送给 collector。它被设计成一个基础组件，部署到所有的宿主机上。Agent 将 client library 和 collector 解耦，为 client library 屏蔽了路由和发现 collector 的细节。2.Collector - 接收 jaeger-agent 发送来的数据，然后将数据写入后端存储。Collector 被设计成无状态的组件，因此您可以同时运行任意数量的 jaeger-collector。
3.Data Store - 后端存储被设计成一个可插拔的组件，支持将数据写入 cassandra、elastic search。
4.Query - 接收查询请求，然后从后端存储系统中检索 trace 并通过 UI 进行展示。 Query 是无状态的，您可以启动多个实例，把它们部署在 nginx 这样的负载均衡器后面。
分布式追踪系统发展很快，种类繁多，但核心步骤一般有三个：代码埋点，数据存储、查询展示订单调用过程

添加jaeger

1. sudo go get github.com/jaegertracing/jaeger-client-go

复制代码

发送span

1. package main
   
2. 
   
3. import (
   
4.         "time"
   
5. 
   
6.         "github.com/uber/jaeger-client-go"
   
7.         jaegercfg "github.com/uber/jaeger-client-go/config"
   
8. )
   
9. 
   
10. func main() {
    
11.         cfg := jaegercfg.Configuration{
    
12.                 Sampler: &jaegercfg.SamplerConfig{
    
13.                         Type:  jaeger.SamplerTypeConst,
    
14.                         Param: 1, //[0,1] 0不采样1一直采样
    
15.                 },
    
16.                 Reporter: &jaegercfg.ReporterConfig{
    
17.                         LogSpans:           true, //打不打印日志
    
18.                         LocalAgentHostPort: "192.168.31.19:6831",
    
19.                 },
    
20.                 ServiceName: "shop",
    
21.         }
    
22.         tracer, closer, err := cfg.NewTracer(jaegercfg.Logger(jaeger.StdLogger))
    
23.         if err != nil {
    
24.                 panic(err)
    
25.         }
    
26.         defer closer.Close()
    
27.         span := tracer.StartSpan("go-grpc-web")
    
28.         time.Sleep(time.Second)
    
29.         defer span.Finish()
    
30. }

复制代码

嵌套span

1. package main
   
2. 
   
3. import (
   
4.         "time"
   
5. 
   
6.         "github.com/opentracing/opentracing-go"
   
7.         "github.com/uber/jaeger-client-go"
   
8.         jaegercfg "github.com/uber/jaeger-client-go/config"
   
9. )
   
10. 
    
11. func main() {
    
12.         cfg := jaegercfg.Configuration{
    
13.                 Sampler: &jaegercfg.SamplerConfig{
    
14.                         Type:  jaeger.SamplerTypeConst,
    
15.                         Param: 1, //[0,1] 0不采样1一直采样
    
16.                 },
    
17.                 Reporter: &jaegercfg.ReporterConfig{
    
18.                         LogSpans:           true, //打不打印日志
    
19.                         LocalAgentHostPort: "39.103.59.35:6831",
    
20.                 },
    
21.                 ServiceName: "shop",
    
22.         }
    
23.         tracer, closer, err := cfg.NewTracer(jaegercfg.Logger(jaeger.StdLogger))
    
24.         if err != nil {
    
25.                 panic(err)
    
26.         }
    
27.         defer closer.Close()
    
28.         parentSpan := tracer.StartSpan("main")
    
29. 
    
30.         spanA := tracer.StartSpan("funcA", opentracing.ChildOf(parentSpan.Context()))
    
31.         time.Sleep(time.Millisecond * 500)
    
32.         spanA.Finish()
    
33. 
    
34.         spanB := tracer.StartSpan("funcB", opentracing.ChildOf(parentSpan.Context()))
    
35.         time.Sleep(time.Millisecond * 1000)
    
36.         spanB.Finish()
    
37. 
    
38.         parentSpan.Finish()
    
39. }

复制代码

grpc使用jaeger

1. package main
   
2. 
   
3. import (
   
4.         "context"
   
5.         "fmt"
   
6.         "japter_test/proto"
   
7. 
   
8.         "japter_test/otgrpc"
   
9. 
   
10.         "github.com/opentracing/opentracing-go"
    
11.         "github.com/uber/jaeger-client-go"
    
12.         jaegercfg "github.com/uber/jaeger-client-go/config"
    
13.         "google.golang.org/grpc"
    
14. )
    
15. 
    
16. func main() {
    
17.         cfg := jaegercfg.Configuration{
    
18.                 ServiceName: "mxshop",
    
19.                 Sampler: &jaegercfg.SamplerConfig{
    
20.                         Type:  jaeger.SamplerTypeConst,
    
21.                         Param: 1, //[0,1] 0不采样1一直采样
    
22.                 },
    
23.                 Reporter: &jaegercfg.ReporterConfig{
    
24.                         LogSpans:           true, //打不打印日志
    
25.                         LocalAgentHostPort: "39.103.59.35:6831",
    
26.                 },
    
27.         }
    
28.         tracer, closer, err := cfg.NewTracer(jaegercfg.Logger(jaeger.StdLogger))
    
29.         if err != nil {
    
30.                 panic(err)
    
31.         }
    
32.         opentracing.SetGlobalTracer(tracer)
    
33.         defer closer.Close()
    
34. 
    
35.         conn, err := grpc.Dial("127.0.0.1:8080", grpc.WithInsecure(), grpc.WithUnaryInterceptor(otgrpc.OpenTracingClientInterceptor(opentracing.GlobalTracer())))
    
36.         if err != nil {
    
37.                 panic(err)
    
38.         }
    
39.         defer conn.Close()
    
40.         c := proto.NewGreeterClient(conn)
    
41.         r, err := c.SayHello(context.Background(), &proto.HelloRquest{
    
42.                 Name: "bobby",
    
43.         })
    
44.         if err != nil {
    
45.                 panic(err)
    
46.         }
    
47.         fmt.Println(r.Message)
    
48. }

复制代码

gin使用jaeger

拦截器

1. package middlewares
   
2. 
   
3. import (
   
4.         "GolangStudy/Practice/shop/goods-web/global"
   
5.         "fmt"
   
6. 
   
7.         "github.com/gin-gonic/gin"
   
8.         "github.com/opentracing/opentracing-go"
   
9.         "github.com/uber/jaeger-client-go"
   
10.         jaegerConfig "github.com/uber/jaeger-client-go/config"
    
11. )
    
12. 
    
13. func Trace() gin.HandlerFunc {
    
14.         return func(ctx *gin.Context) {
    
15.                 cfg := jaegerConfig.Configuration{
    
16.                         ServiceName: "your_service_name",
    
17.                         Sampler: &jaegerConfig.SamplerConfig{
    
18.                                 Type:  jaeger.SamplerTypeConst,
    
19.                                 Param: 1, // 1 = always sample
    
20.                         },
    
21.                         Reporter: &jaegerConfig.ReporterConfig{
    
22.                                 LogSpans:           true,
    
23.                                 LocalAgentHostPort: fmt.Sprintf("%s:%d", global.ServerConfig.JaegerInfo.Host, global.ServerConfig.JaegerInfo.Port), // Jaeger Query 服务的地址和端口
    
24.                         },
    
25.                 }
    
26.                 tracer, closer, err := cfg.NewTracer(jaegerConfig.Logger(jaeger.StdLogger))
    
27.                 if err != nil {
    
28.                         panic(err)
    
29.                 }
    
30.                 opentracing.SetGlobalTracer(tracer)
    
31.                 defer closer.Close()
    
32.                 startSpan := tracer.StartSpan(ctx.Request.URL.Path)
    
33.                 defer startSpan.Finish()
    
34.                 ctx.Set("tracer", tracer)
    
35.                 ctx.Set("parentSpan", startSpan)
    
36.                 ctx.Next()
    
37.         }
    
38. }

复制代码

使用

1. GoodsRouter := Router.Group("goods").Use(middlewares.Trace())

复制代码

到此这篇关于golang 链路追踪的实现示例的文章就介绍到这了,更多相关golang 链路追踪内容请搜索晓枫资讯以前的文章或继续浏览下面的相关文章希望大家以后多多支持晓枫资讯！

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！