Go語(yǔ)言metrics應(yīng)用監(jiān)控指標(biāo)基本使用說(shuō)明

更新時(shí)間：2022年02月22日 10:27:29 作者：tianlongtc

這篇文章主要為大家介紹了Go語(yǔ)言metrics應(yīng)用監(jiān)控指標(biāo)的基本使用說(shuō)明，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步

metrics 是什么？

當(dāng)我們需要為某個(gè)系統(tǒng)某個(gè)服務(wù)做監(jiān)控、做統(tǒng)計(jì)，就需要用到Metrics

五種 Metrics 類型

Gauges ：最簡(jiǎn)單的度量指標(biāo)，只有一個(gè)簡(jiǎn)單的返回值，或者叫瞬時(shí)狀態(tài)
Counters：Counter 就是計(jì)數(shù)器，Counter 只是用 Gauge 封裝了 AtomicLong
Meters：Meter度量一系列事件發(fā)生的速率(rate)，例如TPS。Meters會(huì)統(tǒng)計(jì)最近1分鐘，5分鐘，15分鐘，還有全部時(shí)間的速率。
Histograms：Histogram統(tǒng)計(jì)數(shù)據(jù)的分布情況。比如最小值，最大值，中間值，還有中位數(shù)，75百分位, 90百分位, 95百分位, 98百分位, 99百分位, 和 99.9百分位的值(percentiles)。
Timer其實(shí)是 Histogram 和 Meter 的結(jié)合， histogram 某部分代碼/調(diào)用的耗時(shí)， meter統(tǒng)計(jì)TPS。

接下來(lái)我們寫(xiě)代碼實(shí)際使用一下這些功能就從最簡(jiǎn)單的Gauges 開(kāi)始吧

package main
import (
	"github.com/rcrowley/go-metrics"
	"time"
	"os"
	"log"
)
func main(){
	g := metrics.NewGauge()
	metrics.Register("bar", g)
	g.Update(1)
	go metrics.Log(metrics.DefaultRegistry,
		1 * time.Second,
		log.New(os.Stdout, "metrics: ", log.Lmicroseconds))
	var j int64
	j = 1
	for true {
		time.Sleep(time.Second * 1)
		g.Update(j)
		j++
	}
}

此時(shí)我們運(yùn)行程序可以看到如下輸出

在程序中我們?cè)趍etrics.Log 中設(shè)置了 metrics 的輸出頻率為1s 同時(shí)指定了數(shù)據(jù)輸出的目的為 log.New出來(lái)的Logger 設(shè)置為打印在標(biāo)準(zhǔn)輸出

接下counters 與gauges 類似

只不過(guò)在操作上 gauges 是 update 而 counter 是 inc 做加法增加參數(shù)市值 dec 做減法

	g := metrics.NewGauge()
	metrics.Register("bar", g)
	g.Update(1)
	c := metrics.NewCounter()
	metrics.Register("foo", c)
	c.Inc(45)
	c.Dec(3)

以上代碼可以看到區(qū)別在New 的時(shí)候默認(rèn)的時(shí)候數(shù)值都為0

package main
import (
	"github.com/rcrowley/go-metrics"
	"time"
	"os"
	"log"
)
func main(){
	s := metrics.NewExpDecaySample(1024, 0.015) // or metrics.NewUniformSample(1028)
	h := metrics.NewHistogram(s)
	metrics.Register("baz", h)
	h.Update(1)
	go metrics.Log(metrics.DefaultRegistry,
		1 * time.Second,
		log.New(os.Stdout, "metrics: ", log.Lmicroseconds))
	var j int64
	j = 1
	for true {
		time.Sleep(time.Second * 1)
		j++
		h.Update(j)
	}
}

metrics.NewExpDecaySample這函數(shù)的兩個(gè)參數(shù)的含義：第一是內(nèi)部存儲(chǔ)數(shù)據(jù)的個(gè)數(shù)

第二個(gè)是指數(shù)后乘以的數(shù)值具體位置

下面來(lái)測(cè)試一下meters

package main
import (
	"time"
	"os"
	"github.com/rcrowley/go-metrics"
	"log"
)
func main(){
	m := metrics.NewMeter()
	metrics.Register("quux", m)
	m.Mark(1)
	go metrics.Log(metrics.DefaultRegistry,
		1 * time.Second,
		log.New(os.Stdout, "metrics: ", log.Lmicroseconds))
	var j int64
	j = 1
	for true {
		time.Sleep(time.Second * 1)
		j++
		m.Mark(j)
	}
}

測(cè)試結(jié)果

輸出到influxdb

influxdb的安裝和基本使用這里不做介紹

使用下面工作

vrischmann/go-metrics-influxdb

package main
import (
	"github.com/rcrowley/go-metrics"
	"time"
	"github.com/vrischmann/go-metrics-influxdb"
)
func main(){
	m := metrics.NewMeter()
	metrics.Register("quux", m)
	m.Mark(1)
	go influxdb.InfluxDB(metrics.DefaultRegistry,
		time.Second * 5,
		"http://192.168.150.74:8086",
		"mydb",
		"",
		"")
	var j int64
	j = 1
	for true {
		time.Sleep(time.Second*1)
		m.Mark(j)
		j += 1
	}
}

看以上的代碼其他地方都不用改動(dòng) 只要改下輸出的地方就可以了

在influx中使用設(shè)置的database 表名則自用生成使用是 metrics中register 設(shè)置的名字加上類型在這里例子中表名為quux.meter

就可以在influxdb 里面看到如下的一些數(shù)據(jù)：