Класс RemoteRecordingStream

Для настройки параметров событий используйте setSettings(Map).

Для настройки параметров событий используйте setSettings(Map).

Следующий пример подключается к удалённому хосту и получает потоки событий, используя настройки из конфигурации "default".

 {
     

     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();
     }

 
 

Если несколько событий имеют одно и то же имя (например, один и тот же класс загружен в разных загрузчиках классов), то отключаются все события, соответствующие имени.

Если несколько событий имеют одно и то же имя (например, один и тот же класс загружен в разных загрузчиках классов), то включаются все события, соответствующие имени.

Для управления объёмом данных записи, хранимых на диске, можно указать максимальную продолжительность хранения данных. Данные, хранящиеся на диске и более старые, чем указанная продолжительность, удаляются виртуальной машиной Java (JVM).

Если ни максимальный предел, ни максимальный возраст не установлены, размер записи может неограниченно расти, если события не обрабатываются.

Для управления объёмом данных записи, хранимых на диске, можно указать максимальный объём данных для хранения. Когда максимальный предел превышен, виртуальная машина Java (JVM) удаляет самый старый фрагмент, чтобы освободить место для более нового фрагмента.

Если ни максимальный предел, ни максимальный возраст не установлены, размер записи может неограниченно расти, если события не обрабатываются.

Размер измеряется в байтах.

Для выполнения действия над подмножеством типов событий, рассмотрите использование EventStream.onEvent(String, Consumer) и EventStream.onMetadata(Consumer), так как это, вероятно, более производительно, чем любая механизма выбора или фильтрации, реализованная в универсальном действии.

Если действие не зарегистрировано, стек исключения выводится на стандартный вывод ошибки.

Регистрация действия переопределяет поведение по умолчанию. Если зарегистрированы несколько действий, они выполняются в порядке регистрации.

Если этот метод сам вызывает исключение, поведение является неопределённым.

Если поток уже закрыт, действие будет выполнено немедленно в текущей нити.

Если поток запущен, асинхронно или синхронно, он останавливается немедленно или после следующего сброса. Этот метод НЕ гарантирует, что все зарегистрированные действия будут завершены до возврата.

Закрытие ранее закрытого потока не имеет эффекта.

Если действие было зарегистрировано несколько раз, все экземпляры будут отменены.

Если повторное использование установлено в true, действие не должно хранить ссылку на объект события после завершения действия.

Начальное время должно быть установлено перед запуском потока

Конечное время должно быть установлено перед запуском потока.

В момент конечного времени поток закрывается.

Действия выполняются в текущей нити.

Чтобы остановить поток, используйте метод EventStream.close().

Действия выполняются в отдельной нити.

Чтобы остановить поток, используйте метод EventStream.close().

Останавливает запущенный поток и ожидает, пока все события в записи будут обработаны.

Вызов этого метода в действии, например, в методе onEvent(Consumer), может заблокировать поток на неопределенное время. Чтобы резко остановить поток, используйте метод close().

Следующий фрагмент кода демонстрирует, как этот метод может быть использован совместно с методом startAsync() для отслеживания того, что происходит во время метода тестирования:

  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");
    }
  }

Поток записи должен быть запущен, но не закрыт.

Настоятельно рекомендуется установить максимальный возраст или максимальный размер перед запуском потока. В противном случае дамп может не содержать никаких событий.