首页 > Golang > Go教程

Golang服务监控：Prometheus指标收集教程

时间：2025-09-14 18:32:10 174浏览收藏

想要为你的 Golang 服务添加监控能力？本文将深入探讨如何利用 Prometheus 收集服务指标，实现高效的性能监控。首先，你需要引入 `prometheus/client_golang` 客户端库，该库提供了指标定义、注册以及 HTTP 处理的强大支持。接下来，我们将详细介绍如何定义并注册计数器、直方图等关键指标，并在 HTTP 处理过程中，通过中间件记录请求数量和耗时等信息。最后，我们将演示如何暴露 `/metrics` 端点，以便 Prometheus 能够抓取这些监控数据。通过本文，你将能够轻松地为你的 Golang 服务集成 Prometheus 指标收集，并利用 Grafana 实现可视化监控，从而更好地了解和优化你的服务性能。

首先引入prometheus/client_golang库，然后定义并注册计数器和直方图指标，接着通过中间件在HTTP处理中记录请求量和耗时，最后暴露/metrics端点供Prometheus抓取，实现监控数据采集。

Golang服务监控实现 Prometheus指标收集

要在Golang服务中实现Prometheus指标收集，核心是使用官方提供的客户端库 prometheus/client_golang，并暴露符合Prometheus格式的HTTP端点。下面介绍如何一步步集成监控指标并让Prometheus抓取。

引入Prometheus客户端库

安装官方Golang客户端：

go get github.com/prometheus/client_golang/prometheus go get github.com/prometheus/client_golang/prometheus/promhttp

这个库提供了指标定义、注册和HTTP处理的支持。

定义和注册指标

在服务中创建常用的指标类型，比如计数器、直方图、仪表盘等。以下是一个简单示例：

package main

import ( "net/http" "github.com/prometheus/client_golang/prometheus" "github.com/prometheus/client_golang/prometheus/promhttp" )

// 定义一个请求计数器 var httpRequestsTotal = prometheus.NewCounterVec( prometheus.CounterOpts{ Name: "http_requests_total", Help: "Total number of HTTP requests.", }, []string{"method", "endpoint", "status"}, )

// 定义一个请求耗时直方图 var httpRequestDuration = prometheus.NewHistogram( prometheus.HistogramOpts{ Name: "http_request_duration_seconds", Help: "HTTP request latency in seconds.", Buckets: []float64{0.1, 0.3, 0.5, 1.0, 3.0}, }, )

func init() { // 注册指标到默认的注册表 prometheus.MustRegister(httpRequestsTotal) prometheus.MustRegister(httpRequestDuration) }

在HTTP处理中记录指标

在实际的请求处理中更新指标。例如，使用中间件记录请求次数和耗时：

import "time"

func metricsMiddleware(next http.HandlerFunc) http.HandlerFunc { return func(w http.ResponseWriter, r *http.Request) { start := time.Now()

    // 包装 ResponseWriter 以捕获状态码
    rw := &responseWriter{ResponseWriter: w, statusCode: 200}
    next(rw, r)

    method := r.Method
    endpoint := r.URL.Path
    status := rw.statusCode

    httpRequestsTotal.WithLabelValues(method, endpoint, http.StatusText(status)).Inc()
    httpRequestDuration.Observe(time.Since(start).Seconds())
}

}

// 包装 ResponseWriter type responseWriter struct { http.ResponseWriter statusCode int }

func (rw *responseWriter) WriteHeader(code int) { rw.statusCode = code rw.ResponseWriter.WriteHeader(code) }

暴露/metrics端点

启动一个HTTP服务，暴露Prometheus可抓取的/metrics路径：

func main() { // 注册 metrics 接口 http.Handle("/metrics", promhttp.Handler())

// 示例业务接口
http.HandleFunc("/hello", metricsMiddleware(func(w http.ResponseWriter, r *http.Request) {
    w.Write([]byte("Hello, World!"))
}))

// 启动服务
http.ListenAndServe(":8080", nil)

}

启动后访问 http://localhost:8080/metrics 可看到类似以下输出：

http_requests_total{method="GET",endpoint="/hello",status="200"} 5 http_request_duration_seconds_bucket{le="0.1"} 3 http_request_duration_seconds_bucket{le="0.3"} 5 ...

Prometheus配置示例如下：

scrape_configs: - job_name: 'go-service' static_configs: - targets: ['localhost:8080']

基本上就这些。只要服务暴露了/metrics，Prometheus就能定期拉取数据，配合Grafana可实现可视化监控。

以上就是本文的全部内容了，是否有顺利帮助你解决问题？若是能给你带来学习上的帮助，请大家多多支持golang学习网！更多关于Golang的相关知识，也可关注golang学习网公众号。

golang prometheus 监控指标 client_golang /metrics端点