如何在Java中向FFmpeg进程输入字符串实现优雅退出

Hey there! Let's fix that issue where you want to send the q\n command to FFmpeg for a graceful exit—just like typing it in the terminal. Your current code has a couple of key issues blocking this from working, so let's break it down and fix it step by step.

现有代码的核心问题 #

1. 提前关闭了FFmpeg的输入流：你在启动FFmpeg后立刻调用stdout.close();，直接切断了Java进程和FFmpeg之间的输入通道，后续根本没法发送命令给它。
2. 字符串比较方式错误：Java中用==比较字符串是对比对象引用，正确的做法是用"yes".equals(stopconv)，还能避免空指针风险。
3. 流关闭时机不合理：你在读取stderr的循环内部就关闭了流，会导致读取过程提前终止，没法完整处理FFmpeg的输出。

修改后的实现方案 #

下面是调整后的代码，核心是保留FFmpeg输入流的引用、修正线程安全问题，以及优化流的生命周期管理：

// 用线程安全的变量控制停止信号，避免线程可见性问题
private volatile boolean stopConversion = false;

private void jButton1ActionPerformed(java.awt.event.ActionEvent evt) {
    Thread thread = new Thread() {
        public void run() {
            BufferedReader errorReader = null;
            OutputStream ffmpegInput = null; // 保留FFmpeg输入流的引用，不要提前关闭
            Process ffmpegProcess = null;

            String ffmpegCommand = "ffmpeg " + overwrite + " -i " + "\"" + currentfilestring + "\"" + " " + stream + " " + test + " " + findsilence + " " + videocodec + " -b:v " + videoqual + " " + audiocodec + " -ac 2 -ab " + audioqual + " " + res + " " + aspectratio + " " + framerate + " " + "\"" + destdir + destfile + "\"";
            System.out.println(ffmpegCommand);

            try {
                // 启动FFmpeg进程
                ffmpegProcess = Runtime.getRuntime().exec(ffmpegCommand, null, new File(userDir));
                // 获取FFmpeg的输入流（我们要往这里写退出命令）和错误流（FFmpeg的输出在这里）
                ffmpegInput = ffmpegProcess.getOutputStream();
                InputStream stderr = ffmpegProcess.getErrorStream();
                InputStreamReader errorIsr = new InputStreamReader(stderr);
                errorReader = new BufferedReader(errorIsr);

                // 持续读取FFmpeg的错误输出
                String errorLine;
                while ((errorLine = errorReader.readLine()) != null) {
                    // 这里可以添加你的自定义处理，比如更新进度条、解析输出信息
                    System.out.println(errorLine);

                    // 检查是否需要触发退出
                    if (stopConversion) {
                        // 发送"q\n"命令，模拟终端输入q+回车
                        ffmpegInput.write("q\n".getBytes());
                        ffmpegInput.flush();
                        System.out.println("已向FFmpeg发送退出命令");
                        // 重置标记，避免重复发送
                        stopConversion = false;
                    }
                }

                // 等待FFmpeg优雅退出，获取退出状态码
                int exitCode = ffmpegProcess.waitFor();
                System.out.println("FFmpeg退出，状态码：" + exitCode);

            } catch (Exception e) {
                e.printStackTrace();
            } finally {
                // 统一清理资源，避免泄漏
                try {
                    if (errorReader != null) errorReader.close();
                    if (ffmpegInput != null) ffmpegInput.close();
                    if (ffmpegProcess != null) ffmpegProcess.destroy();
                } catch (IOException e) {
                    e.printStackTrace();
                }
                // 重置进度条
                jProgressBar1.setValue(0);
            }
        }
    };
    thread.start();
}

// 示例：停止按钮/菜单项的事件处理方法
private void stopConversionMenuItemActionPerformed(java.awt.event.ActionEvent evt) {
    stopConversion = true;
}

关键细节说明 #

• 线程安全的停止标记：用volatile boolean确保GUI线程设置的停止信号能被FFmpeg的工作线程立刻感知到，避免线程可见性问题。
• 保留输入流引用：直到进程结束后，才在finally块统一关闭FFmpeg的输入流，确保我们能随时发送命令。
• 优雅的资源清理：所有流和进程资源都放在finally块中关闭，避免异常情况下的资源泄漏。

这样修改后，当你点击停止菜单项时，Java就会向FFmpeg发送q命令，FFmpeg就会像在终端里输入q回车一样，优雅地停止处理任务啦。

内容的提问来源于stack exchange，提问作者jdauthre