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

import ( zvvq好，好zvvq

"context"

zvvq好，好zvvq

"fmt" 内容来自samhan

"log" zvvq好，好zvvq

"net/http" 内容来自samhan

"time"

内容来自samhan

"go.opentelemetry.io/otel/attribute" zvvq.cn

"go.opentelemetry.io/otel/baggage"

内容来自samhan

"go.opentelemetry.io/otel/propagation" 内容来自zvvq

"go.opentelemetry.io/otel/trace"

内容来自samhan

) 内容来自samhan666

func main() {

// 为追踪器创建一个 TracerProvider。 本文来自zvvq

provider := trace.NewTracerProvider( 内容来自samhan

trace.WithSampler(trace.AlwaysSample()),

)

zvvq好，好zvvq

// 创建 HTTP 句柄。

copyright zvvq

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

// 创建新的上下午和追踪。 zvvq好，好zvvq

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

内容来自zvvq，别采集哟

// 设置追踪属性。 内容来自zvvq，别采集哟

span.SetAttributes(

本文来自zvvq

attribute.String("component", "http-server"), 内容来自zvvq

)

内容来自samhan

// 进行模拟工作。

time.Sleep(100 * time.Millisecond)

// 获取 Baggage 信息。

内容来自samhan666

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

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

// 打印 Baggage 信息。 本文来自zvvq

log.Printf("User ID: %s", userId)

// 结束追踪。

span.End()

// 将 Tracing 头添加到响应。

内容来自samhan

propagation.HTTPFormat{}.Inject(ctx, propagation.HeaderCarrier(r.Header))

// 返回响应。

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

copyright zvvq

}) 内容来自samhan

// 启动 HTTP 服务。 内容来自zvvq，别采集哟

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

}

zvvq