监控和可观测是维护分布式 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 中可视化请求的跟踪。
