Jaeger链路追踪浅析及安装使用流程步骤

Go  /  管理员 发布于 2年前   933

什么是链路追踪?

这里的链路指的是客户端向服务发起一个请求，该请求所经过的路线，也可以说是该请求经过的流量

例如：

客户端发起一个下订单的请求其流量过程：

request—>service—>order-web—>order_srv—>mysql—>order_srv—>order-web—>service—>response

这就一个请求的完整链路

链路追踪

指我们通过一些手段将链路进行监控， 对于系统调试和维护链路追踪是非常重要的，

尤其微服务中，我们知道各个微服务部署在不同的服务器上，并且每一个微服务可能是不同的人开发的，如果我们不做链路追踪，微服务之间相互调用，假如有的微服务出问题了，整个系统都会受影响，

那么我们怎么知道是哪一个微服务出的问题，找谁维护等一系列问题。

docker Jaeger的安装

docker run \
  --rm \
  --name jaeger \
  -p6831:6831/udp \
  -p16686:16686 \
  jaegertracing/all-in-one:latest

启动成功后可以访问：localhost:16686

架构图：

Jaeger的快速使用

使用 jaeger 就行链路追踪

package main
import (
    "time"
    "github.com/opentracing/opentracing-go"
    "github.com/uber/jaeger-client-go"
    jaegercfg "github.com/uber/jaeger-client-go/config"
)
func main() {
    //初始化配置
    cfg := jaegercfg.Configuration{
        Sampler: &jaegercfg.SamplerConfig{
            Type:  jaeger.SamplerTypeConst,
            Param: 1,
        },
        Reporter: &jaegercfg.ReporterConfig{
            LogSpans:           true,
            LocalAgentHostPort: "127.0.0.1:6831",
        },
        ServiceName: "mxshop",
    }
    //初始化跟踪链
    Tracer, Closer, err := cfg.NewTracer(jaegercfg.Logger(jaeger.StdLogger))
    if err != nil {
        panic(err)
    }
    //将跟踪连设置为项目全局变量
    opentracing.SetGlobalTracer(Tracer)
    //span1 := opentracing.StartSpan("funcA")
    //time.Sleep(time.Second * 1)
    //span1.Finish()
    defer Closer.Close()
    span1 := Tracer.StartSpan("funcA")            //开始追踪
    time.Sleep(time.Second * 1)
    span1.Finish()            //完成追踪
    span2 := Tracer.StartSpan("funcC")         //开始追踪
    time.Sleep(time.Second * 2)
    span2.Finish()            //完成追踪
}

我们在ui界面可以看到两个Traces里面有运行的时间等信息

层级关系：

package main
import (
    "time"
    "github.com/opentracing/opentracing-go"
    "github.com/uber/jaeger-client-go"
    jaegercfg "github.com/uber/jaeger-client-go/config"
)
func main() {
    //初始化配置
    cfg := jaegercfg.Configuration{
        Sampler: &jaegercfg.SamplerConfig{
            Type:  jaeger.SamplerTypeConst,
            Param: 1,
        },
        Reporter: &jaegercfg.ReporterConfig{
            LogSpans:           true,
            LocalAgentHostPort: "10.2.118.0:6831",
        },
        ServiceName: "test",
    }
    //初始化跟踪连
    Tracer, Closer, err := cfg.NewTracer(jaegercfg.Logger(jaeger.StdLogger))
    if err != nil {
        panic(err)
    }
    defer Closer.Close()
    Parents := Tracer.StartSpan("main")
    span1 := Tracer.StartSpan("funcD", opentracing.ChildOf(Parents.Context()))
    time.Sleep(time.Second * 1)
    span1.Finish()
    span2 := Tracer.StartSpan("funcE", opentracing.ChildOf(Parents.Context()))
    time.Sleep(time.Second * 2)
    span2.Finish()
}

测试效果，可以看到

main:
 
funcD:———1s———
 
funcE —————————-2s———————
![截屏 2022-11-13 下午 8.55.53](/Users/zongscan/Desktop/ 截屏 2022-11-13 下午 8.55.53.png)

相关教程：将jaeger集成到grpc服务中

https://www.zongscan.com/demo333/96041.html