Java如何使用FFmpeg拉取RTSP流

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
 
public class FFmpegRTSPStreamer {
 
    public static void main(String[] args) {
        // RTSP source and destination URLs
        String rtspSourceUrl = "rtsp://your_source_ip:port/stream";
        String rtspDestinationUrl = "rtsp://your_destination_ip:port/stream";
 
        // FFmpeg command to pull RTSP stream and push to another RTSP server
        String ffmpegCommand = String.format(
                "ffmpeg -i %s -c copy -f rtsp %s",
                rtspSourceUrl, rtspDestinationUrl
        );
 
        // Create a ProcessBuilder to execute the FFmpeg command
        ProcessBuilder processBuilder = new ProcessBuilder(
                "bash", "-c", ffmpegCommand
        );
 
        // Redirect FFmpeg's stderr to the Java process's standard output
        processBuilder.redirectErrorStream(true);
 
        try {
            // Start the FFmpeg process
            Process process = processBuilder.start();
 
            // Create BufferedReader to read the output from FFmpeg process
            BufferedReader reader = new BufferedReader(new InputStreamReader(process.getInputStream()));
            String line;
            while ((line = reader.readLine()) != null) {
                System.out.println(line);
            }
 
            // Wait for the process to complete
            int exitCode = process.waitFor();
            System.out.println("\nFFmpeg process exited with code: " + exitCode);
 
        } catch (IOException | InterruptedException e) {
            e.printStackTrace();
        }
    }
}

import java.io.*;
import java.util.logging.*;
import java.util.concurrent.*;
 
public class FFmpegRTSPStreamer {
 
    private static final Logger logger = Logger.getLogger(FFmpegRTSPStreamer.class.getName());
 
    public static void main(String[] args) {
        // RTSP source and destination URLs
        String rtspSourceUrl = "rtsp://your_source_ip:port/path";
        String rtspDestinationUrl = "rtsp://your_destination_ip:port/path";
 
        // FFmpeg command to pull RTSP stream and push to another RTSP server
        // Note: Make sure ffmpeg is in your system's PATH or provide the full path to ffmpeg
        String ffmpegCommand = String.format(
                "ffmpeg -re -i %s -c copy -f rtsp %s",
                rtspSourceUrl, rtspDestinationUrl
        );
 
        // Use a thread pool to manage the FFmpeg process
        ExecutorService executorService = Executors.newSingleThreadExecutor();
        Future<?> future = executorService.submit(() -> {
            try {
                ProcessBuilder processBuilder = new ProcessBuilder("bash", "-c", ffmpegCommand);
                processBuilder.redirectErrorStream(true);
 
                Process process = processBuilder.start();
 
                // Read FFmpeg's output asynchronously
                BufferedReader reader = new BufferedReader(new InputStreamReader(process.getInputStream()));
                String line;
                while ((line = reader.readLine()) != null) {
                    logger.info(line);
                }
 
                // Wait for the process to complete
                int exitCode = process.waitFor();
                logger.info("FFmpeg process exited with code: " + exitCode);
 
            } catch (IOException | InterruptedException e) {
                logger.log(Level.SEVERE, "Error running FFmpeg process", e);
            }
        });
 
        // Optionally, add a timeout to the FFmpeg process
        // This will allow the program to terminate the FFmpeg process if it runs for too long
        ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);
        scheduler.schedule(() -> {
            if (!future.isDone()) {
                logger.warning("FFmpeg process timed out and will be terminated");
                future.cancel(true); // This will interrupt the thread running FFmpeg
                // Note: This won't actually kill the FFmpeg process, just the Java thread monitoring it.
                // To kill the FFmpeg process, you would need to find its PID and use `Process.destroy()` or an OS-specific command.
            }
        }, 60, TimeUnit.MINUTES); // Set the timeout duration as needed
 
        // Note: The above timeout mechanism is not perfect because `future.cancel(true)` only interrupts the Java thread.
        // To properly handle timeouts and killing the FFmpeg process, you would need to use a different approach,
        // such as running FFmpeg in a separate process group and sending a signal to that group.
 
        // In a real application, you would want to handle the shutdown of these ExecutorServices gracefully,
        // for example, by adding shutdown hooks or providing a way to stop the streaming via user input.
 
        // For simplicity, this example does not include such handling.
    }
}