Класс RemoteRecordingStream

public RemoteRecordingStream(MBeanServerConnection connection) throws IOException

Параметры:

connection — MBeanServerConnection, в котором зарегистрирован FlightRecorderMXBean, не null

Исключения:

IOException — если не удаётся открыть поток, при попытке доступа к репозиторию возникает ошибка ввода-вывода или FlightRecorderMXBean

public RemoteRecordingStream(MBeanServerConnection connection, Path directory) throws IOException

Параметры:

connection — MBeanServerConnection, в котором зарегистрирован FlightRecorderMXBean, не null

directory — каталог для сохранения загруженных данных событий, не null

Исключения:

IOException — если не удаётся открыть поток, при попытке доступа к репозиторию возникает ошибка ввода-вывода или FlightRecorderMXBean

public void setSettings(Map<String,String> settings)

{
    

    String host = "com.example";
    int port = 4711;

    String url = "service:jmx:rmi:///jndi/rmi://" + host + ":" + port + "/jmxrmi";

    JMXServiceURL u = new JMXServiceURL(url);
    JMXConnector c = JMXConnectorFactory.connect(u);
    MBeanServerConnection conn = c.getMBeanServerConnection();

    try (final var rs = new RemoteRecordingStream(conn)) {
        rs.onMetadata(e -> {
            for (Configuration c : e.getConfigurations()) {
                if (c.getName().equals("default")) {
                    rs.setSettings(c.getSettings());
                }
            }
        });
        rs.onEvent(System.out::println);
        rs.start();
    }

Параметры:

settings — задаваемые настройки, не null

См. также:

• Recording.setSettings(Map)

public EventSettings disable(String name)

Параметры:

name — настройки события, не null

Возвращает:

настройку события для дальнейшей конфигурации, не null

public EventSettings enable(String name)

Параметры:

name — настройки события, не null

Возвращает:

настройку события для дальнейшей конфигурации, не null

См. также:

• EventType

public void setMaxAge(Duration maxAge)

Параметры:

maxAge — срок хранения данных или null, если он не ограничен

Исключения:

IllegalArgumentException — если maxAge отрицательно

IllegalStateException — если запись находится в состоянии CLOSED

public void setMaxSize(long maxSize)

Параметры:

maxSize — объём сохраняемых данных, 0, если он не ограничен

Исключения:

IllegalArgumentException — если maxSize отрицательно

IllegalStateException — если запись находится в состоянии CLOSED

public void onEvent(Consumer<RecordedEvent> action)

Переопределяет:

onEvent в интерфейсе EventStream

Параметры:

action — действие, выполняемое для каждого RecordedEvent, не null

См. также:

• EventStream.onEvent(Consumer)
• EventStream.onMetadata(Consumer)

public void onEvent(String eventName, Consumer<RecordedEvent> action)

Переопределяет:

onEvent в интерфейсе EventStream

Параметры:

eventName — имя события, не null

action — действие, выполняемое для каждого RecordedEvent, соответствующего имени события, не null

public void onFlush(Runnable action)

Переопределяет:

onFlush в интерфейсе EventStream

Параметры:

action — действие, выполняемое после сброса потока, не null

public void onError(Consumer<Throwable> action)

Переопределяет:

onError в интерфейсе EventStream

Параметры:

action — действие, выполняемое при возникновении исключения, не null

public void onClose(Runnable action)

Переопределяет:

onClose в интерфейсе EventStream

Параметры:

action — действие, выполняемое после закрытия потока, не null

См. также:

• EventStream.close()

public void close()

Переопределяет:

close в интерфейсе AutoCloseable

Переопределяет:

close в интерфейсе EventStream

public boolean remove(Object action)

Переопределяет:

remove в интерфейсе EventStream

Параметры:

action — действие, регистрацию которого нужно отменить, не null

Возвращает:

true, если регистрация действия отменена, иначе false

См. также:

• EventStream.onEvent(Consumer)
• EventStream.onEvent(String, Consumer)
• EventStream.onFlush(Runnable)
• EventStream.onClose(Runnable)
• EventStream.onError(Consumer)

public void setReuse(boolean reuse)

Переопределяет:

setReuse в интерфейсе EventStream

Параметры:

reuse — true, если объект события можно повторно использовать, иначе false

public void setOrdered(boolean ordered)

Переопределяет:

setOrdered в интерфейсе EventStream

Параметры:

ordered — указывает, поступают ли объекты событий в хронологическом порядке в EventStream.onEvent(Consumer)

public void setStartTime(Instant startTime)

Переопределяет:

setStartTime в интерфейсе EventStream

Параметры:

startTime — время начала, не null

См. также:

• EventStream.start()
• EventStream.startAsync()

public void setEndTime(Instant endTime)

Переопределяет:

setEndTime в интерфейсе EventStream

Параметры:

endTime — время окончания, не null

См. также:

• EventStream.start()
• EventStream.startAsync()

public void start()

Переопределяет:

start в интерфейсе EventStream

public void startAsync()

Переопределяет:

startAsync в интерфейсе EventStream

public boolean stop()

  AtomicLong bytesWritten = new AtomicLong();
  try (var r = new RemoteRecordingStream(connection)) {
    r.setMaxSize(Long.MAX_VALUE);
    r.enable("jdk.FileWrite").withoutThreshold();
    r.onEvent(event ->
      bytesWritten.addAndGet(event.getLong("bytesWritten"))
    );
    r.startAsync();
    testFoo();
    r.stop();
    if (bytesWritten.get() > 1_000_000L) {
      r.dump(Path.of("file-write-events.jfr"));
      throw new AssertionError("testFoo() writes too much data to disk");
    }
  }

Возвращает:

true, если запись остановлена, иначе false

Исключения:

IllegalStateException — если запись не запущена или уже остановлена

С версии:

20

public void dump(Path destination) throws IOException

Параметры:

destination — расположение для записи данных записи, не null

Исключения:

IOException — если данные записи не удаётся скопировать в указанное расположение, либо если поток закрыт или не запущен.

С версии:

17

См. также:

• setMaxAge(Duration)
• setMaxSize(long)

public void awaitTermination(Duration timeout) throws InterruptedException

Переопределяет:

awaitTermination в интерфейсе EventStream

Параметры:

timeout — максимальное время ожидания, не null

Исключения:

InterruptedException — если ожидание прервано

См. также:

• EventStream.start()
• EventStream.startAsync()
• Thread.interrupt()

public void awaitTermination() throws InterruptedException

Переопределяет:

awaitTermination в интерфейсе EventStream

Исключения:

InterruptedException — если ожидание прервано

См. также:

• EventStream.start()
• EventStream.startAsync()
• Thread.interrupt()