JDK14的新特性:JFR,JMC和JFR事件流

简介

Java Flight Recorder（JFR）是JVM的诊断和性能分析工具。它能够收集有关JVM以及在其上运行的Java应用程序的数据。JFR是集成到JVM中的，因此JFR对JVM的性能影响很是小，咱们能够放心的使用它。

通常来讲，在使用默认配置的时候，性能影响要小于1%。

JFR的历史好久远了。早在Oracle2008年收购BEA的时候就有了。JFR通常和JMC（Java Mission Control）协同工做。

JFR是一个基于事件的低开销的分析引擎，具备高性能的后端，能够以二进制格式编写事件，而JMC是一个GUI工具，用于检查JFR建立的数据文件。

这些工具最先是在BEA的JRockit JVM中出现的，最后被移植到了Oracle JDK。最开始JFR是商用版本，可是在JDK11的时候，JFR和JMC彻底开源了，这意味着咱们在非商用的状况下也可使用了。

而在今天的JDK 14中，引入了一个新的JFR特性叫作JFR Event Streaming，咱们将在本文中详细讲解。

先介绍一下JFR和JMC。

更多内容请访问 www.flydean.com

JFR

上面咱们简单的介绍了一下JFR。JFR是JVM的调优工具，经过不停的收集JVM和java应用程序中的各类事件，从而为后续的JMC分析提供数据。

Event是由三部分组成的：时间戳，事件名和数据。同时JFR也会处理三种类型的Event：持续一段时间的Event，马上触发的Event和抽样的Event。

为了保证性能的最新影响，在使用JFR的时候，请选择你须要的事件类型。

JFR从JVM中搜集到Event以后，会将其写入一个小的thread-local缓存中，而后刷新到一个全局的内存缓存中，最后将缓存中的数据写到磁盘中去。

或者你能够配置JFR不写到磁盘中去，可是这样缓存中只会保存部分events的信息。这也是为何会有JDK14 JEP 349的缘由。

开启JFR有不少种方式，这里咱们关注下面两种：

1. 添加命令行参数

-XX:StartFlightRecording:<options>

启动命令行参数的格式如上所述。

JFR能够获取超过一百种不一样类型的元数据。若是要咱们一个个来指定这些元数据，将会是一个很是大的功能。因此JDK已经为咱们提供了两个默认的profile：default.jfc and profile.jfc。

其中 default.jfc 是默认的记录等级，对JVM性能影响不大，适合普通的，大部分应用程序。而profile.jfc包含了更多的细节，对性能影响会更多一些。

若是你不想使用默认的两个jfc文件，也能够按照你本身的须要来建立。

下面看一个更加完整的命令行参数：

-XX:StartFlightRecording:disk=true,filename=/tmp/customer.jfr,maxage=5h,settings=profile

上面的命令会建立一个最大age是5h的profile信息文件。

1. 使用jcmd

命令行添加参数仍是太麻烦了，若是咱们想动态添加JFR，则可使用jcmd命令。

jcmd <pid> JFR.start name=custProfile settings=default
jcmd <pid> JFR.dump filename=custProfile.jfr
jcmd <pid> JFR.stop

上面的命令在一个运行中的JVM中启动了JFR，并将统计结果dump到了文件中。

上面的custProfile.jfr是一个二进制文件，为了对其进行分析，咱们须要和JFR配套的工具JMC。

JMC

JDK Mission Control 是一个用于对 Java 应用程序进行管理、监视、概要分析和故障排除的工具套件。

在JDK14中，JMC是独立于JDK单独发行的。咱们能够下载以后进行安装。

咱们先启动一个程序，用于作JFR的测试。

@Slf4j
public class ThreadTest {

    public static void main(String[] args) {
        ExecutorService executorService= Executors.newFixedThreadPool(10);
        Runnable runnable= ()->{
            while(true){
                log.info(Thread.currentThread().getName());
                try {
                    Thread.sleep(500);
                } catch (InterruptedException e) {
                    log.error(e.getMessage(),e);
                }
            }
        };

        for(int i=0; i<10; i++){
            executorService.submit(runnable);
        }
    }
}

很简单的一个程序，启动了10个线程，咱们启动这个程序。

而后再去看看JMC的界面：

咱们能够看到在界面的左边已经能够看到运行在本机的ThreadTest程序了。

点击MBean服务器，能够看到该java程序的面板信息，里面包含CPU，堆栈信息。

在下面有7个tab分别是概览，MBean浏览器，触发器，系统，内存，线程，和诊断命令。

经过下面的tab咱们能够得到更加详细的java程序的信息，而且经过触发器和诊断命令，咱们还能够对目标java程序的JVM发送命令。

JMC很是强大，也有不少功能，具体的细节你们能够本身运行去体会。

由于本文主要是将JFR，下面咱们将讲解如何在JMC中建立JFR和分析JFR。

建立JFR

上面右侧的MBean服务器下就是飞行记录器了，也就是咱们的目标。

点击飞行记录器：

咱们就能够开始建立一个JFR了。

目标文件就是JFR的生成地址，名称能够本身随便起一个，记录时间表示须要记录多长时间范围以内的JFR。

点下一步：

这一步能够选择更加详细的JVM参数。

点下一步：

这里，咱们能够选择须要监控的Profile事件选项。能够按照你的须要进行选择。

最后点完成建立JFR。

分析JFR

上面咱们的JFR记录了1分钟的Profile，在1分钟以后，咱们能够看到目标JFR文件生成了。

生成完JFR以后，JMC会自动打开生成的JFR文件，咱们获得一个大纲视图。

里面包含java应用程序，JVM内部，环境和事件浏览器。

事件浏览器中列出了咱们在1分钟以内监控的事件。

JMC浏览器不只能够监控本机的应用程序，也能够监控远程的应用程序。因为JMC的链接是经过JMX协议，因此远程java程序须要开启JMX协议的支持。

JFR事件

JMC好用是好用，可是要一个一个的去监听JFR文件会很繁琐。接下来咱们来介绍一下怎么采用写代码的方式来监听JFR事件。

仍是上面的图，若是咱们想经过程序来获取“Class Loading Statistics"的信息，能够这样作。

上图的右侧是具体的信息，咱们能够看到主要包含三个字段：开始时间，Loaded Class Count和 Unloaded Class Count。

咱们的思路就是使用jdk.jfr.consumer.RecordingFile去读取生成的JFR文件，而后对文件中的数据进行解析。

相应代码以下：

@Slf4j
public class JFREvent {

    private static Predicate<RecordedEvent> testMaker(String s) {
        return e -> e.getEventType().getName().startsWith(s);
    }

    private static final Map<Predicate<RecordedEvent>,
            Function<RecordedEvent, Map<String, String>>> mappers =
            Map.of(testMaker("jdk.ClassLoadingStatistics"),
                    ev -> Map.of("start", ""+ ev.getStartTime(),
                            "Loaded Class Count",""+ ev.getLong("loadedClassCount"),
                            "Unloaded Class Count", ""+ ev.getLong("unloadedClassCount")
                    ));

    @Test
    public void readJFRFile() throws IOException {
        RecordingFile recordingFile = new RecordingFile(Paths.get("/Users/flydean/flight_recording_1401comflydeaneventstreamThreadTest21710.jfr"));
        while (recordingFile.hasMoreEvents()) {
            var event = recordingFile.readEvent();
            if (event != null) {
                var details = convertEvent(event);
                if (details == null) {
                    // details为空
                } else {
                    // 打印目标
                    log.info("{}",details);
                }
            }
        }
    }

    public Map<String, String> convertEvent(final RecordedEvent e) {
        for (var ent : mappers.entrySet()) {
            if (ent.getKey().test(e)) {
                return ent.getValue().apply(e);
            }
        }
        return null;
    }
}

注意，在convertEvent方法中，咱们将从文件中读取的Event转换成了map对象。

在构建map时，咱们先判断Event的名字是否是咱们所须要的jdk.ClassLoadingStatistics，而后将Event中其余的字段进行转换。最后输出。

运行结果：

{start=2020-04-29T02:18:41.770618136Z, Loaded Class Count=2861, Unloaded Class Count=0}
...

能够看到输出结果和界面上面是同样的。

JFR事件流

讲了这么多，终于到咱们今天要讲的内容了：JFR事件流。

上面的JFR事件中，咱们须要去读取JFR文件，进行分析。可是文件是死的，人是活的，每次分析都须要先生成JFR文件简直是太复杂了。是个程序员都不能容忍。

在JFR事件流中，咱们能够监听Event的变化，从而在程序中进行相应的处理。这样不须要生成JFR文件也能够监听事件变化。

public static void main(String[] args) throws IOException, ParseException {
        //default or profile 两个默认的profiling configuration files
        Configuration config = Configuration.getConfiguration("default");
        try (var es = new RecordingStream(config)) {
            es.onEvent("jdk.GarbageCollection", System.out::println);
            es.onEvent("jdk.CPULoad", System.out::println);
            es.onEvent("jdk.JVMInformation", System.out::println);
            es.setMaxAge(Duration.ofSeconds(10));
            es.start();
        }
    }

看看上面的例子。咱们经过Configuration.getConfiguration("default")获取到了默认的default配置。

而后经过构建了default的RecordingStream。经过onEvent
方法，咱们对相应的Event进行处理。

总结

本文讲解了JFR，JMC和JDK14的最新特性JFR event stream。但愿可以对你们在工做中有所帮助。

本文的例子https://github.com/ddean2009/learn-java-base-9-to-20

本文做者：flydean程序那些事

本文连接：http://www.flydean.com/jdk14-jfr-jmc-event-stream/

本文来源：flydean的博客

欢迎关注个人公众号:程序那些事，更多精彩等着您！