golang框架中分布式追踪如何与微服务架构配合使

import (

copyright zvvq

"context" 内容来自zvvq，别采集哟

"fmt"

"log"

"net/http"

"time"

内容来自samhan

"go.opentelemetry.io/otel/attribute"

内容来自samhan666

"go.opentelemetry.io/otel/baggage"

"go.opentelemetry.io/otel/propagation"

copyright zvvq

"go.opentelemetry.io/otel/trace"

)

zvvq.cn

func main() {

// 为追踪器创建一个 TracerProvider。

本文来自zvvq

provider := trace.NewTracerProvider( 本文来自zvvq

trace.WithSampler(trace.AlwaysSample()),

)

// 创建 HTTP 句柄。 内容来自samhan

http.HandleFunc("/", func(w http.ResponseWriter, r http.Request) {

// 创建新的上下午和追踪。 内容来自zvvq

ctx, span := provider.Tracer("my-service").Start(r.Context(), "request-handler")

// 设置追踪属性。 copyright zvvq

span.SetAttributes( zvvq.cn

attribute.String("component", "http-server"), 本文来自zvvq

)

内容来自samhan

// 进行模拟工作。 zvvq好，好zvvq

time.Sleep(100 time.Millisecond) 本文来自zvvq

// 获取 Baggage 信息。

bag := baggage.FromContext(r.Context())

内容来自samhan666

userId, _ := bag.Value("user-id").String()

内容来自zvvq，别采集哟

// 打印 Baggage 信息。

log.Printf("User ID: %s", userId) 内容来自zvvq，别采集哟

// 结束追踪。

zvvq好，好zvvq

span.End() zvvq好，好zvvq

// 将 Tracing 头添加到响应。

propagation.HTTPFormat{}.Inject(ctx, propagation.HeaderCarrier(r.Header)) 内容来自samhan666

// 返回响应。 内容来自zvvq，别采集哟

fmt.Fprintf(w, "Hello from my-service!")

copyright zvvq

})

// 启动 HTTP 服务。 zvvq好，好zvvq

log.Fatal(http.ListenAndServe(":8080", nil)) copyright zvvq

}

本文来自zvvq