分布式部署 Go 框架的监控和可观测性- 技术经验 -卓越飞翔博客

监控和可观测是维护分布式 go 框架稳定性的关键。安装 prometheus，用于收集和存储度量。安装 grafana，用于可视化 prometheus 度量。安装 jaeger，用于追踪请求。集成 prometheus 和 jaeger 客户端库，以收集度量和追踪数据。配置 grafana 仪表板和告警，以监视度量并发出警报。集成 zipkin，以可视化追踪数据。

分布式部署 Go 框架的监控和可观测性

监控和可观测对于维护分布式系统的稳定性和可靠性至关重要。对于 Go 框架，可以使用各种工具实现监控和可观测功能。

本教程将重点介绍使用 Prometheus、Grafana 和 Jaeger 来实现 Go 框架的监控和可观测性。

安装和配置 Prometheus

Prometheus 是一个开源监控系统，可以收集度量并存储它们以进行分析。要安装 Prometheus，请运行以下命令：

curl https://prometheus.io/download | tar xzvf -
cd prometheus-*
./prometheus --config.file=prometheus.yml

安装和配置 Grafana

Grafana 是一个可视化平台，用于创建仪表板和图表以显示 Prometheus 收集的度量。要安装 Grafana，请运行以下命令：

curl https://dl.grafana.com/oss/release/grafana-8.4.3.linux-amd64.tar.gz | tar xzvf -
cd grafana-*
./bin/grafana-server

安装和配置 Jaeger

Jaeger 是一个开源分布式跟踪系统，使您可以可视化和分析请求的端到端路径。要安装 Jaeger，请运行以下命令：

curl -sL https://bit.ly/jaeger-install | sh
jaeger-agent --reporter.grpc.host-port=localhost:14250

集成 Prometheus 和 Jaeger 客户端库

在 Go 框架中，需要集成 Prometheus 和 Jaeger 客户端库以收集度量和跟踪数据。以下是采用 Prometheus 客户端库的示例代码：

import (
    "net/http"

    "github.com/prometheus/client_golang/prometheus"
    "github.com/prometheus/client_golang/prometheus/promauto"
)

var (
    requestCounter = promauto.NewCounter(prometheus.CounterOpts{
        Name: "http_requests_total",
        Help: "The total number of HTTP requests",
    })
)

func handleRequest(w http.ResponseWriter, r *http.Request) {
    requestCounter.Inc()
    // 处理请求的业务逻辑
}

以下是采用 Jaeger 客户端库的示例代码：

import (
    "context"
    "net/http"
    "time"

    "github.com/jaegertracing/jaeger-client-go"
    "github.com/jaegertracing/jaeger-client-go/config"
)

func tracingMiddleware(next http.Handler) http.Handler {
    return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
        tracer, closer := jaeger.NewTracer(
            "my-service",
            config.Configuration{
                ServiceName: "my-service",
                Sampler:     &config.SamplerConfig{Type: jaeger.SamplerTypeConst, Param: 1},
            },
        )
        defer closer.Close()

        ctx := context.Background()
        span := tracer.StartSpan(ctx, "handle-request")
        defer span.Finish()

        // 使用 span 跟踪请求的业务逻辑
        next.ServeHTTP(w, r)
    })
}

配置 Grafana 仪表板和告警

在 Grafana 中，您可以创建仪表板以可视化 Prometheus 收集的度量。您还可以配置告警规则，在某些阈值或条件下发出警报。

集成 Zipkin 可视化跟踪

如果您想可视化跟踪数据，可以使用 Zipkin 等工具。要为 Jaeger 配置 Zipkin，请使用以下的环境变量：

export JAEGER_AGENT_ZIPKIN_ENABLED=true
export JAEGER_AGENT_ZIPKIN_HTTP_ENDPOINT=http://localhost:9411/api/v2/spans

实战案例

考虑一个简单的 Go web 应用程序，它使用 Prometheus 和 Jaeger 进行监控和可观测。

以下是此应用程序的主函数：

func main() {
    // 初始化 Prometheus 客户端库
    prometheus.MustRegister(requestCounter)

    // 初始化 Jaeger 客户端库
    tracer, closer := jaeger.NewTracer(
        "my-service",
        config.Configuration{
            ServiceName: "my-service",
            Sampler:     &config.SamplerConfig{Type: jaeger.SamplerTypeConst, Param: 1},
        },
    )
    defer closer.Close()

    // 初始化路由器
    router := http.NewServeMux()
    router.Handle("/hello", tracingMiddleware(http.HandlerFunc(handleRequest)))

    // 运行服务器
    http.ListenAndServe(":8080", router)
}

通过访问 /hello 端点，您可以发送请求并触发度量和跟踪数据的收集。您可以在 Grafana 中创建仪表板和告警来监视请求计数，并且可以在 Zipkin 中可视化请求的跟踪。