Java JFR EventStream 怎么实时消费运行事件

排查线上 JVM 抖动时，很多人已经打开了 JFR，却发现自己的 Java 程序没有收到任何事件。问题通常不在事件回调，而在于把“产生记录”和“消费记录”混成了一件事。EventStream 是消费接口：它可以读取当前 JVM 的事件仓库，也可以打开已有的 JFR 文件；要持续实时观察，应该先保证目标 JVM 正在录制，再在流启动前注册监听。

先把 JFR 录制端和消费端分开

EventStream.openRepository() 创建的是当前 JVM 事件仓库的流，适合观察已经在运行的目标进程；openFile(Path) 则读取一个可信来源的记录文件。两者都不会替你开启录制。若目标 JVM 没有产生相应事件，回调自然不会被调用，这时先检查录制配置和事件名称，不要盲目给消费者加线程。

在启动前注册目标事件的回调

实时消费时，按事件名注册比接收全部事件后再用 Java 代码过滤更直接。下面的例子只关注 CPU 采样，并把启动、异常和关闭路径写在同一个资源边界里：

import jdk.jfr.consumer.EventStream;
import java.time.Duration;

try (EventStream stream = EventStream.openRepository()) {
    // 只订阅需要的事件，避免通用回调接收无关数据。
    stream.onEvent("jdk.CPULoad", event -> {
        double machine = event.getDouble("machineTotal");
        System.out.println("machine=" + machine);
    });
    // 记录消费异常，否则默认行为可能只把堆栈打到标准错误。
    stream.onError(error -> System.err.println("JFR consume failed: " + error));
    stream.onClose(() -> System.out.println("JFR stream closed"));
    // 异步处理在独立线程运行；生产代码要配套明确的停止条件。
    stream.startAsync();
    stream.awaitTermination(Duration.ofSeconds(10));
} // try-with-resources 负责关闭流，释放消费端资源。

回调必须在启动前注册。start() 会占用当前线程，startAsync() 则在单独线程中执行动作；选择哪一种，取决于消费者是否需要和主流程并行。

批次刷新决定了顺序和对象能否保存

EventStream 按批次交付事件。可以通过 onFlush 在一批处理完成后提交聚合结果，但不要把“跨批次全局严格有序”当成默认保证。需要按时间顺序接收时显式调用 setOrdered(true)；不关心顺序、只追求吞吐时可以关闭排序。

另一个容易踩坑的设置是 setReuse。默认情况下，同一个 RecordedEvent 对象可能被重复用于不同事件。如果回调只读取字段并立即计算，复用没有问题；如果要把对象放进队列或异步线程，先调用 setReuse(false)，让每个事件拥有独立对象。

异步流要设计完整的退出路径

close() 会停止流，但不保证调用返回前所有已注册动作都执行完。需要等待已消费事件完成时，可使用 awaitTermination(Duration)；若使用 RecordingStream，还可以用 stop() 等待记录中的事件被消费完。结束时间必须在启动前通过 setEndTime 设置，到达时间后流会自动关闭。

落地时可以按“数据源、事件名、启动方式、批次策略、退出策略”逐项记录。只要先确认录制端确实提供事件，再按这个顺序接入，EventStream 没有数据的问题通常很快就能定位。

常见问题

EventStream 能不能自动开始 JFR 录制？

不能。它负责消费事件；要同时创建并控制录制，应使用 RecordingStream 或其他 JFR 录制 API。

为什么异步回调里保存 RecordedEvent 后字段变了？

可能是事件对象被复用。需要跨回调保存时，在启动前设置 setReuse(false)，或者在回调内提取成自己的不可变数据。

为什么设置 setStartTime 后没有历史事件？

开始时间必须在启动前设置，而且流只能处理数据源中可用的记录；时间范围和目标仓库里实际存在的记录需要同时满足。