Go微服务: go-micro集成链路追踪jaeger

本文主要是介绍Go微服务: go-micro集成链路追踪jaeger，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

关于链路追踪jeager的原理

参考: https://blog.csdn.net/Tyro_java/article/details/137754812

核心代码演示

1 ) 概述

这里接前文结构框架：https://blog.csdn.net/Tyro_java/article/details/137753232

2 ）核心代码：common/jaeger.go

package commonimport ("io""time""github.com/opentracing/opentracing-go""github.com/uber/jaeger-client-go"jaegerConfig "github.com/uber/jaeger-client-go/config"
)// 初始化Jaeger Tracer实例
func NewTracer(serviceName string, addr string) (opentracing.Tracer, io.Closer, error) {cfg := jaegerConfig.Configuration{ServiceName: serviceName,Sampler: &jaegerConfig.SamplerConfig{Type:  jaeger.SamplerTypeConst,Param: 1, // 采样率设置为1，即100%采样},Reporter: &jaegerConfig.ReporterConfig{BufferFlushInterval: 1 * time.Second,LogSpans:            true,LocalAgentHostPort:  addr,},}return cfg.NewTracer()
}

可见，这里封装了 Jaeger Tracer 的实例

2 ）核心代码 main.go

package mainimport ("fmt""log""strconv""github.com/go-micro/plugins/v4/registry/consul"opentracingFn "github.com/go-micro/plugins/v4/wrapper/trace/opentracing""github.com/opentracing/opentracing-go""go-micro.dev/v4""go-micro.dev/v4/registry""gitee.com/go-micro-services/product/common""gitee.com/go-micro-services/product/domain/repository""gitee.com/go-micro-services/product/domain/service""gitee.com/go-micro-services/product/handler"pbproduct "gitee.com/go-micro-services/product/proto/product""github.com/jinzhu/gorm"_ "github.com/jinzhu/gorm/dialects/mysql"
)var (serviceName     = "go.micro.service.product"version         = "latest"host            = "127.0.0.1"port            = 8090address         = host + ":" + strconv.Itoa(port)mysqlConfigPath = "/micro/config/mysql"
)func main() {// 1. 指定注册中心consulReg := consul.NewRegistry(registry.Addrs(address),)// 2. 从配置中心获取mysql配置并创建处理mysqlConfig, consulConfigErr := common.GetConsulMysqlConfig(address, mysqlConfigPath)if consulConfigErr != nil {log.Fatal(consulConfigErr)}mysqlUrl := fmt.Sprintf("%s:%s@tcp(%s:%d)/%s?charset=utf8&parseTime=True&loc=Local", mysqlConfig.User, mysqlConfig.Pwd, mysqlConfig.Host, mysqlConfig.Port, mysqlConfig.Database)db, dbErr := gorm.Open("mysql", mysqlUrl)if dbErr != nil {log.Fatal(dbErr)}defer db.Close()db.SingularTable(false) // true 则 表就是单数rp := repository.NewProductRepository(db)// 数据库表初始化，只执行一次, 如果本来就设计好了，则无需下面// rp.InitTable()// 3. 链路追踪配置tracer, closer, tracerErr := common.NewTracer("go.micro.service.product", "localhost:6831")if tracerErr != nil {log.Fatal(tracerErr)}defer closer.Close()opentracing.SetGlobalTracer(tracer)// 4. 创建服务实例productDataService := service.NewProductDataService(rp)// 5. 创建服务和初始化srv := micro.NewService()srv.Init(micro.Name(serviceName),micro.Version(version),micro.Registry(consulReg),micro.WrapHandler(opentracingFn.NewHandlerWrapper(opentracing.GlobalTracer())), // 绑定链路追踪)// 6. 注册 handlerif handlerErr := pbproduct.RegisterProductHandler(srv.Server(), &handler.Product{ProductDataService: productDataService}); handlerErr != nil {log.Fatal(handlerErr)}// 7. 运行服务if runErr := srv.Run(); runErr != nil {log.Fatal(runErr)}
}