概述

首先同步下專案概況：

上篇文章分享了，路由中介軟體 - Jaeger 鏈路追蹤（理論篇），這篇文章咱們接著分享：路由中介軟體 - Jaeger 鏈路追蹤（實戰篇）。

這篇文章，確實讓大家久等了，主要是裡面有一些技術點都是剛剛研究的，沒有存貨。

先看下咱們要實現的東西：

API 呼叫了 5 個服務，其中 4 個 gRPC 服務，1 個 HTTP 服務，服務與服務之間又相互呼叫：

• Speak 服務，又呼叫了 Listen 服務 和 Sing 服務。
• Read 服務，又呼叫了 Listen 服務 和 Sing 服務。
• Write 服務，又呼叫了 Listen 服務 和 Sing 服務。

咱們要實現的就是檢視 API 呼叫的鏈路。

關於一些理論的東西，大家可以去看看上篇文章或查閱一些資料，這篇文章就是實現怎麼用。

OK，開整。

Jaeger 部署

咱們使用 All in one 的方式，進行本地部署。

下載地址：www.jaegertracing.io/download/

我的電腦是 macOS 選擇 -> Binaries -> macOS

下載後並解壓，會發現以下檔案：

• example-hotrod
• jaeger-agent
• jaeger-all-in-one
• jaeger-collector
• jaeger-ingester
• jaeger-query

進入到解壓後的目錄執行：

./jaeger-all-in-one
複製程式碼

目測啟動後，訪問地址：

http://127.0.0.1:16686/

到這，Jaeger 已經部署成功了。

準備測試服務

準備的五個測試服務如下：

聽（listen）

• 埠：9901
• 通訊：gRPC

說（speak）

• 埠：9902
• 通訊：gRPC

讀（read）

• 埠：9903
• 通訊：gRPC

寫（write）

• 埠：9904
• 通訊：gRPC

唱（sing）

• 埠：9905
• 通訊：HTTP

聽、說、讀、寫、唱，想這幾個服務的名稱就花了好久 ~

我預設大家都會寫 grpc 服務，如果不會寫的，可以檢視下我原來的文章《Go gRPC Hello World

應用示例

例項化 Tracer

func NewJaegerTracer(serviceName string,jaegerHostPort string) (opentracing.Tracer,io.Closer,error) {

	cfg := &jaegerConfig.Configuration {
		Sampler: &jaegerConfig.SamplerConfig{
			Type  : "const",//固定取樣
			Param : 1,//1=全取樣、0=不取樣
		},Reporter: &jaegerConfig.ReporterConfig{
			LogSpans           : true,LocalAgentHostPort : jaegerHostPort,},ServiceName: serviceName,}

	tracer,closer,err := cfg.NewTracer(jaegerConfig.Logger(jaeger.StdLogger))
	if err != nil {
		panic(fmt.Sprintf("ERROR: cannot init Jaeger: %v\n",err))
	}
	opentracing.SetGlobalTracer(tracer)
	return tracer,err
}
複製程式碼

HTTP 注入

injectErr := jaeger.Tracer.Inject(span.Context(),opentracing.HTTPHeaders,opentracing.HTTPHeadersCarrier(req.Header))
if injectErr != nil {
	log.Fatalf("%s: Couldn't inject headers",err)
}
複製程式碼

HTTP 攔截

spCtx,err := opentracing.GlobalTracer().Extract(opentracing.HTTPHeaders,opentracing.HTTPHeadersCarrier(c.Request.Header))
if err != nil {
	ParentSpan = Tracer.StartSpan(c.Request.URL.Path)
	defer ParentSpan.Finish()
} else {
	ParentSpan = opentracing.StartSpan(
		c.Request.URL.Path,opentracing.ChildOf(spCtx),opentracing.Tag{Key: string(ext.Component),Value: "HTTP"},ext.SpanKindRPCServer,)
	defer ParentSpan.Finish()
}
複製程式碼

gRPC 注入

func ClientInterceptor(tracer opentracing.Tracer,spanContext opentracing.SpanContext) grpc.UnaryClientInterceptor {
	return func(ctx context.Context,method string,req,reply interface{},cc *grpc.ClientConn,invoker grpc.UnaryInvoker,opts ...grpc.CallOption) error {

		span := opentracing.StartSpan(
			"call gRPC",opentracing.ChildOf(spanContext),Value: "gRPC"},ext.SpanKindRPCClient,)

		defer span.Finish()

		md,ok := metadata.FromOutgoingContext(ctx)
		if !ok {
			md = metadata.New(nil)
		} else {
			md = md.Copy()
		}

		err := tracer.Inject(span.Context(),opentracing.TextMap,MDReaderWriter{md})
		if err != nil {
			span.LogFields(log.String("inject-error",err.Error()))
		}

		newCtx := metadata.NewOutgoingContext(ctx,md)
		err = invoker(newCtx,method,reply,cc,opts...)
		if err != nil {
			span.LogFields(log.String("call-error",err.Error()))
		}
		return err
	}
}
複製程式碼

gRPC 攔截

func serverInterceptor(tracer opentracing.Tracer) grpc.UnaryServerInterceptor {
	return func(ctx context.Context,req interface{},info *grpc.UnaryServerInfo,handler grpc.UnaryHandler) (resp interface{},err error) {

		md,ok := metadata.FromIncomingContext(ctx)
		if !ok {
			md = metadata.New(nil)
		}

		spanContext,err := tracer.Extract(opentracing.TextMap,MDReaderWriter{md})
		if err != nil && err != opentracing.ErrSpanContextNotFound {
			grpclog.Errorf("extract from metadata err: %v",err)
		} else {
			span := tracer.StartSpan(
				info.FullMethod,ext.RPCServerOption(spanContext),)
			defer span.Finish()

			ParentContext = opentracing.ContextWithSpan(ctx,span)
		}

		return handler(ParentContext,req)
	}
}
複製程式碼

上面是一些核心的程式碼，涉及到的全部程式碼我都會上傳到 github，供下載。

執行

啟動服務

// 啟動 Listen 服務
cd listen && go run main.go

// 啟動 Speak 服務
cd speak && go run main.go

// 啟動 Read 服務
cd read && go run main.go

// 啟動 Write 服務
cd write && go run main.go

// 啟動 Sing 服務
cd sing && go run main.go

// 啟動 go-gin-api 服務
cd go-gin-api && go run main.go
複製程式碼

訪問路由

http://127.0.0.1:9999/jaeger_test

效果

就到這吧。

API 原始碼地址

github.com/xinliangnot…

Service 原始碼地址

github.com/xinliangnot…

go-gin-api 系列文章

• 1. 使用 go modules 初始化專案
• 2. 規劃專案目錄和引數驗證
• 3. 路由中介軟體 - 日誌記錄
• 4. 路由中介軟體 - 捕獲異常
• 5. 路由中介軟體 - Jaeger 鏈路追蹤（理論篇）