Java 视频处理：基于 MD5 校验秒传及 ffmpeg 切片合并的实现

原创

Yeats_Liao

发布于 2025-01-09 10:17:45

4670

本文介绍两种网络技术实现方法。一是 MD5 校验秒传，服务器端用数据库记上传文件 MD5 值及存储路径，Java 代码接收客户端 MD5 值并查询校验，返回状态码。二是用 ffmpeg 切片视频成 m3u8 上传，异步合并文件实现视频按需加载。

1. 通过MD5校验实现秒传

服务器端MD5校验

数据库存储：服务器端需数据库（如 MySQL、MongoDB 等）记录上传文件 MD5 值及存储路径。以 MySQL 为例，创建简单表存储相关信息。表结构中，md5_value存文件 MD5 值，file_path存服务器端存储路径，upload_time记录文件上传时间。

CREATE TABLE uploaded_files (
    id INT AUTO_INCREMENT PRIMARY KEY,
    md5_value VARCHAR(32) NOT NULL UNIQUE,
    file_path VARCHAR(255) NOT NULL,
    upload_time TIMESTAMP DEFAULT CURRENT_TIMESTAMP
);

校验逻辑实现： Java服务器端代码示例：接收客户端 MD5 值并校验（用 Spring Boot 框架简化示例，实际应用可依具体框架和需求调整）。代码中接收客户端传来的 MD5 值在数据库查询校验。查到记录则文件已存在，返回 200 状态码表示秒传成功；未查到返回 404 表示需正常上传；查询出错返回 500 表示服务器内部错误。

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

@SpringBootApplication
@RestController
public class FileServerApp {

    private static final String JDBC_URL = "jdbc:mysql://localhost:3306/your_database_name?useSSL=false&serverTimezone=UTC";
    private static final String JDBC_USERNAME = "your_username";
    private static final String JDBC_PASSWORD = "your_password";

    public static void main(String[] args) {
        SpringApplication.run(FileServerApp.class, args);
    }

    @GetMapping("/checkFile")
    public ResponseEntity<String> checkFile(@RequestParam("md5") String md5) {
        try (Connection connection = DriverManager.getConnection(JDBC_URL, JDBC_USERNAME, JDBC_PASSWORD);
             PreparedStatement preparedStatement = connection.prepareStatement("SELECT file_path FROM uploaded_files WHERE md5_value =?")) {

            preparedStatement.setString(1, md5);
            ResultSet resultSet = preparedStatement.executeQuery();

            if (resultSet.next()) {
                // 文件已存在，返回200状态码
                return new ResponseEntity<>("文件已存在", HttpStatus.OK);
            } else {
                // 文件不存在，返回404状态码
                return new ResponseEntity<>("文件不存在", HttpStatus.NOT_FOUND);
            }
        } catch (SQLException e) {
            e.printStackTrace();
            // 数据库查询出错，返回500状态码
            return new ResponseEntity<>("服务器内部错误", HttpStatus.INTERNAL_SERVER_ERROR);
        }
    }
}

2. 用 ffmpeg 将视频切片成 m3u8 上传，采用异步合并文件实现视频按需加载

视频切割

参数调整：前面切割视频示例仅设常见参数，如视频编码格式（-c:v libx264）、音频编码格式（-c:a aac）、切片时长（-hls_time 10）和列表大小（-hls_list_size 0）。实际应用中或需依具体需求调整这些参数，比如： - 视频分辨率：要支持多种分辨率视频播放，可添加不同参数设置生成不同分辨率视频切片集合，在 m3u8 文件中组织，实现自适应分辨率播放。如添加-s:v 1280x720和-s:v 640x360等参数分别生成高清和标清视频切片。 - 码率设置：根据网络状况和目标设备性能，需设置不同视频码率，可通过参数如-b:v 2000k实现不同码率视频切片生成。
错误处理细化：仅依process.waitFor()返回值判断切割不足。实际应用中应获取ffmpeg执行输出信息定位问题。以下是修改后示例，读取ffmpeg标准输出和错误输出信息处理切割问题。

import java.io.BufferedReader;
import java.io.File;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.util.ArrayList;
import java.util.List;

public class VideoSliceUtil {
    public static void sliceVideo(File videoFile, String outputDir) {
        try {
            String ffmpegPath = "ffmpeg"; // 根据实际安装路径修改
            String command = ffmpegPath + " -i " + videoFile.getAbsolutePath() + " -c:v libx264 -c:a aac -f hls -hls_time 10 -hls_list_size 0 " + outputDir + "/video.m3u8";
            Process process = Runtime.getRuntime().exec(command);

            // 读取标准输出和标准错误输出信息
            InputStream stdout = process.getInputStream();
            InputStream stderr = process.getErrorStream();

            BufferedReader stdoutReader = new BufferedReader(new InputStreamReader(stdout));
            BufferedReader stderrReader = new BufferedReader(new InputStreamReader(stderr));

            List<String> stdoutMessages = new ArrayList<>();
            List<String> stderrMessages = new ArrayList<>();

            String line;
            while ((line = stdoutReader.readLine())!= null) {
                stdoutMessages.add(line);
            }
            while ((line = stderrReader.readLine())!= null) {
                stderrMessages.add(line);
            }

            int exitCode = process.waitFor();

            if (exitCode == 0) {
                System.out.println("视频切割成功");
                if (!stdoutMessages.isEmpty()) {
                    System.out.println("标准输出信息：");
                    for (String msg : stdoutMessages) {
                        System.out.println(msg);
                    }
                }
            } else {
                System.out.println("视频切割失败");
                if (!stderrMessages.isEmpty()) {
                    System.out.println("标准错误输出信息：");
                    for (String msg : stderrMessages) {
                        System.out.println(msg);
                    }
                }
            }

            // 关闭流
            stdoutReader.close();
            stderrReader.close();
            stdout.close();
            stderr.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

异步合并文件

具体合并逻辑实现：使用FFmpegFrameRecorder库合并视频片段。假设切割所得片段在指定目录且 m3u8 文件已正确生成。先创建FFmpegFrameRecorder对象，设置视频、音频编码格式及输出文件格式。遍历视频片段，用FrameGrabber读取帧，通过recorder记录到合并文件中。

import java.io.File;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

import org.bytedeco.ffmpeg.global.avcodec;
import org.bytedeco.ffmpeg.global.avutil;
import org.bytedeco.ffmpeg.global.swscale;
import org.bytedeco.javacv.FFmpegFrameRecorder;
import org.bytedeco.javacv.Frame;
import org.bytedeco.javacv.FrameGrabber;
import org.bytedeco.javacv.OpenCVFrameGrabber;

public class FileMergeAsync {
    public static void mergeFilesAsync(final File[] filesToMerge, final String outputFile) {
        ExecutorService executor = Executors.newSingleThreadExecutor();
        executor.submit(new Runnable() {
            @Override
            public void run() {
                try {
                    // 创建FFmpegFrameRecorder对象用于合并视频
                    FFmpegFrameRecorder recorder = new FFmpegFrameRecorder(outputFile, -1);
                    recorder.setVideoCodec(avcodec.AV_CODEC_ID_H264);
                    recorder.setAudioCodec(avutil.AV_CODEC_ID_AAC);
                    recorder.setFormat("mp4");
                    recorder.start();

                    // 遍历每个视频片段进行合并
                    for (File file : filesToMerge) {
                        FrameGrabber grabber = new OpenCVFrameGrabber(file);
                        grabber.start();

                        Frame frame;
                        while ((frame = grabber.read())!= null) {
                            recorder.record(frame);
                        }

                        grabber.stop();
                    }

                    recorder.stop();

                    System.out.println("文件合并成功");
                } catch (Exception e) {
                    e.printStackTrace();
                    System.out.println("文件合并失败");
                } finally {
                    executor.shutdown();
                }
            }
        });
    }
}

资源管理与优化：合并文件时涉及多个对象创建与使用，如FFmpegFrameRecorder、FrameGrabber等，需注意资源管理与优化。用后及时调用stop()释放资源，避免内存泄漏。对可能的异常，在异常处理代码中正确关闭和释放资源。
异步处理的监控与反馈：前面异步合并文件示例仅提交任务后打印成功或失败消息。实际应用中需对异步任务深入监控并提供更多反馈。可通过添加回调函数或用异步任务监控框架了解进度、异常等情况并反馈给相关方。

原创声明：本文系作者授权腾讯云开发者社区发表，未经许可，不得转载。

如有侵权，请联系 cloudcommunity@tencent.com 删除。

腾讯技术创作特训营S11#重启人生

原创声明：本文系作者授权腾讯云开发者社区发表，未经许可，不得转载。

如有侵权，请联系 cloudcommunity@tencent.com 删除。

腾讯技术创作特训营S11#重启人生

登录后参与评论

0 条评论

热度

Java 视频处理：基于 MD5 校验秒传及 ffmpeg 切片合并的实现

Java 视频处理：基于 MD5 校验秒传及 ffmpeg 切片合并的实现

1. 通过MD5校验实现秒传

服务器端MD5校验

2. 用 ffmpeg 将视频切片成 m3u8 上传，采用异步合并文件实现视频按需加载

视频切割

异步合并文件

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐