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.    }}