一、概要

        执行FFmpeg必须是服务程序和FFmpeg在同一个环境内,可以相互调用,如果是docker部署也是需要在容器中安装FFmpeg,或者可以使用ssh方式远程执行!

二、工具类


import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.io.*;
import java.util.concurrent.TimeUnit;

/**
 * 执行FFmpeg命令工具类
 */
public class FfmpegUtil {

    private static final Logger logger = LoggerFactory.getLogger(FfmpegUtil.class);

    // 命令执行超时时间(秒)
    private static final int timeout = 300;

    /**
     * 执行FFmpeg命令
     */
    public static boolean execCmd(String[] cmd) {
        return execCmd(cmd, null);
    }

    /**
     * 执行FFmpeg命令(带输出处理)
     */
    public static boolean execCmd(String[] cmd, OutputHandler outputHandler) {
        ProcessBuilder processBuilder = new ProcessBuilder(cmd);
        // 合并标准错误和标准输出
        processBuilder.redirectErrorStream(true);

        try {
            Process process = processBuilder.start();

            // 处理输出流
            if (outputHandler != null) {
                handleOutput(process, outputHandler);
            }

            // 等待进程完成
            boolean finished = process.waitFor(timeout, TimeUnit.SECONDS);
            if (!finished) {
                process.destroyForcibly();
                logger.error("FFmpeg命令执行超时: {}", String.join(" ", cmd));
                return false;
            }

            int exitValue = process.exitValue();
            if (exitValue == 0) {
                logger.info("FFmpeg命令执行成功: {}", String.join(" ", cmd));
                return true;
            } else {
                logger.error("FFmpeg命令执行失败,退出码: {}, 命令: {}", exitValue, String.join(" ", cmd));
                return false;
            }

        } catch (IOException | InterruptedException e) {
            logger.error("FFmpeg命令执行异常: {}", e.getMessage(), e);
            return false;
        }
    }

    /**
     * 处理输出流
     */
    private static void handleOutput(Process process, OutputHandler outputHandler) {
        try (BufferedReader reader = new BufferedReader(new InputStreamReader(process.getInputStream()))) {
            String line;
            while ((line = reader.readLine()) != null) {
                outputHandler.handle(line);
            }
        } catch (IOException e) {
            logger.error("处理FFmpeg输出流异常: {}", e.getMessage());
        }
    }

    /**
     * 输出处理器接口
     */
    public interface OutputHandler {
        void handle(String line);
    }

}

三、测试类


import org.junit.jupiter.api.Test;
import org.springframework.boot.test.context.SpringBootTest;

/**
 * FFMPEG测试
 */
@SpringBootTest
public class FfmpegUtilTests {

    @Test
    void test() {
        // 不带输出处理
        boolean b = FfmpegUtil.execCmd(new String[]{"/opt/homebrew/bin/ffmpeg", "-version"});
        System.out.println(b);

        // 带输出处理信息
        FfmpegUtil.execCmd(new String[]{"/opt/homebrew/bin/ffmpeg", "-version"}, new FfmpegUtil.OutputHandler() {
            @Override
            public void handle(String line) {
                System.out.println( line);
            }
        });
    }
}

注意:ffmpeg的位置是需要指定的

Logo

火山引擎开发者社区是火山引擎打造的AI技术生态平台,聚焦Agent与大模型开发,提供豆包系列模型(图像/视频/视觉)、智能分析与会话工具,并配套评测集、动手实验室及行业案例库。社区通过技术沙龙、挑战赛等活动促进开发者成长,新用户可领50万Tokens权益,助力构建智能应用。

更多推荐