当前位置:首页 > 文章列表 > Golang > Go教程 > Go runtime/metrics.Read 怎么复用 Sample 切片减少采集分配

Go runtime/metrics.Read 怎么复用 Sample 切片减少采集分配

来源:17golang原创 2026-10-12 16:29:49 0浏览 收藏

周期采集 Go 运行时指标时,真正容易产生重复开销的地方往往不是 metrics.Read 这一行,而是每轮都重新创建并填充 []metrics.Sample。正确的做法是先确定要采集的指标名称,把它们放进固定长度的切片,后续重复调用 metrics.Read 时复用同一组元素。

官方文档:https://pkg.go.dev/runtime/metrics#Read

复用的核心是“复用 Sample 容器,不复用正在被另一 goroutine 读取的结果”。同一采集器可以跨轮次使用一组切片;并发采集则要给每个任务独立的底层数组,必要时再深拷贝 histogram 等指针型结果。
  • 先准备指标名,再按固定长度创建 []metrics.Sample。
  • 每轮只调用 metrics.Read(samples),不要在循环里反复 make。
  • 读取结果前判断 Value.Kind(),未知名称对应 KindBad。

先把指标名称和 Sample 容器分开准备

metrics.Sample 由 Name 和 Value 组成。调用 Read 前,名称必须已经放入切片;调用后,运行时填充每个元素的 Value。因此可以把“准备容器”放到采集器初始化阶段,把“读取值”留在定时循环里。

指标名称、Sample 切片与 runtime metrics Read 的静态关系说明图
图1:Sample 容器边界说明图,展示指标名称、可复用切片和 Read 填充值之间的静态关系;这是说明图,不是运行截图。
package main

import (
	"fmt"
	"runtime/metrics"
)

type Collector struct {
	samples []metrics.Sample
}

func NewCollector(names []string) *Collector {
	// 初始化阶段只分配一次容器,并保存每个样本对应的指标名。
	samples := make([]metrics.Sample, len(names))
	for i, name := range names {
		samples[i].Name = name // Read 会按 Name 填充对应的 Value。
	}
	return &Collector{samples: samples}
}

func (c *Collector) Read() {
	// 每轮复用同一个底层数组,避免按采集周期重复 make。
	metrics.Read(c.samples)
	for _, sample := range c.samples {
		// 未支持的指标会得到 KindBad,不能直接调用 Uint64 或 Float64。
		if sample.Value.Kind() == metrics.KindBad {
			fmt.Printf("skip unsupported metric: %s\n", sample.Name)
			continue
		}
		fmt.Printf("%s: %v\n", sample.Name, sample.Value.Kind())
	}
}

这里的复用对象是切片的底层存储,而不是把上一次采集结果永久保存下来。每次 Read 都会覆盖对应的 Value;如果业务要把结果交给异步处理,应在交接前复制需要的数据。

用固定长度切片批量读取,按 Kind 取出值

如果指标集合是明确的,固定长度的 make 比在每一轮用 append 逐步扩容更直观。批量读取后,先看 Kind 再调用对应方法:KindUint64 使用 Uint64,KindFloat64 使用 Float64,直方图则使用 Float64Histogram。

type Snapshot struct {
	HeapObjects uint64
	Goroutines  uint64
	HeapGoal    uint64
}

func (c *Collector) Snapshot() (Snapshot, error) {
	// Read 会覆盖 c.samples 的 Value,因此本方法要在同一采集器上串行调用。
	metrics.Read(c.samples)
	var out Snapshot
	for i := range c.samples {
		sample := &c.samples[i]
		switch sample.Name {
		case "/gc/heap/objects:objects":
			if sample.Value.Kind() != metrics.KindUint64 {
				return Snapshot{}, fmt.Errorf("unexpected kind for %s", sample.Name) // 防止错误类型调用导致 panic。
			}
			out.HeapObjects = sample.Value.Uint64()
		case "/sched/goroutines:goroutines":
			if sample.Value.Kind() == metrics.KindUint64 {
				out.Goroutines = sample.Value.Uint64() // 只读取与指标约定一致的类型。
			}
		case "/gc/heap/goal:bytes":
			if sample.Value.Kind() == metrics.KindUint64 {
				out.HeapGoal = sample.Value.Uint64()
			}
		}
	}
	return out, nil
}

固定长度并不意味着指标名称永远不变。如果程序希望跟随不同 Go 版本的支持集合,应先根据 metrics.All() 选择需要的描述,再一次性重建 Sample 切片;不要在正在读取的切片上同时改名。

把复用封装在采集器里,隔离并发读取

官方文档允许多个 Read 并发执行,但各次调用的参数不能共享底层内存。换句话说,复用适合“同一个采集器的多轮串行调用”,不适合把一个全局 samples 切片交给多个 goroutine。

串行复用 Sample 切片与并发独立底层数组的关系说明图
图2:采集并发边界说明图,比较单采集器串行复用与多个独立 Sample 数组的关系;这是说明图,不是运行截图。
type Worker struct {
	collector *Collector
}

func (w *Worker) Collect() Snapshot {
	// 由调度器保证同一个 Worker 不会被并发调用,保护可复用的底层数组。
	snapshot, err := w.collector.Snapshot()
	if err != nil {
		return Snapshot{} // 采集失败时返回空快照,由上层决定是否告警。
	}
	return snapshot
}

func newWorkers(names []string, n int) []*Worker {
	workers := make([]*Worker, n)
	for i := range workers {
		// 每个 Worker 都有独立 Collector,避免 Read 参数共享底层内存。
		workers[i] = &Worker{collector: NewCollector(names)}
	}
	return workers
}

如果采集结果要异步发送,不能只把 metrics.Value 或 histogram 指针塞进队列后继续下一轮读取。需要保留的数值应先提取到自有结构体;histogram 的 Buckets 和 Counts 则按业务需要复制,避免后续复用影响已交出的数据。

什么时候应该重建切片

有三种情况不宜强行复用原切片:采集指标集合发生变化、并发调用无法保证独立底层数组、以及下游需要长期持有本轮结果。前两种情况应重建容器,最后一种情况应复制结果,而不是把可变的采集器内部状态暴露出去。

场景推荐做法原因
固定指标、串行定时采集复用同一组 Sample减少每轮容器分配
多个 goroutine 同时采集每个任务独立 Sample 底层数组避免数据竞争
指标列表更新停止旧采集器后重建切片名称与长度必须匹配
结果交给异步消费者复制需要的标量或 histogram 数据避免下一次 Read 覆盖结果

常见问题

复用 Sample 切片会让 Value 自动累加吗?

不会。每次 Read 是按当前运行时状态重新填充 Value;是否累加、求速率或保留历史,要由调用方另行保存上一份快照。

未知指标是否应该直接调用 Uint64?

不应该。名称不在 metrics.All() 中时,Value 会是 KindBad。先判断 Kind,再调用对应取值方法。

能不能把同一个 Sample 切片放进 sync.Pool?

可以把对象池作为更大的生命周期设计,但归还前必须确保没有读者继续使用它,并且每次取出后重新确认指标名称和长度。对于固定串行采集,直接让采集器持有一组切片通常更简单。

总结一下:把指标名和 Sample 切片在初始化阶段准备好,周期任务中重复调用 metrics.Read;用 Value.Kind() 守住类型边界;并发场景为每个采集器分配独立底层数组,需要跨轮次保存时复制结果。这样才能把切片复用带来的分配收益和数据安全同时保留下来。

版本声明
本文转载于:17golang原创 如有侵犯,请联系study_golang@163.com删除
Go os.Chmod 修改符号链接时实际影响哪个文件Go os.Chmod 修改符号链接时实际影响哪个文件
上一篇
Go os.Chmod 修改符号链接时实际影响哪个文件
Go runtime/metrics 怎么按指标描述选择正确的 Value 类型
下一篇
Go runtime/metrics 怎么按指标描述选择正确的 Value 类型
查看更多
最新文章
查看更多
课程推荐
  • 前端进阶之JavaScript设计模式
    前端进阶之JavaScript设计模式
    设计模式是开发人员在软件开发过程中面临一般问题时的解决方案,代表了最佳的实践。本课程的主打内容包括JS常见设计模式以及具体应用场景,打造一站式知识长龙服务,适合有JS基础的同学学习。
    543次学习
  • GO语言核心编程课程
    GO语言核心编程课程
    本课程采用真实案例,全面具体可落地,从理论到实践,一步一步将GO核心编程技术、编程思想、底层实现融会贯通,使学习者贴近时代脉搏,做IT互联网时代的弄潮儿。
    516次学习
  • 简单聊聊mysql8与网络通信
    简单聊聊mysql8与网络通信
    如有问题加微信:Le-studyg;在课程中,我们将首先介绍MySQL8的新特性,包括性能优化、安全增强、新数据类型等,帮助学生快速熟悉MySQL8的最新功能。接着,我们将深入解析MySQL的网络通信机制,包括协议、连接管理、数据传输等,让
    500次学习
  • JavaScript正则表达式基础与实战
    JavaScript正则表达式基础与实战
    在任何一门编程语言中,正则表达式,都是一项重要的知识,它提供了高效的字符串匹配与捕获机制,可以极大的简化程序设计。
    487次学习
  • 从零制作响应式网站—Grid布局
    从零制作响应式网站—Grid布局
    本系列教程将展示从零制作一个假想的网络科技公司官网,分为导航,轮播,关于我们,成功案例,服务流程,团队介绍,数据部分,公司动态,底部信息等内容区块。网站整体采用CSSGrid布局,支持响应式,有流畅过渡和展现动画。
    485次学习
查看更多
AI推荐
  • PubMedQA数据集详解:生物医学问答基准、功能与应用指南
    PubMedQA
    深入了解PubMedQA生物医学问答数据集,涵盖其核心功能、使用方法及在临床决策、药物研发等场景的应用,助力提升NLP模型性能。
    436次使用
  • H2O EvalGPT:开源LLM大模型评估与排行榜工具
    H2O EvalGPT
    H2O EvalGPT是H2O.ai推出的开源LLM评估平台,提供详细的大模型性能排行榜、行业特定基准测试及A/B测试功能,助您快速选择最适合项目的高性能大语言模型。
    509次使用
  • LMArena是什么?伯克利AI模型评估平台使用指南与功能解析
    LMArena
    LMArena是加州大学伯克利分校推出的AI模型匿名评测平台。通过盲测投票机制,用户可对比不同大模型回答并生成实时排行榜,助力开发者优化模型及用户选择最佳AI工具。
    526次使用
  • 斯坦福HELM:大语言模型Holistic Evaluation整体评估框架详解
    HELM
    深入了解斯坦福推出的HELM(Holistic Evaluation of Language Models)大模型评测体系。本文解析其核心功能、安装配置步骤及应用场景,涵盖准确性、公平性、鲁棒性等多维度指标,助力开发者全面优化语言模型性能。
    469次使用
  • MMBench详解:多模态大模型基准测试、功能特点与使用指南
    MMBench
    MMBench是由上海人工智能实验室等机构联合推出的多模态基准测试平台,提供细粒度能力评估、大规模数据集及VLMEvalKit工具。本文详细介绍其核心功能、安装使用方法及应用场景,助力开发者全面评估多模态模型性能。
    296次使用
微信登录更方便
  • 密码登录
  • 注册账号
登录即同意 用户协议 和 隐私政策
返回登录
  • 重置密码