欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

golang?鏈路追蹤的實現示例

 更新時間：2025年03月03日 10:39:09   作者：愛編程的 小李  
本文主要介紹了golang?鏈路追蹤的實現示例,包括調用鏈過長和接口響應慢的問題,具有一定的參考價值,感興趣的可以了解一下

分布式鏈路追蹤（Distributed Tracing），也叫分布式鏈路跟蹤，分布式跟蹤，分布式追蹤等等。

問題

場景1:調用鏈過長，查詢很慢

在這里插入圖片描述

web-gin由A負責，服務A由B負責，某個接口出現異常了，先查詢日志看是哪個地方出錯了，發(fā)現服務A調用失敗，依次找到D

場景2:接口相應很慢

在這里插入圖片描述

解決方法

(1)打日志:慢(可能不看懂其他人寫的日志)
(2)ELK:可以解決，也是日志需要寫入
(3)第三方鏈路追蹤系統可以解決

鏈路追蹤系統技術選型

java使用zipkin和skywalking比較多，而go使用jaeger多

zipkinjaegerskywalking
OpenTracing是是是
客戶端支持語言java、c#、php、python等java、c#、go、php、python等java、.Net Core、NodeJS、PHP、python
存儲ES、Mysql、Cassandra內存ES、kafka、Cassandra內存ES、H2、mysql、TIDB、shard sphere
傳輸協議支持http、MQudp/httpgRPC
ui豐富程度低中中
實現方式-代碼侵入式攔截請求，侵入攔截請求，侵入字節(jié)碼注入，無侵入
擴展性高高中
trace查詢支持支持支持
性能損失中中低
選擇jaeger:官方支持jaeger
技術選型原則：
客戶端支持、綜合考慮、什么語言開發(fā)的

安裝jaeger

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

架構

在這里插入圖片描述

Jaeger組成

1.Jaeger Client - 為不同語言實現了符合 OpenTracing 標準的 SDK。應用程序通過 API 寫入數據，client library 把 trace 信息按照應用程序指定的采樣策略傳遞給 jaeger-agent。
2.Agent - 它是一個監(jiān)聽在 UDP 端口上接收 span 數據的網絡守護進程，它會將數據批量發(fā)送給 collector。它被設計成一個基礎組件，部署到所有的宿主機上。Agent 將 client library 和 collector 解耦，為 client library 屏蔽了路由和發(fā)現 collector 的細節(jié)。2.Collector - 接收 jaeger-agent 發(fā)送來的數據，然后將數據寫入后端存儲。Collector 被設計成無狀態(tài)的組件，因此您可以同時運行任意數量的 jaeger-collector。
3.Data Store - 后端存儲被設計成一個可插拔的組件，支持將數據寫入 cassandra、elastic search。
4.Query - 接收查詢請求，然后從后端存儲系統中檢索 trace 并通過 UI 進行展示。 Query 是無狀態(tài)的，您可以啟動多個實例，把它們部署在 nginx 這樣的負載均衡器后面。
分布式追蹤系統發(fā)展很快，種類繁多，但核心步驟一般有三個：代碼埋點，數據存儲、查詢展示訂單調用過程

在這里插入圖片描述

添加jaeger

sudo go get github.com/jaegertracing/jaeger-client-go

發(fā)送span

package main

import (
	"time"

	"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, //[0,1] 0不采樣1一直采樣
		},
		Reporter: &jaegercfg.ReporterConfig{
			LogSpans:           true, //打不打印日志
			LocalAgentHostPort: "192.168.31.19:6831",
		},
		ServiceName: "shop",
	}
	tracer, closer, err := cfg.NewTracer(jaegercfg.Logger(jaeger.StdLogger))
	if err != nil {
		panic(err)
	}
	defer closer.Close()
	span := tracer.StartSpan("go-grpc-web")
	time.Sleep(time.Second)
	defer span.Finish()
}

嵌套span

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, //[0,1] 0不采樣1一直采樣
		},
		Reporter: &jaegercfg.ReporterConfig{
			LogSpans:           true, //打不打印日志
			LocalAgentHostPort: "39.103.59.35:6831",
		},
		ServiceName: "shop",
	}
	tracer, closer, err := cfg.NewTracer(jaegercfg.Logger(jaeger.StdLogger))
	if err != nil {
		panic(err)
	}
	defer closer.Close()
	parentSpan := tracer.StartSpan("main")

	spanA := tracer.StartSpan("funcA", opentracing.ChildOf(parentSpan.Context()))
	time.Sleep(time.Millisecond * 500)
	spanA.Finish()

	spanB := tracer.StartSpan("funcB", opentracing.ChildOf(parentSpan.Context()))
	time.Sleep(time.Millisecond * 1000)
	spanB.Finish()

	parentSpan.Finish()
}

grpc使用jaeger

package main

import (
	"context"
	"fmt"
	"japter_test/proto"

	"japter_test/otgrpc"

	"github.com/opentracing/opentracing-go"
	"github.com/uber/jaeger-client-go"
	jaegercfg "github.com/uber/jaeger-client-go/config"
	"google.golang.org/grpc"
)

func main() {
	cfg := jaegercfg.Configuration{
		ServiceName: "mxshop",
		Sampler: &jaegercfg.SamplerConfig{
			Type:  jaeger.SamplerTypeConst,
			Param: 1, //[0,1] 0不采樣1一直采樣
		},
		Reporter: &jaegercfg.ReporterConfig{
			LogSpans:           true, //打不打印日志
			LocalAgentHostPort: "39.103.59.35:6831",
		},
	}
	tracer, closer, err := cfg.NewTracer(jaegercfg.Logger(jaeger.StdLogger))
	if err != nil {
		panic(err)
	}
	opentracing.SetGlobalTracer(tracer)
	defer closer.Close()

	conn, err := grpc.Dial("127.0.0.1:8080", grpc.WithInsecure(), grpc.WithUnaryInterceptor(otgrpc.OpenTracingClientInterceptor(opentracing.GlobalTracer())))
	if err != nil {
		panic(err)
	}
	defer conn.Close()
	c := proto.NewGreeterClient(conn)
	r, err := c.SayHello(context.Background(), &proto.HelloRquest{
		Name: "bobby",
	})
	if err != nil {
		panic(err)
	}
	fmt.Println(r.Message)
}

gin使用jaeger

攔截器

package middlewares

import (
	"GolangStudy/Practice/shop/goods-web/global"
	"fmt"

	"github.com/gin-gonic/gin"
	"github.com/opentracing/opentracing-go"
	"github.com/uber/jaeger-client-go"
	jaegerConfig "github.com/uber/jaeger-client-go/config"
)

func Trace() gin.HandlerFunc {
	return func(ctx *gin.Context) {
		cfg := jaegerConfig.Configuration{
			ServiceName: "your_service_name",
			Sampler: &jaegerConfig.SamplerConfig{
				Type:  jaeger.SamplerTypeConst,
				Param: 1, // 1 = always sample
			},
			Reporter: &jaegerConfig.ReporterConfig{
				LogSpans:           true,
				LocalAgentHostPort: fmt.Sprintf("%s:%d", global.ServerConfig.JaegerInfo.Host, global.ServerConfig.JaegerInfo.Port), // Jaeger Query 服務的地址和端口
			},
		}
		tracer, closer, err := cfg.NewTracer(jaegerConfig.Logger(jaeger.StdLogger))
		if err != nil {
			panic(err)
		}
		opentracing.SetGlobalTracer(tracer)
		defer closer.Close()
		startSpan := tracer.StartSpan(ctx.Request.URL.Path)
		defer startSpan.Finish()
		ctx.Set("tracer", tracer)
		ctx.Set("parentSpan", startSpan)
		ctx.Next()
	}
}

使用

GoodsRouter := Router.Group("goods").Use(middlewares.Trace())

到此這篇關于golang 鏈路追蹤的實現示例的文章就介紹到這了,更多相關golang 鏈路追蹤內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！ 

相關文章

  • go語言實現簡單的并發(fā)網頁爬蟲示例

    go語言實現簡單的并發(fā)網頁爬蟲示例

    在這個章節(jié)中,我們將會結合之前的知識點,實現一個簡易的并發(fā)網頁爬蟲,我們的爬蟲會先爬取一個起始頁面,提取出所有的鏈接,然后并發(fā)地爬取這些鏈接,有需要的朋友可以借鑒參考下,希望能夠有所幫助
    2023-08-08
  • Go語言中 Channel 詳解

    Go語言中 Channel 詳解

    Go 語言中的 channel 是實現 goroutine 間無鎖通信的關鍵機制，他使得寫多線程并發(fā)程序變得簡單、靈活、觸手可得。下面就個人理解對 channel 使用過程中應該注意的地方進行一個簡要的總結。
    2018-10-10
  • Go?modules?replace解決Go依賴引用問題

    Go?modules?replace解決Go依賴引用問題

    這篇文章主要為大家介紹了Go?modules?replace解決Go依賴引用問題，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪
    2022-06-06
  • Go語言實現服務端消息接收和發(fā)送

    Go語言實現服務端消息接收和發(fā)送

    這篇文章主要為大家詳細介紹了Go語言實現服務端消息接收和發(fā)送功能，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下
    2022-07-07
  • Go語言學習之指針的用法詳解

    Go語言學習之指針的用法詳解

    這篇文章主要為大家詳細介紹了Go語言中指針的用法，文中的示例代碼講解詳細，對我們學習Go語言有一定的幫助，需要的可以參考一下
    2022-04-04
  • 淺析Go語言中的棧和先進先出原則

    淺析Go語言中的棧和先進先出原則

    這篇文章主要來和大家探討一樣如何在Go語言中實現和使用堆棧，以及堆棧如何遵循先進先出 (FIFO) 原則，文中的示例代碼簡潔易懂，需要的可以參考一下
    2023-07-07
  • Golang配置管理庫?Viper的教程詳解

    Golang配置管理庫?Viper的教程詳解

    這篇文章主要介紹了Golang?配置管理庫?Viper,使用?viper?能夠很好的去管理你的配置文件信息，比如數據庫的賬號密碼，服務器監(jiān)聽的端口，你可以通過更改配置文件去更改這些內容，而不用定位到那一段代碼上去，提高了開發(fā)效率，需要的朋友可以參考下
    2022-05-05
  • golang中單向channel的語法介紹

    golang中單向channel的語法介紹

    通過消息來共享數據是golang的一種設計哲學，channel則是這種哲理的體現。下面這篇文章主要給大家介紹了關于golang中單向channel語法的相關資料，文中通過示例代碼介紹的非常詳細，需要的朋友們下面來一起看看吧。
    2017-07-07
  • Go語言區(qū)別于其他語言的特性

    Go語言區(qū)別于其他語言的特性

    在本文中，今天這篇文章將給大家介紹一下 Go 與其他語言不同的 9 個特性,需要的朋友可以參考下面文章的具體內容
    2021-10-10
  • Golang中println和fmt.Println區(qū)別解析

    Golang中println和fmt.Println區(qū)別解析

    Golang 中打印數據通常使用 fmt.Println() 方法，也可以使用內置的 println() 方法。這兩個方法大家可能都使用過，它們的區(qū)別是什么呢?本文給大家詳細講解，感興趣的朋友跟隨小編一起看看吧
    2023-03-03

最新評論