| | |
| | | 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 org.springframework.stereotype.Service; |
| | | |
| | | import javax.annotation.PostConstruct; |
| | | import javax.annotation.PreDestroy; |
| | | 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; |
| | |
| | | * @Version: 1.0 |
| | | **/ |
| | | @Service |
| | | @Slf4j |
| | | @Slf4j(topic = "cmd") |
| | | public class MediaService implements IMediaService { |
| | | |
| | | @Resource |
| | | MediaClient mediaClient; |
| | | @Value("${mediamtx.host}") |
| | | String mediamtxHost; |
| | | @Value("${mediamtx.enabled}") |
| | | Boolean mediamtxEnabled; |
| | | |
| | | @Async |
| | | String processName = "mediamtx.exe"; |
| | | |
| | | @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}; |
| | | if (mediamtxEnabled) { |
| | | if (Platform.isWindows()) { |
| | | String exePath = System.getProperty("user.dir") + File.separator + "lib" + File.separator + "mediamtx" + File.separator + "mediamtx.exe"; |
| | | 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, null); |
| | | // 启动cmd窗口 |
| | | // String[] command = {"cmd","/c","start",exePath,ymlPath}; |
| | | // CmdUtils.commandStart(command); |
| | | } |
| | | } |
| | | } |
| | | |
| | | @PreDestroy |
| | | public void destroyMediaMtx() { |
| | | log.info("销毁mediaMtx"); |
| | | if (CmdUtils.isProcessRunning(processName)) { |
| | | // 进程已经在运行,结束该进程 |
| | | CmdUtils.stopProcess(processName); |
| | | } |
| | | } |
| | | |
| | | @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) { |