Golang如何使用Prometheus监控应用

P粉602998670

发布： 2025-10-15 14:20:02

原创

534人浏览过

Go应用通过prometheus/client_golang库集成Prometheus监控，首先引入包并定义Counter、Gauge、Histogram指标，如请求总数和响应延迟；接着在init函数中注册指标，使用中间件记录HTTP请求的method和endpoint维度数据；然后通过http.Handle("/metrics", promhttp.Handler())暴露指标接口；最后在Prometheus配置中添加目标地址，实现定时抓取，结合Grafana可完成可视化监控。

golang如何使用prometheus监控应用

Prometheus 是云原生生态中最流行的监控系统之一，Golang 应用可以很方便地集成 Prometheus 来暴露指标数据。实现方式主要是通过 prometheus/client_golang 官方库，在应用中定义并暴露 HTTP 接口供 Prometheus 抓取。

引入 Prometheus 客户端库

在 Go 项目中使用 Prometheus，第一步是引入官方客户端库：

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

这两个包分别用于定义指标和提供 HTTP 处理器来暴露指标。

定义并注册监控指标

你可以根据需要创建计数器（Counter）、仪表（Gauge）、直方图（Histogram）等类型的指标。例如，统计请求次数和响应耗时：

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

Counter：只增不减，适合累计值，如请求数。
Gauge：可增可减，适合当前状态，如内存使用量。
Histogram：记录分布，如请求延迟。

示例代码：

package main

import ( "net/http" "time"

"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"}, )

httpRequestDuration = prometheus.NewHistogramVec(
    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},
    },
    []string{"method", "endpoint"},
)

登录后复制

)

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

在 HTTP 路由中记录指标

使用中间件的方式，在每个请求前后记录指标。以下是一个简单的日志+监控中间件：

Kits AI

Kits.ai 是一个为音乐家提供一站式AI音乐创作解决方案的网站，提供AI语音生成和免费AI语音训练

413

查看详情

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

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

    // 请求结束后记录指标
    httpRequestsTotal.WithLabelValues(r.Method, r.URL.Path).Inc()
    httpRequestDuration.WithLabelValues(r.Method, r.URL.Path).Observe(time.Since(start).Seconds())
}

登录后复制

}

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

将 handler 包装进中间件：

http.HandleFunc("/hello", monitor(helloHandler))