public class RtspFMp4ProxyTcpSync {

    public static void main(String[] args) {
        // rtsp адрес камеры
        URI uri = URI.create("rtsp://192.168.3.1:554/h264/ch1/main/av_stream");
        // идентификационная аутентификация
        UsernamePasswordCredential credential = new UsernamePasswordCredential("admin", "123456");
        DigestAuthenticator authenticator = new DigestAuthenticator(credential);
        // создать экземпляр клиента RTSP и использовать здесь режим связи TCP
        RtspClient client = new RtspClient(uri, authenticator, ERtspTransportProtocol.TCP);
        // создать прокси FMP4, здесь в синхронном режиме
        RtspFMp4Proxy proxy = new RtspFMp4Proxy(client);
        // установить событие приёма данных FMP4
        proxy.onFmp4DataHandle(x -> {
            // *****обработка данных*****
            System.out.println(x.length);
        });
        // устанавливает события данных формата кодека
        proxy.onCodecHandle(x -> {
            // *****обработка данных*****
            System.out.println(x);
        });
      proxy.onDestroyHandle(() -> System.out.println("close"));
        // закрыто асинхронно, написано перед запуском, потому что это тестовый пример
        CompletableFuture.runAsync(() -> {
            try {
                TimeUnit.SECONDS.sleep(5);
            } catch (InterruptedException e) {
                throw new RuntimeException(e);
            }
            proxy.stop();
        });
        // запуск, возврат асинхронного будущего
        CompletableFuture<Void> future = proxy.start();
        // цикл ожидания завершения
        while (!future.isDone()) {
            try {
                TimeUnit.SECONDS.sleep(1);
            } catch (InterruptedException e) {
                throw new RuntimeException(e);
            }
        }
    }
}