Golang如何使用Prometheus监控指标-Golang-PHP中文网

Golang如何使用Prometheus监控指标

P粉602998670

发布： 2025-10-03 10:30:06

原创

286人浏览过

答案：Go应用集成Prometheus需引入client_golang库，定义Counter、Gauge等指标类型，通过中间件收集HTTP请求数据，暴露/metrics端点供Prometheus抓取，并在prometheus.yml中配置目标，实现监控与可视化。

golang如何使用prometheus监控指标

在Go应用中集成Prometheus监控，能帮助你实时掌握服务的运行状态，比如请求延迟、QPS、资源使用情况等。Golang对接Prometheus并不复杂，核心是使用官方推荐的客户端库 prometheus/client_golang 来暴露指标，并让Prometheus服务器定期抓取。

引入Prometheus客户端库

开始前，先安装必要的依赖：

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

这两个包分别用于定义指标和提供HTTP接口供Prometheus抓取。

定义并注册监控指标

Prometheus支持多种指标类型：Counter（计数器）、Gauge（当前值）、Histogram（分布统计）和Summary（分位数）。根据你的监控需求选择合适的类型。

立即学习“go语言免费学习笔记（深入）”；

例如，记录HTTP请求次数和响应耗时：

package main

import ( "net/http" "time"

"github.com/prometheus/client_golang/prometheus"
"github.com/prometheus/client_golang/prometheus/promhttp"

登录后复制

)

标小兔AI写标书

一款专业的标书AI代写平台，提供专业AI标书代写服务，安全、稳定、速度快，可满足各类招投标需求，标小兔，写标书，快如兔。

查看详情

// 定义指标 var ( httpRequestsTotal = prometheus.NewCounterVec( prometheus.CounterOpts{ Name: "http_requests_total", Help: "Total number of HTTP requests.", }, []string{"method", "endpoint", "status"}, )

httpRequestDuration = prometheus.NewHistogramVec(
    prometheus.HistogramOpts{
        Name:    "http_request_duration_seconds",
        Help:    "Histogram of request latencies.",
        Buckets: []float64{0.1, 0.3, 0.5, 1.0, 3.0},
    },
    []string{"method", "endpoint"},
)

登录后复制

)

func init() { // 注册指标 prometheus.MustRegister(httpRequestsTotal) prometheus.MustRegister(httpRequestDuration) }

在HTTP处理中收集数据

在实际处理请求的地方更新指标。比如写一个中间件来自动统计：

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

    // 执行原处理逻辑
    next.ServeHTTP(w, r)

    // 请求结束后记录指标
    endpoint := r.URL.Path
    status := http.StatusOK // 实际应从ResponseRecorder获取
    method := r.Method

    httpRequestsTotal.WithLabelValues(method, endpoint, "200").Inc()
    httpRequestDuration.WithLabelValues(method, endpoint).Observe(time.Since(start).Seconds())
}

登录后复制

}

func helloHandler(w http.ResponseWriter, r *http.Request) { w.Write([]byte("Hello, Prometheus!")) }

暴露/metrics端点

Prometheus通过抓取 /metrics 接口获取数据。使用 promhttp.Handler() 快速暴露指标：

func main() { http.HandleFunc("/hello", metricsMiddleware(helloHandler))

// 暴露Prometheus指标
http.Handle("/metrics", promhttp.Handler())

http.ListenAndServe(":8080", nil)

登录后复制

}

启动服务后，访问 http://localhost:8080/metrics 可看到类似以下内容：

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