prometheus学习笔记(2)-利用java client写入数据
时间:2022-07-25
本文章向大家介绍prometheus学习笔记(2)-利用java client写入数据,主要内容包括其使用实例、应用技巧、基本知识点总结和需要注意事项,具有一定的参考价值,需要的朋友可以参考一下。
继续学习prometheus,上一节演示了用http方式使用curl向pushgateway发送数据,本节将研究如何利用client jar包,以java代码的方式写入数据。
一、依赖的jar包
1 <dependency>
2 <groupId>io.prometheus</groupId>
3 <artifactId>simpleclient</artifactId>
4 <version>0.9.0</version>
5 </dependency>
6
7 <dependency>
8 <groupId>io.prometheus</groupId>
9 <artifactId>simpleclient_pushgateway</artifactId>
10 <version>0.9.0</version>
11 </dependency>
主要就是上面2个(这是最小配置),考虑到我们通常是在spring环境中使用,一般还要加1个spring依赖,完整pom如下:
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.cnblogs.yjmyzz</groupId>
<artifactId>spring-boot-demo</artifactId>
<version>0.0.1-SNAPSHOT</version>
<properties>
<java.version>1.8</java.version>
</properties>
<dependencies>
<!-- spring应用最小依赖-->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
<version>5.2.4.RELEASE</version>
</dependency>
<!-- The client -->
<dependency>
<groupId>io.prometheus</groupId>
<artifactId>simpleclient</artifactId>
<version>0.9.0</version>
</dependency>
<dependency>
<groupId>io.prometheus</groupId>
<artifactId>simpleclient_pushgateway</artifactId>
<version>0.9.0</version>
</dependency>
<!-- 下面2个也常用,但在本例中用不到-->
<!-- <dependency>-->
<!-- <groupId>io.prometheus</groupId>-->
<!-- <artifactId>simpleclient_hotspot</artifactId>-->
<!-- <version>0.9.0</version>-->
<!-- </dependency>-->
<!-- <dependency>-->
<!-- <groupId>io.prometheus</groupId>-->
<!-- <artifactId>simpleclient_httpserver</artifactId>-->
<!-- <version>0.9.0</version>-->
<!-- </dependency>-->
</dependencies>
<build>
<plugins>
<plugin>
<artifactId>maven-compiler-plugin</artifactId>
<version>3.1</version>
<configuration>
<source>1.8</source>
<target>1.8</target>
</configuration>
</plugin>
</plugins>
</build>
</project>
二、示例代码
package com.cnblogs.yjmyzz.springbootdemo;
import io.prometheus.client.Counter;
import io.prometheus.client.Gauge;
import io.prometheus.client.exporter.PushGateway;
import org.springframework.context.annotation.AnnotationConfigApplicationContext;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.ComponentScan;
import java.io.IOException;
import java.util.Random;
/**
* @author 菩提树下的杨过(http : / / yjmyzz.cnblogs.com)
* 利用client写入prometheus示例
*/
@ComponentScan("com.cnblogs.yjmyzz")
public class SampleApplication {
/**
* push网关
*
* @return
*/
@Bean
public PushGateway getPushGateway() {
return new PushGateway("localhost:9091");
}
/**
* counter实例
*
* @return
*/
@Bean
public Counter getCounter() {
return Counter.build()
.name("blog_visit") //这里模拟博客访问量
.labelNames("blog_id") //博客id
.help("counter_blog_visit") //这个名字随便起
.register(); //注:通常只能注册1次,1个实例中重复注册会报错
}
@Bean
public Gauge getGauge() {
return Gauge.build()
.name("blog_fans") //这里模拟粉丝数(注:这里我们没设置label)
.help("gauge_blog_fans")
.register();
}
public static void main(String[] args) throws IOException, InterruptedException {
AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext(SampleApplication.class);
//从spring上下文中取出这些实例
Counter counter = context.getBean(Counter.class);
Gauge gauge = context.getBean(Gauge.class);
PushGateway gateway = context.getBean(PushGateway.class);
Random rnd = new Random();
//粉丝数先预设50
gauge.inc(50);
while (true) {
//随机生成1个blogId
int blogId = rnd.nextInt(100000);
//该blogId的访问量+1
counter.labels(blogId + "").inc();
//模拟粉丝数的变化
if (blogId % 2 == 0) {
gauge.inc();
} else {
gauge.dec();
}
//利用网关采集数据
gateway.push(counter, "job-counter-test");
gateway.push(gauge, "job-gauge-test");
//辅助输出日志
System.out.println("blogId:" + blogId);
Thread.sleep(5000);
}
}
}
代码运行起来后,可以通过http://localhost:9091,确认job是否执行成功
三、配置grafana图表
写入成功后,grafana里就能识别出这2个指标了:
参考文章:
https://github.com/prometheus/client_java
- java教程
- Java快速入门
- Java 开发环境配置
- Java基本语法
- Java 对象和类
- Java 基本数据类型
- Java 变量类型
- Java 修饰符
- Java 运算符
- Java 循环结构
- Java 分支结构
- Java Number类
- Java Character类
- Java String类
- Java StringBuffer和StringBuilder类
- Java 数组
- Java 日期时间
- Java 正则表达式
- Java 方法
- Java 流(Stream)、文件(File)和IO
- Java 异常处理
- Java 继承
- Java 重写(Override)与重载(Overload)
- Java 多态
- Java 抽象类
- Java 封装
- Java 接口
- Java 包(package)
- Java 数据结构
- Java 集合框架
- Java 泛型
- Java 序列化
- Java 网络编程
- Java 发送邮件
- Java 多线程编程
- Java Applet基础
- Java 文档注释
- pytest 测试框架学习(10):pytest.param
- pytest 测试框架学习(11):pytest.raises
- Hibernate第二天:Hibernate的一级缓存、其他的API
- pytest 测试框架学习(12):pytest.deprecated_call
- Pinstaller(Python打包为exe文件
- pytest 测试框架学习(14):pytest.warns
- ImportError: /lib64/libm.so.6: version `CXXAB_1.3.8.' not found (required by /usr/local/python37/lib
- pytest 测试框架学习(15):pytest.freeze_includes
- Linux: scp文件,目录上传下载标准版
- Hibernate第三天:Hibernate的一对多配置、Hibernate的多对多的配置
- Git: 掉坑记 -- git reset 杀手
- ModuleNotFoundError: No module named 'phkit.pinyin'
- Hibernate第四天:Hibernate的查询方式、抓取策略
- 爬虫抓取博客园前10页标题带有Python关键字(不区分大小写)的文章
- Python爬虫抓取唐诗宋词