go-gin-api 路由中間件 - Jaeger 鏈路追蹤

来源:https://www.cnblogs.com/it-3327/archive/2019/11/09/11827993.html

概述首先同步下項目概況:上篇文章分享了,路由中間件 - Jaeger 鏈路追蹤(理論篇)。這篇文章咱們分享:路由中間件 - Jaeger 鏈路追蹤(實戰篇)。說實話,這篇文章確實讓大家久等了,主要是裡面有一些技術點都是剛剛研究的,沒有存貨。先看下咱們要實現的東西:API 調用了 5 個服務,其中 4 ...


概述

首先同步下項目概況:



上篇文章分享了,路由中間件 - Jaeger 鏈路追蹤(理論篇)。

這篇文章咱們分享:路由中間件 - Jaeger 鏈路追蹤(實戰篇)。

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

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


API 調用了 5 個服務,其中 4 個 gRPC 服務,1 個 HTTP 服務,服務與服務之間又相互調用:

    Speak 服務,又調用了 Listen 服務 和 Sing 服務。

    Read 服務,又調用了 Listen 服務 和 Sing 服務。

    Write 服務,又調用了 Listen 服務 和 Sing 服務。

咱們要實現的就是查看 API 調用的鏈路。

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

OK,開整。

Jaeger 部署

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

下載地址:https://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, closer, 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),    
                opentracing.Tag{Key: string(ext.Component), 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, req, 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),    
                    opentracing.Tag{Key: string(ext.Component), Value: "gRPC"},    
                    ext.SpanKindRPCServer,    
                )    
                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

 



效果




基本實現了,就到這吧。


您的分享是我們最大的動力!

更多相關文章
  • 概述首先同步下項目概況:上篇文章分享了,規劃項目目錄和參數驗證,其中參數驗證使用的是 validator.v8 版本,現已更新到 validator.v9 版本,最新代碼查看 github 即可。這篇文章咱們分享:路由中間件 - 日誌記錄。日誌是特別重要的一個東西,方便我們對問題進行排查,這篇文章我 ...
  • 本文主要學習了在Java1.8中新增的Collector介面和Collectors工具類,以及使用它們在處理集合時的改進和優化。 ...
  • 模塊安裝 Windows 安裝scrapy 需要安裝依賴環境twisted,twisted又需要安裝C++的依賴環境 pip install scrapy 時 如果出現twisted錯誤 在https://www.lfd.uci.edu/~gohlke/pythonlibs/ 下載對應的Twiste ...
  • me:5次 標準答案:5 次,因為從 0 開始,到 10 結束,步進為 2。 1. 下麵的迴圈會列印多少次"I Love FishC"? me:錯誤,迴圈應該使用的是一個數組,比如range() 標準答案:會報錯,上節課的課後習題我們提到了 in 是“成員資格運算符”,而不是像 C 語言那樣去使用 ...
  • 概述首先同步下項目概況:上篇文章分享了,路由中間件 - 日誌記錄,這篇文章咱們分享:路由中間件 - 捕獲異常。當系統發生異常時,提示 “系統異常,請聯繫管理員!”,併發送 panic 告警郵件。什麼是異常?在 Go 中異常就是 panic,它是在程式運行的時候拋出的,當 panic 拋出之後,如果在 ...
  • [TOC] 這篇博客及之後的系列,我會向大家介紹各種驗證碼的識別。包括普通圖形驗證碼,極驗滑動驗證碼,點觸驗證碼,微博宮格驗證碼。 一.普通圖形驗證碼 之前的博客已向大家介紹了簡單的圖形驗證碼的處理過程,但是會和實際的有所差別,這是因為驗證碼內的多餘線條與圖案干擾了圖片的識別。因此,對於這種情況,需 ...
  • 前言 Java文件的運行過程: 1,javac.exe:編譯器 2,java.exe:解釋器 微軟shell下運行實例: C:\Users\Administrator>cd D:\文檔\JAVALIAnxi\ C:\Users\Administrator>d: D:\文檔\JAVALIAnxi>ja ...
  • 把所有的節點用一根直線串起來 連續存儲[數組] 什麼叫做數組:元素類型相同,大小相等 重點看代碼吧,需要註意的都在註釋里,多敲幾遍,當然了,有些功能還沒有實現,以後再實現 ...
一周排行
  • 微信公眾號: "Dotnet9" ,網站: "Dotnet9" ,問題或建議: "請網站留言" , 如果對您有所幫助: "歡迎贊賞" 。 .NET CORE(C ) WPF 抽屜式菜單 閱讀導航 1. 本文背景 2. 代碼實現 3. 本文參考 4. 源碼 1. 本文背景 使用簡單動畫實現抽屜式菜單 ...
  • 在上面abp(net core)+easyui+efcore實現倉儲管理系統——ABP WebAPI與EasyUI結合增刪改查之八(三十四) 文章的學習之後。我們通過前面的八篇文章已經學習了通過WebAPI介面與控制器去實現新增、刪除與修改功能。接下來,我們要在控制器中實現查詢功能。 ...
  • 1.選中項目-->屬性-->生成-->選中 XML文檔文件(xml路徑和該項目相同) 2.選擇生成序列化程式集:自動/開 ...
  • 本筆記摘抄自:https://www.cnblogs.com/PatrickLiu/p/7640873.html,記錄一下學習過程以備後續查用。 一、引言 從今天開始我們開始講結構型設計模式,結構型設計模式有如下幾種:適配器模式、橋接模式、裝飾模式、組合模式、外觀模式、享元模式、代理模式。 創建型設 ...
  • C 中 ConfigureAwait 相關答疑FAQ 在前段時間經常看到園子里有一些文章討論到 ConfigureAwait,剛好今天在微軟官方博客看到了 "Stephen Toub" 前不久的一篇答疑 ConfigureAwait 的一篇文章,想翻譯過來。 原文地址:https://devblog ...
  • 想要實現二維數組中根據某個欄位排序,一般可以通過數組迴圈對比的方式實現。這裡介紹一種更簡單的方法,直接通過PHP函數實現。array_multisort() :可以用來一次對多個數組進行排序,或者根據某一維或多維對多維數組進行排序。詳細介紹可參考PHP手冊:https://www.php.net/m ...
  • 常用的軟體: 播放器: cloundMusic(網易雲音樂) https://music.163.com/#/download PotPlayer(一款強大的視頻播放器) https://daumpotplayer.com/download/ ACDsee(ACDsee圖片編輯器免費版) https ...
  • 發現問題 在一次偶然中,在爬取某個網站時,老方法,打開調試工具查看請求方式,請求攔截,是否是非同步載入,不亦樂乎,當我以為這個網站非常簡單的時候,發現二級網頁的地址和源碼不對應 Ajax非同步載入?源碼也是這樣的 而且這些鏈接直... ...
  • 準備年後要跳槽,所以最近一直再看面試題,並且把收集到的面試題整理了以下發到博客上,希望對大家有所幫助。 首先是集合類的面試題 1. HashMap 排序題,上機題。 已知一個 HashMap<Integer,User>集合, User 有 name(String)和 age(int)屬性。請寫一個方 ...
  • JVM體繫結構圖 Native Interface(本地介面) Java本地介面(Java Native Interface (JNI))允許運行在Java虛擬機(Java Virtual Machine (JVM))上的代碼調用本地程式和類庫,或者被它們調用,這些程式和類庫可以是其它語言編寫的,比 ...
x