文档章节

prometheus收集springboot指标

super-wen
 super-wen
发布于 2017/06/02 17:53
字数 577
阅读 210
收藏 3

##prometheus 主动采集 springboot

maven dependency

          <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-actuator</artifactId>
                <version>${spring-boot.version}</version>
         </dependency>

        <dependency>
            <groupId>com.moelholm</groupId>
            <artifactId>prometheus-spring-boot-starter</artifactId>
            <version>1.0.1</version>
        </dependency>

实现逻辑

将springboot内部的publicMetrics转为prometheus 格式.

@Component
public class SpringBootMetricsCollector extends Collector {
  private final Collection<PublicMetrics> publicMetrics;

  @Autowired
  public SpringBootMetricsCollector(Collection<PublicMetrics> publicMetrics) {
    this.publicMetrics = publicMetrics;
  }

  @Override
  public List<MetricFamilySamples> collect() {
    ArrayList<MetricFamilySamples> samples = new ArrayList<MetricFamilySamples>();
    for (PublicMetrics publicMetrics : this.publicMetrics) {
      for (Metric<?> metric : publicMetrics.metrics()) {
        String name = Collector.sanitizeMetricName(metric.getName());
        double value = metric.getValue().doubleValue();
        MetricFamilySamples metricFamilySamples = new MetricFamilySamples(
                name, Type.GAUGE, name, Collections.singletonList(
                new MetricFamilySamples.Sample(name, new ArrayList<String>(), new ArrayList<String>(), value)));
        samples.add(metricFamilySamples);
      }
    }
    return samples;
  }
}

prometheus 通过访问/prometheus节点采集。

git库地址:https://github.com/thomasdarimont/prometheus-spring-boot-starter

springboot 推送metrics 到 pushGateway,然后prometheus 去pushGateway采集。

          <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-actuator</artifactId>
                <version>${spring-boot.version}</version>
         </dependency>

            <dependency>
                <groupId>io.prometheus</groupId>
                <artifactId>simpleclient_pushgateway</artifactId>
                <version>0.0.21</version>
            </dependency>
             <dependency>
                <groupId>io.prometheus</groupId>
                <artifactId>simpleclient_spring_boot</artifactId>
                <version>0.0.21</version>
            </dependency>
            

具体代码

@Configuration
@ComponentScan("io.prometheus.client.spring.boot")
public class PrometheusConfiguration {
    private static final Logger LOGGER = LoggerFactory.getLogger(PrometheusConfiguration.class);

    @Value("${spring.application.name}")
    String applicationName;

    @Value("${prometheus.pushgateway.host}")
    String pushHost;

    @Value("${prometheus.pushgateway.intervalInMillis:10000}")
    long intervalInMillis;


    @Autowired
    private SpringBootMetricsCollector springBootMetricsCollector;


    @PostConstruct
    public void initialize() {
        Map<String,String> map = new HashMap<>();
        //这里存在问题,在docker中获得的是1@localhost
        map.put("instance", ManagementFactory.getRuntimeMXBean().getName());
        PushGateway prometheusPush = new PushGateway(pushHost);
        Executors.newSingleThreadScheduledExecutor().scheduleAtFixedRate(() -> {
            try {
                LOGGER.debug("prometheus push");
                prometheusPush.push(springBootMetricsCollector, applicationName,map);
            } catch (Exception e) {
                LOGGER.error("prometheus push error", e);
            }
        }, 5000, intervalInMillis, TimeUnit.MILLISECONDS);
    }
}

修改上述代码,使之适用dcos,docker环境

当服务部署在dcos上时,端口是不固定,数量是不固定的.这时候就需要通过主动推送到pushGateway后,交由prometheus 采集.

@Configuration
public class SystemConfiguration implements EnvironmentAware {

    private static final Logger LOGGER = LoggerFactory.getLogger(SystemConfiguration.class);

    private String host;//docker 传入的宿主机ip

    private String port0;

    private String prot1;

    @Value("${server.port}")
    private String serverPort;

    @Override
    public void setEnvironment(Environment environment) {
        /**
         * 在docker中.目的是从环境变量中获得传入的宿主机ip和端口.
         */
        this.host = environment.getProperty("HOST");
        this.port0 = environment.getProperty("PORT0");
        this.prot1 = environment.getProperty("PORT1");
        LOGGER.info("-------------------------environment");
        LOGGER.info("host:"+host);
        LOGGER.info("port0:"+ port0);
        LOGGER.info("prot1:"+ prot1);
    }

    @PostConstruct
    public void init(){
        if(StringUtils.isEmpty(host)){
            //未能从环境变量中获得host
            try {
                 this.host = InetAddress.getLocalHost().getHostAddress();
            } catch (UnknownHostException e) {
                LOGGER.error("获得host失败",e);
            }
            this.port0 = serverPort;
        }
        LOGGER.info("-------------------------postConstruct");
        LOGGER.info("host:"+this.host);
        LOGGER.info("port0:"+this.port0);
    }


    public String getHost() {
        return host;
    }

    public void setHost(String host) {
        this.host = host;
    }

    public String getPort0() {
        return port0;
    }

    public void setPort0(String port0) {
        this.port0 = port0;
    }

    public String getProt1() {
        return prot1;
    }

    public void setProt1(String prot1) {
        this.prot1 = prot1;
    }

    public String getServerPort() {
        return serverPort;
    }

    public void setServerPort(String serverPort) {
        this.serverPort = serverPort;
    }
}

@Configuration
@ComponentScan("io.prometheus.client.spring.boot")
public class PrometheusConfiguration  {
    private static final Logger LOGGER = LoggerFactory.getLogger(PrometheusConfiguration.class);

    @Value("${spring.application.name}")
    String applicationName;

    @Value("${prometheus.pushgateway.host}")
    String pushHost;

    @Value("${prometheus.pushgateway.intervalInMillis:10000}")
    long intervalInMillis;

    @Autowired
    private SystemConfiguration systemConfiguration;


    @Autowired
    private SpringBootMetricsCollector springBootMetricsCollector;


    @PostConstruct
    public void initialize() {


        Map<String,String> map = new HashMap<>();
        map.put("instance", systemConfiguration.getHost()+"@"+systemConfiguration.getPort0());
        PushGateway prometheusPush = new PushGateway(pushHost);
        Executors.newSingleThreadScheduledExecutor().scheduleAtFixedRate(() -> {
            try {
                LOGGER.debug("prometheus push");
                prometheusPush.push(springBootMetricsCollector, applicationName,map);
            } catch (Exception e) {
                LOGGER.error("prometheus push error", e);
            }
        }, 5000, intervalInMillis, TimeUnit.MILLISECONDS);
    }


}

© 著作权归作者所有

共有 人打赏支持
super-wen
粉丝 5
博文 37
码字总数 13546
作品 0
徐汇
程序员
私信 提问
为springboot项目添加springboot-admin监控

我们知道spring-boot-actuator暴露了大量统计和监控信息的端点,spring-boot-admin 就是为此提供的监控项目。 先来看看大概会提供什么样的功能 从图中可以看出,主要内容都是由spring boot a...

ryan-miao
06/12
0
0
springboot2输出metrics到influxdb

序 本文主要研究一下如何将springboot2的metrics输出到influxdb maven 配置 influx 启动之后创建数据库 命令行创建 rest接口创建 返回 或者直接配置文件指定auto-create-db=true,就无需额外...

go4it
06/17
0
0
SpringBoot-01:什么是SpringBoot?

------------吾亦无他,唯手熟尔,谦卑若愚,好学若饥------------- SpringBoot: Spring Boot可以轻松创建独立的,生产级的基于Spring的应用程序,您可以“运行”。 SpringBoot对Spring平台和...

晨曦dawn
06/22
0
0
深入理解SpringBoot的过滤条件--AutoConfigure

我们知道在Spring及SpringBoot里按条件创建Bean的核心是接口与注解,其实在SpringBoot里还有一种AutoConfigure也可以来过滤配置,只不过这种技术,能够让SpringBoot更快速的启动,那么下面我们...

融科聂晨
07/23
0
0
一个 SpringBoot 项目通过 SOFALookout & Prometheus 进行监控

一个 SpringBoot 项目通过 SOFALookout & Prometheus 进行监控 Harries Blog™2018-06-110 阅读 SpringAppcatclientbuildapache...

Harries Blog™
06/11
0
0

没有更多内容

加载失败,请刷新页面

加载更多

腾讯与Github的魔幻会面背后的故事…

10月22日,腾讯开源管理办公室有幸邀请到Github新晋CEO Nat Friedman,前来鹅厂参观交流。目前腾讯已经有近70个项目在Github上开源,共获得17w stars,世界排名11位。Github是腾讯开源的主阵...

腾讯开源
21分钟前
1
0
单例模式

单例模式(Singleton pattern)属于创建型设计模式。 保证一个类仅有一个实例,并提供一个访问它的全局访问点。 通常我们可以让一个全局变量使得一个对象被访问,但它不能防止你实例化多个对...

NinjaFrog
25分钟前
0
0
TypeScript基础入门之装饰器(三)

转载 TypeScript基础入门之装饰器(三) 继续上篇文章[TypeScript基础入门之装饰器(二)] 访问器装饰器 Accessor Decorator在访问器声明之前声明。 访问器装饰器应用于访问器的属性描述符,可用...

durban
43分钟前
2
0
spring5调研学习(转载)

Spring框架的新功能 这一章主要提供Spring框架新的功能和变更。 升级到新版本的框架可以参考。Spring git。 内容列表 Spring 5.x框架新的功能 Spring 4.x框架新的功能 Spring 3.x框架新的功能...

小海bug
53分钟前
2
0
为何Spring框架能这么流行?

想要学习更多关于Spring框架在Java开发者中如此流行?看这篇文章可以学到更多! Spring框架特性 Spring是用于应用开发中的一款强大,轻量级框架。更广泛地说,你可以认为Spring框架是一个定义...

java知识分子
56分钟前
2
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部