Zipkin과 Jaeger를 사용하여 Beego에서 분산 추적 구현

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 중국어 웹사이트의 기타 관련 기사를 참조하세요!