栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

新特性jfr streaming

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

新特性jfr streaming

java14提供了jfr streaming的特性。这个算是带来了非常大的体验变化的。

jfr的优势

在11的时候,jfr已经在openjdk中了,目前已经backport到8的版本。下面简单介绍一下jfr的为什么这么重要,以至于从11专门做backport到8。

  1. 丰富的采集数据,jfr中包含了特别多的数据,可以用作性能调优。基本每层的资源都有统计。可以说数据是非常丰富的。
  2. 低消耗。jfr因为集成在jvm内部,所以他有很多性能方面的考虑,这个是其他产品所不具备的。在java code层面做这些操作,消耗不会太低。但是jfr可以保证大部分消耗不超过5%,基本都是在1%的水平。
  3. 支持事后分析,jfr支持常态打开,并且可以在程序退出后,把数据采集到文件的状态。
特性的优势

上面讲了jfr的这么多好处,那这个新特性的优势是什么呢。

  1. jfr原来支持事后文件打开,这样就导致了各种数据只能事后进行分析,而不能实时的知道数据的来源。例如我们想借助他低功耗的做一些指标采集,是无法实时的获取的。
  2. jfr会占用jvm进程的内存,所以他本身保存的数据是有限的,他要减少数据对进程的影响,所以采用保留最后,丢弃前面数据的做法。这样无法在时间的角度分析数据。

jfr streaming解决了上面的问题。他提供了api的方式,可以消费我们关注的指标数据。程序拿到指标数据后,就可以做很多操作,例如暴露让别的程序抓取,或者是直接socket传输走。
这样在用很低的功耗获取到特别多的数据。

demo

因为这是jdk14的特性。所以必须切换为jdk14。


import jdk.jfr.Configuration;
import jdk.jfr.consumer.RecordingStream;

import java.io.IOException;
import java.text.ParseException;

public class JfrStream {
    public static void main(String[] args) throws IOException, ParseException {
 Configuration config = Configuration.getConfiguration("default");
 try (var es = new RecordingStream(config)) {
     es.onEvent("jdk.CPULoad", System.out::println);
     es.onEvent("jdk.ThreadDump",System.out::println);
     es.start();

 }
    }
}

code是比较简单的,想要运行获取到数据,这里就必须开启jfr功能。

-XX:StartFlightRecording

code是比较简单的,我们只要关注event就好,这里的event都可以在配置文件中获取。
这里只是简单的输出了一下。后面传递的是一个consumer

Consumer action

后面就可以再这里进行一些需要特定话的操作。

配合自定义事件

自定义事件是Java11的特性。

@Label("myevent")
@Description("Helps the programmer getting started")
public class CustomEvent extends Event {


    @Label("Message")
    String message;

    public String getMessage() {
 return message;
    }

    public void setMessage(String message) {
 this.message = message;
    }
}

    public static void main(String[] args) throws IOException, ParseException {
 new Thread(() -> {
     while (true) {
  CustomEvent customEvent = new CustomEvent();
  customEvent.begin();
  customEvent.setMessage("first");
  customEvent.end();
  customEvent.commit();
  try {
      Thread.sleep(3000);
  } catch (InterruptedException e) {
      e.printStackTrace();
  }

     }
 }).start();

 Configuration config = Configuration.getConfiguration("default");

 try (var es = new RecordingStream(config)) {
     es.onEvent("com.xp.log.CustomEvent", System.out::println);
     es.start();

 }


    }

现在如果想做一个apm系统暴露指标,会特别容易。只要自定义事件,写好消费者,就可以获取一个低消耗的采集能力。

转载请注明:文章转载自 www.mshxw.com
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号