前提
spring-actuator
做度量统计收集,使用Prometheus(普罗米修斯)进行数据收集,Grafana(增强ui)进行数据展示,用于监控生成环境机器的性能指标和业务数据指标。一般,我们叫这样的操作为”埋点”。SpringBoot中的依赖spring-actuator
中集成的度量统计API使用的框架是Micrometer,官网是Micrometer.io。在实践中发现了业务开发者滥用了Micrometer的度量类型Counter
,导致无论什么情况下都只使用计数统计的功能。这篇文章就是基于Micrometer分析其他的度量类型API的作用和适用场景。
Micrometer提供的度量类库
Meter
是指一组用于收集应用中的度量数据的接口,Meter单词可以翻译为”米”或者”千分尺”,但是显然听起来都不是很合理,因此下文直接叫Meter,理解它为度量接口即可。Meter
是由MeterRegistry
创建和保存的,可以理解MeterRegistry
是Meter
的工厂和缓存中心,一般而言每个JVM应用在使用Micrometer的时候必须创建一个MeterRegistry
的具体实现。Micrometer中,Meter
的具体类型包括:Timer
,Counter
,Gauge
,DistributionSummary
,LongTaskTimer
,FunctionCounter
,FunctionTimer
和TimeGauge
。下面分节详细介绍这些类型的使用方法和实战使用场景。而一个Meter
具体类型需要通过名字和Tag
(这里指的是Micrometer提供的Tag接口)作为它的唯一标识,这样做的好处是可以使用名字进行标记,通过不同的Tag
去区分多种维度进行数据统计。
MeterRegistry
MeterRegistry在Micrometer是一个抽象类,主要实现包括:
1、SimpleMeterRegistry:每个Meter的最新数据可以收集到SimpleMeterRegistry实例中,但是这些数据不会发布到其他系统,也就是数据是位于应用的内存中的。
2、CompositeMeterRegistry:多个MeterRegistry聚合,内部维护了一个MeterRegistry的列表。
3、全局的MeterRegistry:工厂类io.micrometer.core.instrument.Metrics
中持有一个静态final的CompositeMeterRegistry
实例globalRegistry。
当然,使用者也可以自行继承MeterRegistry去实现自定义的MeterRegistry。SimpleMeterRegistry
适合做调试的时候使用,它的简单使用方式如下:
MeterRegistryregistry=newSimpleMeterRegistry();Countercounter=registry.counter("counter");counter.increment();
CompositeMeterRegistry
实例初始化的时候,内部持有的MeterRegistry
列表是空的,如果此时用它新增一个Meter实例,Meter实例的操作是无效的
CompositeMeterRegistrycomposite=newCompositeMeterRegistry();CountercompositeCounter=composite.counter("counter");compositeCounter.increment();//<-实际上这一步操作是无效的,但是不会报错SimpleMeterRegistrysimple=newSimpleMeterRegistry();composite.add(simple);//<-向CompositeMeterRegistry实例中添加SimpleMeterRegistry实例compositeCounter.increment();//<-计数成功
全局的MeterRegistry的使用方式更加简单便捷,因为一切只需要操作工厂类Metrics的静态方法:
Metrics.addRegistry(newSimpleMeterRegistry());Countercounter=Metrics.counter("counter","tag-1","tag-2");counter.increment();
Tag与Meter的命名
Micrometer中,Meter的命名约定使用英文逗号(dot,也就是”.”)分隔单词。但是对于不同的监控系统,对命名的规约可能并不相同,如果命名规约不一致,在做监控系统迁移或者切换的时候,可能会对新的系统造成破坏。Micrometer中使用英文逗号分隔单词的命名规则,再通过底层的命名转换接口NamingConvention
进行转换,最终可以适配不同的监控系统,同时可以消除监控系统不允许的特殊字符的名称和标记等。开发者也可以覆盖NamingConvention
实现自定义的命名转换规则:registry.config().namingConvention(myCustomNamingConvention);
。在Micrometer中,对一些主流的监控系统或者存储系统的命名规则提供了默认的转换方式,例如当我们使用下面的命名时候:
MeterRegistryregistry=...registry.timer("http.server.requests");
对于不同的监控系统或者存储系统,命名会自动转换如下:
1、Prometheus - http_server_requests_duration_seconds。
2、Atlas - httpServerRequests。
3、Graphite - http.server.requests。
4、InfluxDB - http_server_requests。
其实NamingConvention已经提供了5种默认的转换规则:dot、snakeCase、camelCase、upperCamelCase和slashes。
另外,Tag(标签)是Micrometer的一个重要的功能,严格来说,一个度量框架只有实现了标签的功能,才能真正地多维度进行度量数据收集。Tag的命名一般需要是有意义的,所谓有意义就是可以根据Tag的命名可以推断出它指向的数据到底代表什么维度或者什么类型的度量指标。假设我们需要监控数据库的调用和Http请求调用统计,一般推荐的做法是:
MeterRegistryregistry=...registry.counter("database.calls","db","users")registry.counter("http.requests","uri","/api/users")
这样,当我们选择命名为”database.calls”的计数器,我们可以进一步选择分组”db”或者”users”分别统计不同分组对总调用数的贡献或者组成。一个反例如下:
MeterRegistryregistry=...registry.counter("calls","class","database","db","users");registry.counter("calls","class","http","uri","/api/users");
通过命名”calls”得到的计数器,由于标签混乱,数据是基本无法分组统计分析,这个时候可以认为得到的时间序列的统计数据是没有意义的。可以定义全局的Tag,也就是全局的Tag定义之后,会附加到所有的使用到的Meter上(只要是使用同一MeterRegistry),全局的Tag可以这样定义:
MeterRegistryregistry=...registry.counter("calls","class","database","db","users");registry.counter("calls","class","http","uri","/api/users");MeterRegistryregistry=...registry.config().commonTags("stack","prod","region","us-east-1");//和上面的意义是一样的registry.config().commonTags(Arrays.asList(Tag.of("stack","prod"),Tag.of("region","us-east-1")));
像上面这样子使用,就能通过主机,实例,区域,堆栈等操作环境进行多维度深入分析。
还有两点点需要注意:
1、Tag的值必须不为null。
2、Micrometer中,Tag必须成对出现,也就是Tag必须设置为偶数个,实际上它们以Key=Value的形式存在,具体可以看io.micrometer.core.instrument.Tag
接口:
publicinterfaceTagextendsComparable<Tag>{StringgetKey();StringgetValue();staticTagof(Stringkey,Stringvalue){returnnewImmutableTag(key,value);}defaultintcompareTo(Tago){returnthis.getKey().compareTo(o.getKey());}}
当然,有些时候,我们需要过滤一些必要的标签或者名称进行统计,或者为Meter的名称添加白名单,这个时候可以使用MeterFilter。MeterFilter本身提供一些列的静态方法,多个MeterFilter可以叠加或者组成链实现用户最终的过滤策略。例如:
MeterRegistryregistry=...registry.config().meterFilter(MeterFilter.ignoreTags("http")).meterFilter(MeterFilter.denyNameStartsWith("jvm"));
表示忽略”http”标签,拒绝名称以”jvm”字符串开头的Meter。更多用法可以参详一下MeterFilter
这个类。
Meter的命名和Meter的Tag相互结合,以命名为轴心,以Tag为多维度要素,可以使度量数据的维度更加丰富,便于统计和分析。
Meters
前面提到Meter主要包括:Timer
,Counter
,Gauge
,DistributionSummary
,LongTaskTimer
,FunctionCounter
,FunctionTimer
和TimeGauge
。下面逐一分析它们的作用和个人理解的实际使用场景(应该说是生产环境)。
Counter
Counter
是一种比较简单的Meter,它是一种单值的度量类型,或者说是一个单值计数器。Counter
接口允许使用者使用一个固定值(必须为正数)进行计数。准确来说:Counter
就是一个增量为正数的单值计数器。这个举个很简单的使用例子:
MeterRegistrymeterRegistry=newSimpleMeterRegistry();Countercounter=meterRegistry.counter("http.request","createOrder","/order/create");counter.increment();System.out.println(counter.measure());//[Measurement{statistic='COUNT',value=1.0}]
使用场景:
Counter
的作用是记录XXX的总量或者计数值,适用于一些增长类型的统计,例如下单、支付次数、Http请求总量记录等等,通过Tag可以区分不同的场景,对于下单,可以使用不同的Tag标记不同的业务来源或者是按日期划分,对于Http请求总量记录,可以使用Tag区分不同的URL。用下单业务举个例子:
CompositeMeterRegistrycomposite=newCompositeMeterRegistry();CountercompositeCounter=composite.counter("counter");compositeCounter.increment();//<-实际上这一步操作是无效的,但是不会报错SimpleMeterRegistrysimple=newSimpleMeterRegistry();composite.add(simple);//<-向CompositeMeterRegistry实例中添加SimpleMeterRegistry实例compositeCounter.increment();//<-计数成功0
控制台输出
CompositeMeterRegistrycomposite=newCompositeMeterRegistry();CountercompositeCounter=composite.counter("counter");compositeCounter.increment();//<-实际上这一步操作是无效的,但是不会报错SimpleMeterRegistrysimple=newSimpleMeterRegistry();composite.add(simple);//<-向CompositeMeterRegistry实例中添加SimpleMeterRegistry实例compositeCounter.increment();//<-计数成功1
上面的例子是使用全局静态方法工厂类Metrics去构造Counter实例,实际上,io.micrometer.core.instrument.Counter接口提供了一个内部建造器类Counter.Builder去实例化Counter,Counter.Builder的使用方式如下:
CompositeMeterRegistrycomposite=newCompositeMeterRegistry();CountercompositeCounter=composite.counter("counter");compositeCounter.increment();//<-实际上这一步操作是无效的,但是不会报错SimpleMeterRegistrysimple=newSimpleMeterRegistry();composite.add(simple);//<-向CompositeMeterRegistry实例中添加SimpleMeterRegistry实例compositeCounter.increment();//<-计数成功2
FunctionCounter
FunctionCounter
是Counter
的特化类型,它把计数器数值增加的动作抽象成接口类型ToDoubleFunction
,这个接口JDK1.8中对于Function
的特化类型接口。FunctionCounter
的使用场景和Counter
是一致的,这里介绍一下它的用法:
CompositeMeterRegistrycomposite=newCompositeMeterRegistry();CountercompositeCounter=composite.counter("counter");compositeCounter.increment();//<-实际上这一步操作是无效的,但是不会报错SimpleMeterRegistrysimple=newSimpleMeterRegistry();composite.add(simple);//<-向CompositeMeterRegistry实例中添加SimpleMeterRegistry实例compositeCounter.increment();//<-计数成功3
FunctionCounter
使用的一个明显的好处是,我们不需要感知FunctionCounter实例的存在,实际上我们只需要操作作为FunctionCounter实例构建元素之一的AtomicInteger实例即可,这种接口的设计方式在很多框架里面都可以看到。
Timer
Timer(计时器)适用于记录耗时比较短的事件的执行时间,通过时间分布展示事件的序列和发生频率。所有的Timer的实现至少记录了发生的事件的数量和这些事件的总耗时,从而生成一个时间序列。Timer的基本单位基于服务端的指标而定,但是实际上我们不需要过于关注Timer的基本单位,因为Micrometer在存储生成的时间序列的时候会自动选择适当的基本单位。Timer接口提供的常用方法如下:
CompositeMeterRegistrycomposite=newCompositeMeterRegistry();CountercompositeCounter=composite.counter("counter");compositeCounter.increment();//<-实际上这一步操作是无效的,但是不会报错SimpleMeterRegistrysimple=newSimpleMeterRegistry();composite.add(simple);//<-向CompositeMeterRegistry实例中添加SimpleMeterRegistry实例compositeCounter.increment();//<-计数成功4
实际上,比较常用和方便的方法是几个函数式接口入参的方法:
CompositeMeterRegistrycomposite=newCompositeMeterRegistry();CountercompositeCounter=composite.counter("counter");compositeCounter.increment();//<-实际上这一步操作是无效的,但是不会报错SimpleMeterRegistrysimple=newSimpleMeterRegistry();composite.add(simple);//<-向CompositeMeterRegistry实例中添加SimpleMeterRegistry实例compositeCounter.increment();//<-计数成功5
使用场景:
根据个人经验和实践,总结如下:
1、记录指定方法的执行时间用于展示。
2、记录一些任务的执行时间,从而确定某些数据来源的速率,例如消息队列消息的消费速率等。
这里举个实际的例子,要对系统做一个功能,记录指定方法的执行时间,还是用下单方法做例子:
CompositeMeterRegistrycomposite=newCompositeMeterRegistry();CountercompositeCounter=composite.counter("counter");compositeCounter.increment();//<-实际上这一步操作是无效的,但是不会报错SimpleMeterRegistrysimple=newSimpleMeterRegistry();composite.add(simple);//<-向CompositeMeterRegistry实例中添加SimpleMeterRegistry实例compositeCounter.increment();//<-计数成功6
在实际生产环境中,可以通过spring-aop把记录方法耗时的逻辑抽象到一个切面中,这样就能减少不必要的冗余的模板代码。上面的例子是通过Mertics构造Timer实例,实际上也可以使用Builder构造:
CompositeMeterRegistrycomposite=newCompositeMeterRegistry();CountercompositeCounter=composite.counter("counter");compositeCounter.increment();//<-实际上这一步操作是无效的,但是不会报错SimpleMeterRegistrysimple=newSimpleMeterRegistry();composite.add(simple);//<-向CompositeMeterRegistry实例中添加SimpleMeterRegistry实例compositeCounter.increment();//<-计数成功7
另外,Timer的使用还可以基于它的内部类Timer.Sample,通过start和stop两个方法记录两者之间的逻辑的执行耗时。例如:
CompositeMeterRegistrycomposite=newCompositeMeterRegistry();CountercompositeCounter=composite.counter("counter");compositeCounter.increment();//<-实际上这一步操作是无效的,但是不会报错SimpleMeterRegistrysimple=newSimpleMeterRegistry();composite.add(simple);//<-向CompositeMeterRegistry实例中添加SimpleMeterRegistry实例compositeCounter.increment();//<-计数成功8
FunctionTimer
FunctionTimer是Timer的特化类型,它主要提供两个单调递增的函数(其实并不是单调递增,只是在使用中一般需要随着时间最少保持不变或者说不减少):一个用于计数的函数和一个用于记录总调用耗时的函数,它的建造器的入参如下:
CompositeMeterRegistrycomposite=newCompositeMeterRegistry();CountercompositeCounter=composite.counter("counter");compositeCounter.increment();//<-实际上这一步操作是无效的,但是不会报错SimpleMeterRegistrysimple=newSimpleMeterRegistry();composite.add(simple);//<-向CompositeMeterRegistry实例中添加SimpleMeterRegistry实例compositeCounter.increment();//<-计数成功9
官方文档中的例子如下:
Metrics.addRegistry(newSimpleMeterRegistry());Countercounter=Metrics.counter("counter","tag-1","tag-2");counter.increment();0
按照个人理解,ToDoubleFunction用于统计事件个数,ToDoubleFunction用于记录执行总时间,实际上两个函数都只是Function函数的变体,还有一个比较重要的是总时间的单位totalTimeFunctionUnit。简单的使用方式如下:
Metrics.addRegistry(newSimpleMeterRegistry());Countercounter=Metrics.counter("counter","tag-1","tag-2");counter.increment();1
LongTaskTimer
LongTaskTimer也是一种Timer的特化类型,主要用于记录长时间执行的任务的持续时间,在任务完成之前,被监测的事件或者任务仍然处于运行状态,任务完成的时候,任务执行的总耗时才会被记录下来。LongTaskTimer适合用于长时间持续运行的事件耗时的记录,例如相对耗时的定时任务。在Spring应用中,可以简单地使用@Scheduled和@Timed注解,基于spring-aop完成定时调度任务的总耗时记录:
Metrics.addRegistry(newSimpleMeterRegistry());Countercounter=Metrics.counter("counter","tag-1","tag-2");counter.increment();2
当然,在非spring体系中也能方便地使用LongTaskTimer:
Metrics.addRegistry(newSimpleMeterRegistry());Countercounter=Metrics.counter("counter","tag-1","tag-2");counter.increment();3
Gauge
Gauge(仪表)是获取当前度量记录值的句柄,也就是它表示一个可以任意上下浮动的单数值度量Meter。Gauge通常用于变动的测量值,测量值用ToDoubleFunction
参数的返回值设置,如当前的内存使用情况,同时也可以测量上下移动的”计数”,比如队列中的消息数量。官网文档中提到Gauge的典型使用场景是用于测量集合或映射的大小或运行状态中的线程数。Gauge一般用于监测有自然上界的事件或者任务,而Counter一般使用于无自然上界的事件或者任务的监测,所以像Http请求总量计数应该使用Counter而非Gauge。MeterRegistry
中提供了一些便于构建用于观察数值、函数、集合和映射的Gauge相关的方法:
Metrics.addRegistry(newSimpleMeterRegistry());Countercounter=Metrics.counter("counter","tag-1","tag-2");counter.increment();4
上面的三个方法通过MeterRegistry
构建Gauge并且返回了集合或者映射实例,使用这些集合或者映射实例就能在其size变化过程中记录这个变更值。更重要的优点是,我们不需要感知Gauge接口的存在,只需要像平时一样使用集合或者映射实例就可以了。此外,Gauge还支持java.lang.Number
的子类,java.util.concurrent.atomic
包中的AtomicInteger
和AtomicLong
,还有Guava提供的AtomicDouble
:
Metrics.addRegistry(newSimpleMeterRegistry());Countercounter=Metrics.counter("counter","tag-1","tag-2");counter.increment();5
除了使用MeterRegistry创建Gauge之外,还可以使用建造器流式创建:
Metrics.addRegistry(newSimpleMeterRegistry());Countercounter=Metrics.counter("counter","tag-1","tag-2");counter.increment();6
使用场景:
根据个人经验和实践,总结如下:
1、有自然(物理)上界的浮动值的监测,例如物理内存、集合、映射、数值等。
2、有逻辑上界的浮动值的监测,例如积压的消息、(线程池中)积压的任务等,其实本质也是集合或者映射的监测。
举个相对实际的例子,假设我们需要对登录后的用户发送一条短信或者推送,做法是消息先投放到一个阻塞队列,再由一个线程消费消息进行其他操作:
Metrics.addRegistry(newSimpleMeterRegistry());Countercounter=Metrics.counter("counter","tag-1","tag-2");counter.increment();7
上面的例子代码写得比较糟糕,只为了演示相关使用方式,切勿用于生产环境。
TimeGauge
TimeGauge是Gauge的特化类型,相比Gauge,它的构建器中多了一个TimeUnit类型的参数,用于指定ToDoubleFunction
入参的基础时间单位。这里简单举个使用例子:
Metrics.addRegistry(newSimpleMeterRegistry());Countercounter=Metrics.counter("counter","tag-1","tag-2");counter.increment();8
DistributionSummary
Summary(摘要)主要用于跟踪事件的分布,在Micrometer中,对应的类是DistributionSummary(分发摘要)。它的使用方式和Timer十分相似,但是它的记录值并不依赖于时间单位。常见的使用场景:使用DistributionSummary测量命中服务器的请求的有效负载大小。使用MeterRegistry
创建DistributionSummary实例如下:
Metrics.addRegistry(newSimpleMeterRegistry());Countercounter=Metrics.counter("counter","tag-1","tag-2");counter.increment();9
通过建造器流式创建如下:
MeterRegistryregistry=...registry.timer("http.server.requests");0
DistributionSummary中有很多构建参数跟缩放和直方图的表示相关,见下一节。
使用场景:
根据个人经验和实践,总结如下:
1、不依赖于时间单位的记录值的测量,例如服务器有效负载值,缓存的命中率等。
举个相对具体的例子:
MeterRegistryregistry=...registry.timer("http.server.requests");1
直方图和百分数配置
直方图和百分数配置适用于Summary和Timer,这部分相对复杂,等研究透了再补充。
基于SpirngBoot、Prometheus、Grafana集成
集成了Micrometer框架的JVM应用使用到Micrometer的API收集的度量数据位于内存之中,因此,需要额外的存储系统去存储这些度量数据,需要有监控系统负责统一收集和处理这些数据,还需要有一些UI工具去展示数据,一般大佬只喜欢看炫酷的图表或者动画。常见的存储系统就是时序数据库,主流的有Influx、Datadog等。比较主流的监控系统(主要是用于数据收集和处理)就是Prometheus(一般叫普罗米修斯,下面就这样叫吧)。而展示的UI目前相对用得比较多的就是Grafana。另外,Prometheus已经内置了一个时序数据库的实现,因此,在做一套相对完善的度量数据监控的系统只需要依赖目标JVM应用,Prometheus组件和Grafana组件即可。下面花一点时间从零开始搭建一个这样的系统,之前写的一篇文章基于Windows系统,操作可能跟生产环境不够接近,这次使用CentOS7。
SpirngBoot中使用Micrometer
SpringBoot中的spring-boot-starter-actuator
依赖已经集成了对Micrometer的支持,其中的metrics端点的很多功能就是通过Micrometer实现的,prometheus端点默认也是开启支持的,实际上actuator依赖的spring-boot-actuator-autoconfigure
中集成了对很多框架的开箱即用的API,其中prometheus
包中集成了对Prometheus的支持,使得使用了actuator可以轻易地让项目暴露出prometheus端点,作为Prometheus收集数据的客户端,Prometheus(服务端软件)可以通过此端点收集应用中Micrometer的度量数据。
我们先引入spring-boot-starter-actuator和spring-boot-starter-web,实现一个Counter和Timer作为示例。依赖:
MeterRegistryregistry=...registry.timer("http.server.requests");2
接着编写一个下单接口和一个消息发送模块,模拟用户下单之后向用户发送消息:
MeterRegistryregistry=...registry.timer("http.server.requests");3
yaml的配置如下:
MeterRegistryregistry=...registry.timer("http.server.requests");4
注意多看spring官方文档关于Actuator的详细描述,在SpringBoot-2.x之后,配置Web端点暴露的权限控制和1.x有很大的不同。总结一下就是:除了shutdown
端点之外,其他端点默认都是开启支持的这里仅仅是开启支持,并不是暴露为Web端点,端点必须暴露为Web端点才能被访问,禁用或者开启端点支持的配置方式如下:
MeterRegistryregistry=...registry.timer("http.server.requests");5
可以查看actuator-api文档查看所有支持的端点的特性,这个是2.1.0.RELEASE版本的官方文档,不知道日后链接会不会挂掉。端点只开启支持,但是不暴露为Web端点,是无法通过http://{host}:{management.port}/{management.endpoints.web.base-path}/{endpointId}访问的。暴露监控端点为Web端点的配置是:
MeterRegistryregistry=...registry.timer("http.server.requests");6
management.endpoints.web.exposure.exclude
用于指定不暴露为Web端点的监控端点,指定多个的时候用英文逗号分隔management.endpoints.web.exposure.include
默认指定的只有info和health两个端点,我们可以直接指定暴露所有的端点:management.endpoints.web.exposure.include=*
,如果采用YAML配置,记得*要加单引号’*‘。暴露所有Web监控端点是一件比较危险的事情,如果需要在生产环境这样做,请务必先确认http://{host}:{management.port}
不能通过公网访问(也就是监控端点访问的端口只能通过内网访问,这样可以方便后面说到的Prometheus服务端通过此端口收集数据)。
Prometheus的安装和配置
Prometheus目前的最新版本是2.5,鉴于笔者没深入玩过Docker,这里还是直接下载它的压缩包解压安装。
MeterRegistryregistry=...registry.timer("http.server.requests");7
先编辑解压出来的目录下的prometheus配置文件prometheus.yml,主要修改scrape_configs节点的属性:
MeterRegistryregistry=...registry.timer("http.server.requests");8
配置拉取度量数据的路径为localhost:10091/management/metrics,此前记得把前一节提到的应用在虚拟机中启动。接着启动Prometheus应用:
MeterRegistryregistry=...registry.timer("http.server.requests");9
Prometheus引用的默认启动端口是9090,启动成功后,日志如下:
此时,访问ttp://${虚拟机host}:9090/targets就能看到当前Prometheus中执行的Job
访问ttp://${虚拟机host}:9090/graph
以查找到我们定义的度量Meter和spring-boot-starter-actuator中已经定义好的一些关于JVM或者Tomcat的度量Meter。我们先对应用的/order接口进行调用,然后查看一下监控前面在应用中定义的rder_count_total``ethod_cost_time_seconds_sum
可以看到,Meter的信息已经被收集和展示,但是显然不够详细和炫酷,这个时候就需要使用Grafana的UI做一下点缀。
Grafana的安装和使用
Grafana的安装过程如下:
MeterRegistryregistry=...registry.counter("database.calls","db","users")registry.counter("http.requests","uri","/api/users")0
安装完成后,通过命令service grafana-server start启动即可,默认的启动端口为3000,通过ttp://${host}:3000
即可。初始的账号密码都为admin,权限是管理员权限。接着需要在Home面板添加一个数据源,目的是对接Prometheus服务端从而可以拉取它里面的度量数据。数据源添加面板如下:
其实就是指向Prometheus服务端的端口就可以了。接下来可以天马行空地添加需要的面板,就下单数量统计的指标,可以添加一个Graph的面板
配置面板的时候,需要在基础(General)中指定Title:
接着比较重要的是Metrics的配置,需要指定数据源和Prometheus的查询语句:
最好参考一下Prometheus的官方文档,稍微学习一下它的查询语言PromQL的使用方式,一个面板可以支持多个PromQL查询。前面提到的两项是基本配置,其他配置项一般是图表展示的辅助或者预警等辅助功能,这里先不展开,可以取Grafana的官网挖掘一下使用方式。然后我们再调用一下下单接口,过一段时间,图表的数据就会自动更新和展示:
接着添加一下项目中使用的Timer的Meter,便于监控方法的执行时间,完成之后大致如下:
自定义系统输出 例如:
MeterRegistryregistry=...registry.counter("database.calls","db","users")registry.counter("http.requests","uri","/api/users")1
来统计这个数据
那么在java中可以使用 Metrics.counter("app_login")来增加数据
在prometheus监听自定义路径 /app/meter 代码如下
MeterRegistryregistry=...registry.counter("database.calls","db","users")registry.counter("http.requests","uri","/api/users")2
写自定义的原因是因为 prometheus需要返回响应头为text/plain; version=0.0.4;charset=utf-8 并且Content-Length需要文本长度。 比较坑。 所以留下日志
Github博客:https://github.com/yunlongn