| | |
|---|
| | | import com.ruoyi.media.service.IMediaService; |
|---|
| | | import com.ruoyi.utils.forest.MediaClient; |
|---|
| | | import com.ruoyi.utils.tools.ArdTool; |
|---|
| | | import com.ruoyi.utils.tools.CmdUtils; |
|---|
| | | import com.sun.jna.Platform; |
|---|
| | | import io.minio.messages.Item; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | |
|---|
| | | |
|---|
| | | import javax.annotation.PostConstruct; |
|---|
| | | import javax.annotation.Resource; |
|---|
| | | import java.io.BufferedReader; |
|---|
| | | import java.io.File; |
|---|
| | | import java.io.IOException; |
|---|
| | | import java.io.InputStreamReader; |
|---|
| | | import java.util.ArrayList; |
|---|
| | | import java.util.List; |
|---|
| | | import java.util.regex.Matcher; |
|---|
| | |
|---|
| | | @Value("${mediamtx.host}") |
|---|
| | | String mediamtxHost; |
|---|
| | | |
|---|
| | | @Async |
|---|
| | | @PostConstruct |
|---|
| | | public void initMediaMtx() { |
|---|
| | | if (Platform.isWindows()) { |
|---|
| | | String processName="mediamtx.exe"; |
|---|
| | | String exePath = System.getProperty("user.dir") + File.separator + "lib" + File.separator + "mediamtx" + File.separator + "mediamtx.exe"; |
|---|
| | | try { |
|---|
| | | // 构建启动命令，使用cmd /c start命令来启动可执行程序并显示命令提示符窗口 |
|---|
| | | String[] cmd = {"cmd", "/c", "start", exePath}; |
|---|
| | | String ymlPath = System.getProperty("user.dir") + File.separator + "lib" + File.separator + "mediamtx" + File.separator + "mediamtx.yml"; |
|---|
| | | |
|---|
| | | ProcessBuilder processBuilder = new ProcessBuilder(cmd); |
|---|
| | | processBuilder.redirectErrorStream(true); // 将错误输出重定向到标准输出 |
|---|
| | | |
|---|
| | | Process process = processBuilder.start(); |
|---|
| | | |
|---|
| | | // 如果你想等待程序完成 |
|---|
| | | int exitCode = process.waitFor(); |
|---|
| | | System.out.println("程序退出代码: " + exitCode); |
|---|
| | | } catch (IOException | InterruptedException e) { |
|---|
| | | e.printStackTrace(); |
|---|
| | | List<String> cmd = new ArrayList<>(); |
|---|
| | | cmd.add(exePath); |
|---|
| | | cmd.add(ymlPath); |
|---|
| | | if (CmdUtils.isProcessRunning(processName)) { |
|---|
| | | // 进程已经在运行，结束该进程 |
|---|
| | | CmdUtils.stopProcess(processName); |
|---|
| | | } |
|---|
| | | // 启动后台进程 |
|---|
| | | CmdUtils.commandStart(processName,cmd); |
|---|
| | | // 启动cmd窗口 |
|---|
| | | // String[] command = {"cmd","/c","start",exePath,ymlPath}; |
|---|
| | | // CmdUtils.commandStart(command); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public String addPath(String name, String rtspPath, String mode) { |
|---|
| | | String rtspUrl = "rtsp://" + mediamtxHost + ":8554/"; |
|---|
| | | String rtspUrl = "rtsp://" + mediamtxHost + ":7554/"; |
|---|
| | | Conf mediaInfo = new Conf(); |
|---|
| | | //-vcodec libx264 //指定视频编码器为 libx264，使用 H.264 编码格式进行视频压缩 |
|---|
| | | //-preset ultrafast //--preset的参数主要调节编码速度和质量的平衡，有ultrafast（转码速度最快，视频往往也最模糊）、superfast、veryfast、faster、fast、medium、slow、slower、veryslow、placebo这10个选项，从快到慢 |
|---|
| | |
|---|
| | | String name = item.getName(); |
|---|
| | | info.setName(name); |
|---|
| | | //RTSP播放地址 |
|---|
| | | String rtspUrl = "rtsp://" + mediamtxHost + ":8554/" + name; |
|---|
| | | String rtspUrl = "rtsp://" + mediamtxHost + ":7554/" + name; |
|---|
| | | info.setRtspUrl(rtspUrl); |
|---|
| | | Source source = item.getSource(); |
|---|
| | | if (source == null) { |
|---|
