如何使用golang收集系统指标
发表于:2024-10-12 作者:千家信息网编辑
千家信息网最后更新 2024年10月12日,这篇文章主要讲解了"如何使用golang收集系统指标",文中的讲解内容简单清晰,易于学习与理解,下面请大家跟着小编的思路慢慢深入,一起来研究和学习"如何使用golang收集系统指标"吧!common.
千家信息网最后更新 2024年10月12日如何使用golang收集系统指标
这篇文章主要讲解了"如何使用golang收集系统指标",文中的讲解内容简单清晰,易于学习与理解,下面请大家跟着小编的思路慢慢深入,一起来研究和学习"如何使用golang收集系统指标"吧!
common.go
// copy code from github.com/shirou/gopsutilpackage sysimport ( "bufio" "os" "strings")// ReadLines reads contents from file and splits them by new line.// A convenience wrapper to ReadLinesOffsetN(filename, 0, -1).func readLines(filename string) ([]string, error) { return readLinesOffsetN(filename, 0, -1)}// ReadLines reads contents from file and splits them by new line.// The offset tells at which line number to start.// The count determines the number of lines to read (starting from offset):// n >= 0: at most n lines// n < 0: whole filefunc readLinesOffsetN(filename string, offset uint, n int) ([]string, error) { f, err := os.Open(filename) if err != nil { return []string{""}, err } defer f.Close() var ret []string r := bufio.NewReader(f) for i := 0; i < n+int(offset) || n < 0; i++ { line, err := r.ReadString('\n') if err != nil { break } if i < int(offset) { continue } ret = append(ret, strings.Trim(line, "\n")) } return ret, nil}
sys.go
// copy code from github.com/shirou/gopsutil// almost the same, but change a lot, especially the returned structpackage sysimport ( "errors" "io/ioutil" "strconv" "strings")type SysStat struct { // /proc/loadavg Load1 float64 Load5 float64 Load15 float64 // /proc/meminfo Total uint64 Available uint64 Used uint64 UsedPercent float64 Free uint64 Active uint64 Inactive uint64 Buffers uint64 Cached uint64 Wired uint64 Shared uint64 // /proc/net/dev // sum of all interfaces Name string BytesSent uint64 BytesRecv uint64 PacketsSent uint64 PacketsRecv uint64 // /proc/stat CPU string User float64 System float64 Idle float64 Nice float64 Iowait float64 Irq float64 Softirq float64 Steal float64 Guest float64 GuestNice float64 Stolen float64}func GetSysStat() *SysStat { stat := new(SysStat) stat.cPUTimes() stat.netIOCounters() stat.virtualMemory() stat.loadAvg() return stat}func (stat *SysStat) cPUTimes() error { filename := "/proc/stat" var lines = []string{} lines, _ = readLinesOffsetN(filename, 0, 1) err := stat.parseStatLine(lines[0]) if err != nil { return err } return nil}func (stat *SysStat) parseStatLine(line string) error { fields := strings.Fields(line) if strings.HasPrefix(fields[0], "cpu") == false { return errors.New("not contain cpu") } cpu := fields[0] if cpu == "cpu" { cpu = "cpu-total" } user, err := strconv.ParseFloat(fields[1], 64) if err != nil { return err } nice, err := strconv.ParseFloat(fields[2], 64) if err != nil { return err } system, err := strconv.ParseFloat(fields[3], 64) if err != nil { return err } idle, err := strconv.ParseFloat(fields[4], 64) if err != nil { return err } iowait, err := strconv.ParseFloat(fields[5], 64) if err != nil { return err } irq, err := strconv.ParseFloat(fields[6], 64) if err != nil { return err } softirq, err := strconv.ParseFloat(fields[7], 64) if err != nil { return err } stolen, err := strconv.ParseFloat(fields[8], 64) if err != nil { return err } cpu_tick := float64(100) // TODO: how to get _SC_CLK_TCK ? stat.CPU = cpu stat.User = float64(user) / cpu_tick stat.Nice = float64(nice) / cpu_tick stat.System = float64(system) / cpu_tick stat.Idle = float64(idle) / cpu_tick stat.Iowait = float64(iowait) / cpu_tick stat.Irq = float64(irq) / cpu_tick stat.Softirq = float64(softirq) / cpu_tick stat.Stolen = float64(stolen) / cpu_tick if len(fields) > 9 { // Linux >= 2.6.11 steal, err := strconv.ParseFloat(fields[9], 64) if err != nil { return err } stat.Steal = float64(steal) } if len(fields) > 10 { // Linux >= 2.6.24 guest, err := strconv.ParseFloat(fields[10], 64) if err != nil { return err } stat.Guest = float64(guest) } if len(fields) > 11 { // Linux >= 3.2.0 guestNice, err := strconv.ParseFloat(fields[11], 64) if err != nil { return err } stat.GuestNice = float64(guestNice) } return nil}type netIOCountersStat struct { Name string BytesSent uint64 BytesRecv uint64 PacketsSent uint64 PacketsRecv uint64}func (stat *SysStat) netIOCounters() error { filename := "/proc/net/dev" lines, err := readLines(filename) if err != nil { return err } statlen := len(lines) - 1 all := make([]netIOCountersStat, 0, statlen) for _, line := range lines[2:] { parts := strings.SplitN(line, ":", 2) if len(parts) != 2 { continue } interfaceName := strings.TrimSpace(parts[0]) if interfaceName == "" { continue } fields := strings.Fields(strings.TrimSpace(parts[1])) bytesRecv, err := strconv.ParseUint(fields[0], 10, 64) if err != nil { return err } packetsRecv, err := strconv.ParseUint(fields[1], 10, 64) if err != nil { return err } bytesSent, err := strconv.ParseUint(fields[8], 10, 64) if err != nil { return err } packetsSent, err := strconv.ParseUint(fields[9], 10, 64) if err != nil { return err } nic := netIOCountersStat{ Name: interfaceName, BytesRecv: bytesRecv, PacketsRecv: packetsRecv, BytesSent: bytesSent, PacketsSent: packetsSent} all = append(all, nic) } return stat.getNetIOCountersAll(all)}func (stat *SysStat) getNetIOCountersAll(n []netIOCountersStat) error { stat.Name = "all-interfaces" for _, nic := range n { stat.BytesRecv += nic.BytesRecv stat.PacketsRecv += nic.PacketsRecv stat.BytesSent += nic.BytesSent stat.PacketsSent += nic.PacketsSent } return nil}func (stat *SysStat) virtualMemory() error { filename := "/proc/meminfo" lines, _ := readLines(filename) for _, line := range lines { fields := strings.Split(line, ":") if len(fields) != 2 { continue } key := strings.TrimSpace(fields[0]) value := strings.TrimSpace(fields[1]) value = strings.Replace(value, " kB", "", -1) t, err := strconv.ParseUint(value, 10, 64) if err != nil { return err } switch key { case "MemTotal": stat.Total = t * 1000 case "MemFree": stat.Free = t * 1000 case "Buffers": stat.Buffers = t * 1000 case "Cached": stat.Cached = t * 1000 case "Active": stat.Active = t * 1000 case "Inactive": stat.Inactive = t * 1000 } } stat.Available = stat.Free + stat.Buffers + stat.Cached stat.Used = stat.Total - stat.Free stat.UsedPercent = float64(stat.Total-stat.Available) / float64(stat.Total) * 100.0 return nil}func (stat *SysStat) loadAvg() error { filename := "/proc/loadavg" line, err := ioutil.ReadFile(filename) if err != nil { return err } values := strings.Fields(string(line)) load1, err := strconv.ParseFloat(values[0], 64) if err != nil { return err } load5, err := strconv.ParseFloat(values[1], 64) if err != nil { return err } load15, err := strconv.ParseFloat(values[2], 64) if err != nil { return err } stat.Load1 = load1 stat.Load5 = load5 stat.Load15 = load15 return nil}
感谢各位的阅读,以上就是"如何使用golang收集系统指标"的内容了,经过本文的学习后,相信大家对如何使用golang收集系统指标这一问题有了更深刻的体会,具体使用情况还需要大家实践验证。这里是,小编将为大家推送更多相关知识点的文章,欢迎关注!
指标
系统
学习
内容
就是
思路
情况
文章
更多
知识
知识点
篇文章
跟着
问题
实践
推送
研究
验证
数据库的安全要保护哪些东西
数据库安全各自的含义是什么
生产安全数据库录入
数据库的安全性及管理
数据库安全策略包含哪些
海淀数据库安全审计系统
建立农村房屋安全信息数据库
易用的数据库客户端支持安全管理
连接数据库失败ssl安全错误
数据库的锁怎样保障安全
工控网络安全态势感知特点
杭州余杭区软件开发
网络安全工作周小节
加强网络安全保卫
手抄报网络安全简单又漂亮
网络安全人员培训考核标准
电网 软件开发
国内七元一月的云服务器
现成的数据库下载
系统软件开发哪家正规
高性能虚拟化服务器
男32再学软件开发行吗
世界最牛的游戏软件开发公司
csi网络安全
严禁软件开发的分包转包
关于维护网络安全的重要论述
绝地求生从哪里看是哪个服务器
er图数据库关系图箭头
网络技术虚拟示范技术
戴尔电脑怎么退出服务器
如何找到某个软件的数据库
云南创新软件开发咨询报价
hana抽数支持的数据库
云非编的服务器在哪
数据库装哪个版本的编译器
数据库大作业实验心得体会
咋自定义服务器ip
lfw人脸数据库 排名
河南erp软件开发哪家好
机房服务器的维护工资