| | |
|---|
| | | |
|---|
| | | 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 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"; |
|---|
| | | // 构建启动命令，使用cmd /c start命令来启动可执行程序并显示命令提示符窗口 |
|---|
| | | // String[] cmd = {"cmd", "/c", "start", exePath,ymlPath}; |
|---|
| | | // ProcessBuilder processBuilder = new ProcessBuilder(cmd); |
|---|
| | | // processBuilder.redirectErrorStream(true); // 将错误输出重定向到标准输出 |
|---|
| | | // Process process = processBuilder.start(); |
|---|
| | | // 如果你想等待程序完成 |
|---|
| | | // int exitCode = process.waitFor(); |
|---|
| | | List<String> cmd = new ArrayList<>(); |
|---|
| | | cmd.add(exePath); |
|---|
| | | cmd.add(ymlPath); |
|---|
| | | commandStart(cmd); |
|---|
| | | |
|---|
| | | 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(); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | public static void commandStart(List<String> command) { |
|---|
| | | command.forEach(v -> System.out.print(v + " ")); |
|---|
| | | System.out.println(); |
|---|
| | | System.out.println(); |
|---|
| | | ProcessBuilder builder = new ProcessBuilder(); |
|---|
| | | //正常信息和错误信息合并输出 |
|---|
| | | builder.redirectErrorStream(true); |
|---|
| | | builder.command(command); |
|---|
| | | //开始执行命令 |
|---|
| | | Process process = null; |
|---|
| | | try { |
|---|
| | | process = builder.start(); |
|---|
| | | //如果你想获取到执行完后的信息，那么下面的代码也是需要的 |
|---|
| | | // String line = ""; |
|---|
| | | // BufferedReader br = new BufferedReader(new InputStreamReader(process.getInputStream())); |
|---|
| | | // while ((line = br.readLine()) != null) { |
|---|
| | | // System.out.println(line); |
|---|
| | | // } |
|---|
| | | } catch (IOException e) { |
|---|
| | | e.printStackTrace(); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | @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) { |
|---|
