Zipkin 및 Jaeger를 사용하여 Beego에서 분산 추적 구현
마이크로서비스가 널리 보급됨에 따라 분산 시스템 개발이 점점 더 보편화되었습니다. 그러나 분산 시스템은 다양한 서비스 간의 요청 흐름을 추적하는 방법, 서비스 성능을 분석하고 최적화하는 방법 등과 같은 새로운 과제도 가져옵니다. 이러한 측면에서 분산 추적 솔루션은 점점 더 중요한 구성 요소가 되었습니다. 이 기사에서는 Zipkin과 Jaeger를 사용하여 Beego에서 분산 추적을 구현하는 방법을 소개합니다.
여러 서비스에 걸친 요청 추적은 분산 추적의 주요 목표입니다. 중앙 집중식 로그 스트림이나 지표 스트림은 서비스 간 상관 관계를 제공할 수 없기 때문에 이 문제를 해결할 수 없습니다. 요청에는 여러 서비스가 함께 작동해야 할 수 있으며 이러한 서비스는 다른 서비스의 응답 시간과 동작을 인식해야 합니다. 전통적인 접근 방식은 다양한 지표를 기록한 다음 임계값을 완화하여 요청 수신 시 차단을 방지하는 것입니다. 그러나 이 접근 방식은 결함 및 성능 문제와 같은 문제를 숨길 수 있습니다. 분산 추적은 서비스 간 요청 추적을 위한 솔루션입니다. 이 접근 방식에서는 요청이 서비스 간에 흐름에 따라 각 서비스가 전체 요청을 추적하는 일련의 ID를 생성합니다.
Beego에서 분산 추적을 구현하는 방법을 살펴보겠습니다.
Zipkin과 Jaeger는 현재 가장 인기 있는 분산 추적 솔루션입니다. 두 도구 모두 OpenTracing API를 지원하므로 개발자는 일관된 방식으로 서비스 전반에 걸쳐 요청을 기록하고 추적할 수 있습니다.
먼저 Zipkin 또는 Jaeger를 설치 및 시작한 다음 Beego 애플리케이션에서 분산 추적을 구성해야 합니다. 이번 글에서는 Zipkin을 사용하겠습니다.
Zipkin 설치:
curl -sSL https://zipkin.io/quickstart.sh | bash -s java -jar zipkin.jar
Zipkin이 실행되면 http://localhost:9411을 통해 웹 UI에 액세스할 수 있습니다.
다음으로 Beego에 OpenTracing API에 대한 지원을 추가해야 합니다. opentracing-go 패키지를 사용하고 그것이 제공하는 API를 사용하여 서비스 간 요청 및 기타 이벤트를 기록할 수 있습니다. 추적 코드의 예는 다음과 같습니다.
import ( "github.com/opentracing/opentracing-go" ) func main() { // Initialize the tracer tracer, closer := initTracer() defer closer.Close() // Start a new span span := tracer.StartSpan("example-span") // Record some events span.SetTag("example-tag", "example-value") span.LogKV("example-key", "example-value") // Finish the span span.Finish() } func initTracer() (opentracing.Tracer, io.Closer) { // Initialize the tracer tracer, closer := zipkin.NewTracer( zipkin.NewReporter(httpTransport.NewReporter("http://localhost:9411/api/v2/spans")), zipkin.WithLocalEndpoint(zipkin.NewEndpoint("example-service", "localhost:80")), zipkin.WithTraceID128Bit(true), ) // Set the tracer as the global tracer opentracing.SetGlobalTracer(tracer) return tracer, closer }
위의 예에서는 먼저 Zipkin 추적기를 초기화한 다음 이를 사용하여 일부 이벤트를 기록합니다. 태그와 키-값 쌍을 추가하고span.Finish()를 호출하여 범위를 종료할 수 있습니다.
이제 Beego 애플리케이션에 분산 추적을 추가해 보겠습니다.
먼저 opentracing-go 및 zipkin-go-opentracing 종속성을 추가해 보겠습니다. go mod를 사용하거나 패키지를 수동으로 설치할 수 있습니다.
go get github.com/opentracing/opentracing-go go get github.com/openzipkin/zipkin-go-opentracing
그런 다음 Beego 애플리케이션에서 Zipkin 추적기와 Beego 추적기 미들웨어를 초기화해야 합니다. 다음은 Beego 추적기 미들웨어의 샘플 코드입니다.
import ( "net/http" "github.com/astaxie/beego" opentracing "github.com/opentracing/opentracing-go" "github.com/openzipkin/zipkin-go-opentracing" ) func TraceMiddleware() func(http.ResponseWriter, *http.Request, http.HandlerFunc) { return func(w http.ResponseWriter, r *http.Request, next http.HandlerFunc) { // Initialize the tracer tracer, closer := initTracer() defer closer.Close() // Extract the span context from the HTTP headers spanCtx, err := tracer.Extract(opentracing.HTTPHeaders, opentracing.HTTPHeadersCarrier(r.Header)) if err != nil && err != opentracing.ErrSpanContextNotFound { beego.Error("failed to extract span context:", err) } // Start a new span span := tracer.StartSpan(r.URL.Path, ext.RPCServerOption(spanCtx)) // Set some tags span.SetTag("http.method", r.Method) span.SetTag("http.url", r.URL.String()) // Inject the span context into the HTTP headers carrier := opentracing.HTTPHeadersCarrier(r.Header) if err := tracer.Inject(span.Context(), opentracing.HTTPHeaders, carrier); err != nil { beego.Error("failed to inject span context:", err) } // Set the span as a variable in the request context r = r.WithContext(opentracing.ContextWithSpan(r.Context(), span)) // Call the next middleware/handler next(w, r) // Finish the span span.Finish() } } func initTracer() (opentracing.Tracer, io.Closer) { // Initialize the Zipkin tracer report := zipkinhttp.NewReporter("http://localhost:9411/api/v2/spans") defer report.Close() endpoint, err := zipkin.NewEndpoint("example-service", "localhost:80") if err != nil { beego.Error("failed to create Zipkin endpoint:", err) } nativeTracer, err := zipkin.NewTracer( report, zipkin.WithLocalEndpoint(endpoint), zipkin.WithTraceID128Bit(true)) if err != nil { beego.Error("failed to create Zipkin tracer:", err) } // Initialize the OpenTracing API tracer tracer := zipkinopentracing.Wrap(nativeTracer) // Set the tracer as the global tracer opentracing.SetGlobalTracer(tracer) return tracer, report }
위의 샘플 코드에서는 TraceMiddleware라는 미들웨어를 정의합니다. 이 미들웨어는 HTTP 헤더(있는 경우)에서 기존 추적 컨텍스트를 추출하고 이를 사용하여 요청에 대한 새 추적기를 생성합니다. 또한 다른 모든 미들웨어와 핸들러가 액세스할 수 있도록 요청 컨텍스트에서 범위를 설정했습니다. 마지막으로 핸들러 실행이 종료된 후 Zipkin이 요청된 모든 서비스에 대한 상호 종속성 추적을 기록할 수 있도록 범위에서 Finish() 메서드를 호출합니다.
또한 이 미들웨어를 Beego 라우터에 연결해야 합니다. 라우터 초기화 코드에서 다음 코드를 사용하여 이 작업을 수행할 수 있습니다.
beego.InsertFilter("*", beego.BeforeRouter, TraceMiddleware())
이제 Beego 애플리케이션을 실행하고 http://localhost:9411을 방문하여 Zipkin UI를 열고 추적 데이터를 확인하세요.
Beego 애플리케이션에서 분산 추적을 구현하는 것은 복잡해 보일 수 있지만 opentracing-go 및 zipkin-go-opentracing 라이브러리를 사용하면 이 기능을 쉽게 추가할 수 있습니다. 이는 서비스의 수와 복잡성이 지속적으로 증가함에 따라 점점 더 중요해지고 있으며 이를 통해 서비스가 어떻게 함께 작동하는지 이해하고 요청 처리 프로세스 전반에 걸쳐 서비스가 제대로 작동하는지 확인할 수 있습니다.
위 내용은 Zipkin과 Jaeger를 사용하여 Beego에서 분산 추적 구현의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!