当前位置：首页 > 文章列表 > Golang > Go教程 > Golang自定义监控指标教程详解

Golang自定义监控指标教程详解

2026-01-10 13:56:33 0浏览收藏

编程并不是一个机械性的工作，而是需要有思考，有创新的工作，语法是固定的，但解决问题的思路则是依靠人的思维，这就需要我们坚持学习和更新自己的知识。今天golang学习网就整理分享《Golang自定义指标监控教程》，文章讲解的知识点主要包括，如果你对Golang方面的知识点感兴趣，就不要错过golang学习网，在这可以对大家的知识积累有所帮助，助力开发能力的提升。

答案是使用Prometheus Go客户端库定义并注册自定义指标，通过HTTP中间件记录请求数据，暴露/metrics端点供Prometheus抓取。具体步骤为：1. 引入prometheus/client_golang依赖，定义计数器http_requests_total和直方图request_duration_seconds；2. 在init函数中注册指标；3. 编写中间件更新指标，利用包装的ResponseWriter捕获状态码；4. 使用promhttp.Handler()暴露/metrics路径；5. 配置prometheus.yml的scrape_configs添加目标地址，即可在UI查询指标。

Golang如何使用Prometheus抓取自定义指标

在Go应用中集成Prometheus来抓取自定义指标，核心是使用官方客户端库 prometheus/client_golang。你需要定义指标、注册到处理器，并暴露一个HTTP端点供Prometheus抓取。

1. 引入依赖并初始化指标

先安装Prometheus Go客户端：

go get github.com/prometheus/client_golang/prometheusgo get 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"}, )

requestDuration = 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, 2.0},
    },
    []string{"endpoint"},
)

)

在程序启动时注册这些指标：

func init() { prometheus.MustRegister(httpRequestsTotal) prometheus.MustRegister(requestDuration) }

2. 在代码中更新指标

在处理请求的地方记录数据。例如，在HTTP中间件中：

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.ServeHTTP(rw, r)

    duration := time.Since(start).Seconds()
    endpoint := r.URL.Path

    httpRequestsTotal.WithLabelValues(r.Method, endpoint, fmt.Sprintf("%d", rw.statusCode)).Inc()
    requestDuration.WithLabelValues(endpoint).Observe(duration)
}

}

确保实现自定义的 responseWriter 来获取状态码：

type responseWriter struct { http.ResponseWriter statusCode int }

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

3. 暴露/metrics端点

使用 promhttp 处理器暴露指标：

func main() { http.Handle("/metrics", promhttp.Handler())

// 示例接口
http.HandleFunc("/api/users", metricsMiddleware(func(w http.ResponseWriter, r *http.Request) {
    fmt.Fprintln(w, "user list")
}))

log.Println("Server starting on :8080")
log.Fatal(http.ListenAndServe(":8080", nil))

}

Prometheus就可以通过 http://your-service:8080/metrics 抓取数据了。