golang框架中分布式追踪如何与其他监控系统集成

import ( zvvq.cn

"context" 内容来自zvvq

"fmt" copyright zvvq

"go.opentelemetry.io/otel" 内容来自zvvq，别采集哟

"go.opentelemetry.io/otel/propagation" copyright zvvq

) zvvq.cn

func main() {

copyright zvvq

// 初始化 OpenTelemetry 追踪器 内容来自zvvq，别采集哟

otel.SetTracerProvider(otel.NewTracerProvider())

本文来自zvvq

// 创建一个新的 Context，其中包含分布式追踪数据

ctx, span := otel.Tracer("example").Start(context.Background(), "my-span")

内容来自samhan

// 在 span 上附加数据 内容来自zvvq

span.AddEvent("doing work") 内容来自samhan666

// 完成 span

span.End() 内容来自samhan666

// 从上下文中提取追踪数据并将其发送到监控系统

zvvq

traceID := propagation.TraceContextFromContext(ctx).TraceID()

zvvq

fmt.Println(traceID)

} copyright zvvq

import (

zvvq.cn

"fmt"

"io" zvvq好，好zvvq

"net/http" 内容来自samhan

"<a style=color:f60; text-decoration:underline; href="https://www.php.cn/zt/15841.html" target="_blank">git</a>hub.com/openzipkin/zipkin-go" copyright zvvq

"github.com/openzipkin/zipkin-go/model"

zvvq.cn

httpreporter "github.com/openzipkin/zipkin-go/reporter/http"

) 内容来自zvvq，别采集哟

func main() { zvvq.cn

// 创建一个新的 Zipkin 追踪器 内容来自zvvq

reporter := httpreporter.NewReporter("http://localhost:9411/api/v2/spans")

本文来自zvvq

endpoint, err := zipkin.NewEndpoint("my-service", "localhost:8080") 内容来自zvvq

if err != nil {

内容来自zvvq，别采集哟

panic(err)

zvvq

} 本文来自zvvq

tracer, err := zipkin.NewTracer(reporter, zipkin.WithLocalEndpoint(endpoint))

if err != nil {

panic(err) 本文来自zvvq

}

内容来自zvvq，别采集哟

// 创建一个新的 Trace 内容来自zvvq

trace := tracer.StartSpan("my-trace") copyright zvvq

// 在 Trace 上添加标签和记录时间 内容来自zvvq

trace.Tag("http.url", "http://example.com") 内容来自zvvq，别采集哟

trace.Annotate(model.Annotation{Value: "Got Request", Timestamp: time.Now()}) zvvq好，好zvvq

// 完成 Trace

trace.Finish() 本文来自zvvq

// 打印 Trace ID

fmt.Println(trace.ID) zvvq

} zvvq

// prometheus 包含与 Prometheus 集成的库 zvvq

import (

"net/http" copyright zvvq

"time"

内容来自zvvq

prom "github.com/prometheus/client_<a style=color:f60; text-decoration:underline; href="https://www.php.cn/zt/16009.html" target="_blank">golang</a>/prometheus"

otelcol "go.opentelemetry.io/otel/exporters/prometheus" zvvq.cn

) copyright zvvq

func main() {

zvvq.cn

// 创建一个新的 OTel 追踪器 本文来自zvvq

otel.SetTracerProvider(otel.NewTracerProvider()) 内容来自zvvq，别采集哟

// 创建一个新的 Prometheus 导出器

zvvq

exporter, err := otelcol.NewExporter(otelcol.WithHistogramBuckets([]float64{0.005, 0.01, 0.025, 0.05, 0.1, 0.25, 0.5, 1, 2.5, 5, 10})) zvvq.cn

if err != nil { 本文来自zvvq

panic(err)

内容来自samhan666

}

// 注册导出器

本文来自zvvq

otel.SetTracerProvider(

内容来自zvvq，别采集哟

otel.TracerProviderWithBoundExporter(

本文来自zvvq

otel.DefaultTracerProvider(),

exporter,

),

内容来自samhan

)

// 使用追踪器来追踪 HTTP 请求

http.HandleFunc("/", func(w http.ResponseWriter, r http.Request) { 本文来自zvvq

ctx, span := otel.Tracer("example").Start(r.Context(), "my-span") zvvq

defer span.End() 本文来自zvvq

// 模拟一些工作 内容来自samhan

time.Sleep(200 time.Millisecond)

copyright zvvq

w.Write([]byte("Hello, World!")) 本文来自zvvq

}) 内容来自samhan

// 启动 HTTP 服务器

内容来自samhan

http.ListenAndServe(":8080", nil)

copyright zvvq

}