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<RecordedEvent> 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系统暴露指标，会特别容易。只要自定义事件，写好消费者，就可以获取一个低消耗的采集能力。