From 552bf0af0a1bc72d02ef1698a78646bdbee663ee Mon Sep 17 00:00:00 2001 From: chenyouting <514333061@qq.com> Date: Sat, 7 Feb 2026 09:42:16 +0800 Subject: [PATCH] =?UTF-8?q?hby100japp=E5=8A=9F=E8=83=BD,=E8=AF=AD=E9=9F=B3?= =?UTF-8?q?=E9=9F=B3=E9=87=8F=E5=A2=9E=E5=8A=A02?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../app/service/AudioProcessService.java | 13 ++- .../global/mqtt/utils/FfmpegVolumeUtil.java | 84 ++++++++++++++--- .../global/mqtt/utils/FfmpegVolumeUtil3.java | 92 +++++++++++++++++++ 3 files changed, 171 insertions(+), 18 deletions(-) create mode 100644 fys-admin/src/main/java/com/fuyuanshen/global/mqtt/utils/FfmpegVolumeUtil3.java diff --git a/fys-admin/src/main/java/com/fuyuanshen/app/service/AudioProcessService.java b/fys-admin/src/main/java/com/fuyuanshen/app/service/AudioProcessService.java index 9309bf06..81768f0c 100644 --- a/fys-admin/src/main/java/com/fuyuanshen/app/service/AudioProcessService.java +++ b/fys-admin/src/main/java/com/fuyuanshen/app/service/AudioProcessService.java @@ -15,6 +15,7 @@ import com.fuyuanshen.equipment.utils.AudioProcessUtil; import com.fuyuanshen.equipment.utils.FileHashUtil; import com.fuyuanshen.equipment.utils.Mp3Duration; import com.fuyuanshen.global.mqtt.utils.FfmpegVolumeUtil; +import com.fuyuanshen.global.mqtt.utils.FfmpegVolumeUtil3; import com.fuyuanshen.system.domain.vo.SysOssVo; import com.fuyuanshen.system.service.ISysOssService; import lombok.RequiredArgsConstructor; @@ -31,7 +32,6 @@ import javax.xml.stream.XMLStreamException; import javax.xml.stream.XMLStreamReader; import java.io.*; import java.nio.charset.StandardCharsets; -import java.nio.file.Files; import java.time.LocalDateTime; import java.time.format.DateTimeFormatter; import java.util.Arrays; @@ -182,7 +182,7 @@ public class AudioProcessService { private String saveByteArrayToFile(byte[] data, String filename) throws IOException { // 确定保存路径（可以是临时目录或指定目录） - String directory = System.getProperty("java.io.tmpdir"); // 使用系统临时目录 + String directory = System.getProperty("java.io.tmpdir");// 使用系统临时目录 File dir = new File(directory); if (!dir.exists()) { dir.mkdirs(); @@ -469,10 +469,12 @@ public class AudioProcessService { appBusinessFileBo.setDuration(mp3Duration); String directory = System.getProperty("java.io.tmpdir"); // 使用系统临时目录 - File file = new File(directory, generateRandomFileName(fileSuffix)); - savedMp3VolumePath = file.getAbsolutePath(); + String fileName = generateRandomFileName(fileSuffix); + savedMp3VolumePath = directory + "/" + fileName; + log.info("保存MP3文件: {}", savedMp3VolumePath); FfmpegVolumeUtil.increaseMp3Volume(savedPath, savedMp3VolumePath, 12); + File file = new File(savedMp3VolumePath); String fileHash = fileHashUtil.getFileHash(file,"SHA-256"); SysOssVo upload = ossService.updateHash(file, fileHash); @@ -492,11 +494,12 @@ public class AudioProcessService { } catch (Exception e){ log.error("上传音频文件失败", e); } finally { - log.info("删除临时文件: {}", savedPath); + log.info("删除savedPath临时文件: {}", savedPath); if(savedPath != null){ deleteTempFile(new File(savedPath)); } if(savedMp3VolumePath != null){ + log.info("删除savedMp3VolumePath临时文件: {}", savedMp3VolumePath); deleteTempFile(new File(savedMp3VolumePath)); } } diff --git a/fys-admin/src/main/java/com/fuyuanshen/global/mqtt/utils/FfmpegVolumeUtil.java b/fys-admin/src/main/java/com/fuyuanshen/global/mqtt/utils/FfmpegVolumeUtil.java index 7dff8069..2e7b5e65 100644 --- a/fys-admin/src/main/java/com/fuyuanshen/global/mqtt/utils/FfmpegVolumeUtil.java +++ b/fys-admin/src/main/java/com/fuyuanshen/global/mqtt/utils/FfmpegVolumeUtil.java @@ -1,6 +1,7 @@ package com.fuyuanshen.global.mqtt.utils; import java.io.BufferedReader; +import java.io.File; import java.io.IOException; import java.io.InputStreamReader; @@ -19,11 +20,33 @@ public class FfmpegVolumeUtil { System.err.println("FFmpeg未安装或未找到！请安装FFmpeg并确保在系统路径中。"); return; } + + // 检查输入文件 + File inputFile = new File(inputFilePath); + if (!inputFile.exists()) { + System.err.println("输入文件不存在：" + inputFilePath); + return; + } + if (!inputFile.canRead()) { + System.err.println("输入文件不可读：" + inputFilePath); + return; + } + + // 创建输出目录 + File outputFile = new File(outputFilePath); + File parentDir = outputFile.getParentFile(); + if (parentDir != null) { + parentDir.mkdirs(); + if (!parentDir.canWrite()) { + System.err.println("输出目录不可写：" + parentDir.getAbsolutePath()); + return; + } + } + Process process = null; try { - // 构建FFmpeg命令 String command = String.format( - "ffmpeg -i \"%s\" -af \"volume=%sdB\" \"%s\"", + "ffmpeg -y -i \"%s\" -af \"volume=%sdB\" \"%s\"", inputFilePath, volumeGain, outputFilePath @@ -31,37 +54,72 @@ public class FfmpegVolumeUtil { System.out.println("执行命令: " + command); - // 执行FFmpeg命令 - process = Runtime.getRuntime().exec(command); + // 使用 ProcessBuilder 提供更好的控制 + ProcessBuilder processBuilder = new ProcessBuilder("ffmpeg", "-y", + "-i", inputFilePath, "-af", "volume=" + volumeGain + "dB", outputFilePath); + processBuilder.redirectErrorStream(false); + process = processBuilder.start(); - // 读取命令执行结果 - BufferedReader reader = new BufferedReader(new InputStreamReader(process.getInputStream())); - String line; - while ((line = reader.readLine()) != null) { - System.out.println(line); - } + // 同时读取标准输出和错误输出 + Process finalProcess = process; + Thread stdOutThread = new Thread(() -> { + try (BufferedReader reader = new BufferedReader( + new InputStreamReader(finalProcess.getInputStream()))) { + String line; + while ((line = reader.readLine()) != null) { + System.out.println("[FFmpeg STDOUT] " + line); + } + } catch (IOException e) { + System.err.println("读取标准输出时出错: " + e.getMessage()); + }finally { + finalProcess.destroy(); + } + }); + + Process finalProcess1 = process; + Thread stdErrThread = new Thread(() -> { + try (BufferedReader reader = new BufferedReader( + new InputStreamReader(finalProcess1.getErrorStream()))) { + String line; + while ((line = reader.readLine()) != null) { + System.err.println("[FFmpeg STDERR] " + line); + } + } catch (IOException e) { + System.err.println("读取错误输出时出错: " + e.getMessage()); + }finally { + finalProcess1.destroy(); + } + }); + + stdOutThread.start(); + stdErrThread.start(); - // 等待命令执行完成 int exitCode = process.waitFor(); + stdOutThread.join(); + stdErrThread.join(); + if (exitCode == 0) { System.out.println("音量调整成功！输出文件：" + outputFilePath); } else { System.err.println("FFmpeg命令执行失败，退出码：" + exitCode); } } catch (IOException | InterruptedException e) { + System.err.println("执行FFmpeg命令时发生错误: " + e.getMessage()); e.printStackTrace(); } finally { if (process != null) { + System.out.println("已销毁进程"); process.destroy(); } } } + public static void main(String[] args) { // 示例用法 - String inputPath = "D:\\http_output9.mp3"; - String outputPath = "D:\\output17.mp3"; + String inputPath = "/app/input.mp3"; + String outputPath = "/app/output17.mp3"; int volumeGain = 12; increaseMp3Volume(inputPath, outputPath, volumeGain); diff --git a/fys-admin/src/main/java/com/fuyuanshen/global/mqtt/utils/FfmpegVolumeUtil3.java b/fys-admin/src/main/java/com/fuyuanshen/global/mqtt/utils/FfmpegVolumeUtil3.java new file mode 100644 index 00000000..1ef0126d --- /dev/null +++ b/fys-admin/src/main/java/com/fuyuanshen/global/mqtt/utils/FfmpegVolumeUtil3.java @@ -0,0 +1,92 @@ +package com.fuyuanshen.global.mqtt.utils; + +import java.io.BufferedReader; +import java.io.File; +import java.io.IOException; +import java.io.InputStreamReader; + +public class FfmpegVolumeUtil3 { + + /** + * 使用FFmpeg增加MP3文件的音量 + * + * @param inputFilePath 输入MP3文件路径 + * @param outputFilePath 输出MP3文件路径 + * @param volumeGain 音量增益（例如：1.5表示增加50%音量，2.0表示翻倍） + */ + public static void increaseMp3Volume(String inputFilePath, String outputFilePath, int volumeGain) { + boolean ffmpegAvailable = isFfmpegAvailable(); + if (!ffmpegAvailable) { + System.err.println("FFmpeg未安装或未找到！请安装FFmpeg并确保在系统路径中。"); + return; + } + // 创建输出文件的父目录 + File outputFile = new File(outputFilePath); + File parentDir = outputFile.getParentFile(); + if (parentDir != null && !parentDir.exists()) { + boolean created = parentDir.mkdirs(); + if (!created) { + System.err.println("无法创建输出目录：" + parentDir.getAbsolutePath()); + return; + } + } + Process process = null; + try { + // 构建FFmpeg命令 + String command = String.format( + "ffmpeg -y -i \"%s\" -af \"volume=%sdB\" \"%s\"", + inputFilePath, + volumeGain, + outputFilePath + ); + + System.out.println("执行命令: " + command); + + // 执行FFmpeg命令 + process = Runtime.getRuntime().exec(command); + + // 读取命令执行结果 + BufferedReader reader = new BufferedReader(new InputStreamReader(process.getInputStream())); + String line; + while ((line = reader.readLine()) != null) { + System.out.println(line); + } + + // 等待命令执行完成 + int exitCode = process.waitFor(); + if (exitCode == 0) { + System.out.println("音量调整成功！输出文件：" + outputFilePath); + } else { + System.err.println("FFmpeg命令执行失败，退出码：" + exitCode); + } + } catch (IOException | InterruptedException e) { + e.printStackTrace(); + } finally { + if (process != null) { + process.destroy(); + } + } + } + + public static void main(String[] args) { + + // 示例用法 + String inputPath = "/app/input.mp3"; + String outputPath = "/app/output18.mp3"; + int volumeGain = 12; + + increaseMp3Volume(inputPath, outputPath, volumeGain); + } + + private static boolean isFfmpegAvailable() { + try { + Process process = Runtime.getRuntime().exec("ffmpeg -version"); + int exitCode = process.waitFor(); + return exitCode == 0; + } catch (Exception e) { + return false; + } + } + +} +