Golang使用zipkin进行链路监控

准备工作

• docker运行zipkin服务

docker run -d -p 9411:9411 openzipkin/zipkin


一、对grpc服务进行监控

关于Golang使用grpc的内容请转移到这边文章Golang使用grpc实战

代码改造

需要注意对grpc进行监控的zipkin版本需要0.3.5&＃xff0c;访问zipkin的v1版本&＃xff0c;使用最新版本会出现问题

服务端

const (serviceName &＃61; "simple_zipkin_server"zipkinAddr &＃61; "http://127.0.0.1:9411/api/v1/spans"zipkinRecorderAddr &＃61; "127.0.0.1:9000"
)/*获取zipkin的tracer对象&＃xff0c;并把tracer封装成ServerInterceptor注入到grpc.ServerOption中
*/
func NewZipkinTracer(opts []grpc.ServerOption) (opentracing.Tracer, []grpc.ServerOption, error) {collector, err :&＃61; zipkin.NewHTTPCollector(zipkinAddr)if err !&＃61; nil {log.Fatal(err.Error())return nil, opts, err}recorder :&＃61; zipkin.NewRecorder(collector, true, zipkinRecorderAddr, serviceName)tracer, err :&＃61; zipkin.NewTracer(recorder, zipkin.ClientServerSameSpan(true), zipkin.TraceID128Bit(true))if err !&＃61; nil {log.Fatal(err.Error())return nil, opts, err}opts &＃61; append(opts, grpc_middleware.WithUnaryServerChain(otgrpc.OpenTracingServerInterceptor(tracer, otgrpc.LogPayloads()),))return tracer, opts, nil
}func main() {//...go func() {//...var opts &＃61; []grpc.ServerOption{grpc.Creds(cred)}_, opts, err &＃61; NewZipkinTracer(opts)if err !&＃61; nil {log.Fatal(err.Error())return}rpcserver :&＃61; grpc.NewServer(opts...)//...}//...
}


客户端

const (serviceName &＃61; "simple_zipkin_server"zipkinAddr &＃61; "http://127.0.0.1:9411/api/v1/spans"zipkinRecorderAddr &＃61; "127.0.0.1:9000"
)/*获取zipkin的tracer对象&＃xff0c;并把tracer封装成ClientInterceptor注入到grpc.DialOption中
*/
func NewZipkinTracer(opts []grpc.DialOption) (opentracing.Tracer, []grpc.DialOption, error) {collector, err :&＃61; zipkin.NewHTTPCollector(zipkinAddr)if err !&＃61; nil {log.Fatal(err.Error())return nil, opts, err}recorder :&＃61; zipkin.NewRecorder(collector, true, zipkinRecorderAddr, serviceName)tracer, err :&＃61; zipkin.NewTracer(recorder, zipkin.ClientServerSameSpan(true), zipkin.TraceID128Bit(true))if err !&＃61; nil {log.Fatal(err.Error())return nil, opts, err}opts &＃61; append(opts, grpc.WithUnaryInterceptor(otgrpc.OpenTracingClientInterceptor(tracer, otgrpc.LogPayloads()),))return tracer, opts, nil
}func main() {//...var opts &＃61; []grpc.DialOption{grpc.WithTransportCredentials(creds)}_, opts, err &＃61; NewZipkinTracer(opts)if err !&＃61; nil {log.Fatal(err.Error())return}conn, err :&＃61; grpc.Dial(fmt.Sprintf("%v:%d", addr.Service.Address, addr.Service.Port), opts...)if err !&＃61; nil {log.Fatal(err)}defer conn.Close()//...
}


测试

• 先后运行server.go和client.go&＃xff0c;进行一次grpc的调用&＃xff1b;

• 访问http://localhost:9411/zipkin&＃xff0c;选择"serviceName"为"simple_zipkin_server"&＃xff0c;然后点击右边的搜索按钮&＃xff0c;即可看到如下图的调用链监控信息&＃xff1b;

二、对Gin框架的Web服务进行监控

关于Golang使用gin框架构建Web服务的内容请转移到这边文章Go语言Web知识&＃xff08;一&＃xff09; 认识Gin框架

代码改造

var (zkReporter reporter.ReporterzkTracer opentracing.Tracer
)const (serviceName &＃61; "zipkin_gin_server"serviceEndpoint &＃61; "localhost:8080"zipkinAddr &＃61; "http://127.0.0.1:9411/api/v2/spans"
)func initZipkinTracer(engine *gin.Engine) error {zkReporter &＃61; zkHttp.NewReporter(zipkinAddr)endpoint, err :&＃61; zipkin.NewEndpoint(serviceName, serviceEndpoint)if err !&＃61; nil {log.Fatalf("unable to create local endpoint: %&＃43;v\n", err)return err}nativeTracer, err :&＃61; zipkin.NewTracer(zkReporter, zipkin.WithTraceID128Bit(true), zipkin.WithLocalEndpoint(endpoint))if err !&＃61; nil {log.Fatalf("unable to create tracer: %&＃43;v\n", err)return err}zkTracer &＃61; zkOt.Wrap(nativeTracer)opentracing.SetGlobalTracer(zkTracer)// 将tracer注入到gin的中间件中engine.Use(func(c *gin.Context) {span :&＃61; zkTracer.StartSpan(c.FullPath())defer span.Finish()c.Next()})return nil
}func main() {engine :&＃61; gin.Default()err :&＃61; initZipkinTracer(engine)if err !&＃61; nil {panic(err)}defer zkReporter.Close()engine.GET("/ping", func(c *gin.Context) {c.JSON(http.StatusOK, "pong")})//...engine.Run(":8080")
}


测试

• 访问http://localhost:8080/ping&＃xff0c;返回"pong"&＃xff0c;进行一次http请求&＃xff1b;
• 访问http://localhost:9411/zipkin&＃xff0c;选择"serviceName"为"zipkin_gin_server"&＃xff0c;然后点击右边的搜索按钮&＃xff0c;即可看到如下图的调用链监控信息&＃xff1b;