优化:修改未读消息入库前判断不存在则插入 取消：程序自动拉起redis/mediamtx/minio,中间件全部服务化 增加：流媒体vtdu详情接口

liusuyi

2024-07-24 f041323a2bce037843fcb163b017427baa556da3

 ard-work/src/main/java/com/ruoyi/cmd/startup.java

@@ -29,122 +29,122 @@
 **/

@Slf4j(topic = "cmd")

@Component

public class startup implements ApplicationContextInitializer {

public class startup{



    //minio

    String minioName = "minio.exe";

    @Value("${minio.accessKey}")

    String accessKey;

    @Value("${minio.secretKey}")

    String secretKey;

    @Value("${minio.path}")

    String path;

    @Value("${minio.enabled}")

    Boolean minioEnabled;



    //mediamtx

    String mediamtxName = "mediamtx.exe";

    @Value("${mediamtx.enabled}")

    Boolean mediamtxEnabled;

    //redis

    String redisName = "redis-server.exe";

//    //minio

//    String minioName = "minio.exe";

//    @Value("${minio.accessKey}")

//    String accessKey;

//    @Value("${minio.secretKey}")

//    String secretKey;

//    @Value("${minio.path}")

//    String path;

//    @Value("${minio.enabled}")

//    Boolean minioEnabled;

//

//    //mediamtx

//    String mediamtxName = "mediamtx.exe";

//    @Value("${mediamtx.enabled}")

//    Boolean mediamtxEnabled;

//    //redis

//    String redisName = "redis-server.exe";



    /**

     * 程序初始化启动redis

     * 刘苏义

     * 2023/9/22 10:38:41

     */

    @Override

    public void initialize(ConfigurableApplicationContext applicationContext) {

        if (Platform.isWindows()) {

            String workingDir = System.getProperty("user.dir") + File.separator + "server" + File.separator + "redis";

            String exePath = workingDir +File.separator+ redisName;

            List<String> cmd = new ArrayList<>();

            cmd.add(exePath);

            if (CmdUtils.isProcessRunning(redisName)) {

                // 进程已经在运行，结束该进程

                CmdUtils.stopProcess(redisName);

            }

            // 启动后台进程

            CmdUtils.commandStart(workingDir, redisName, cmd, null);

            // 启动cmd窗口

            //String[] command = {"cmd", "/c", "start", exePath, "-H127.0.0.1:8000", "-o"};

            //CmdUtils.commandStart(command);

        }

    }

//    @Override

//    public void initialize(ConfigurableApplicationContext applicationContext) {

//        if (Platform.isWindows()) {

//            String workingDir = System.getProperty("user.dir") + File.separator + "server" + File.separator + "redis";

//            String exePath = workingDir +File.separator+ redisName;

//            List<String> cmd = new ArrayList<>();

//            cmd.add(exePath);

//            if (CmdUtils.isProcessRunning(redisName)) {

//                // 进程已经在运行，结束该进程

//                CmdUtils.stopProcess(redisName);

//            }

//            // 启动后台进程

//            CmdUtils.commandStart(workingDir, redisName, cmd, null);

//            // 启动cmd窗口

//            //String[] command = {"cmd", "/c", "start", exePath, "-H127.0.0.1:8000", "-o"};

//            //CmdUtils.commandStart(command);

//        }

//    }



    @PostConstruct

    @Order(1)

    public void init() {

        if (minioEnabled) {

            log.info("初始化启动minio");

            if (Platform.isWindows()) {

                String workingDir = System.getProperty("user.dir") + File.separator + "server" + File.separator + "minio";

                String exePath = workingDir + File.separator + minioName;

                Map<String, String> env = new HashMap<>();

                env.put("MINIO_ROOT_USER", accessKey);

                env.put("MINIO_ROOT_PASSWORD", secretKey);

                List<String> cmd = new ArrayList<>();

                cmd.add(exePath);

                cmd.add("server");

                cmd.add(path);

                cmd.add("--console-address=0.0.0.0:9000");

                cmd.add("--address=0.0.0.0:9001");

                if (CmdUtils.isProcessRunning(minioName)) {

                    // 进程已经在运行，结束该进程

                    CmdUtils.stopProcess(minioName);

                }

                // 启动后台进程

                CmdUtils.commandStart(workingDir, minioName, cmd, env);

                // 启动cmd窗口

                //String[] command = {"cmd", "/c", "start", exePath};

                //CmdUtils.commandStart(command);

            }

        }

        if (mediamtxEnabled) {

            log.info("初始化启动mediaMTX");

            if (Platform.isWindows()) {

                String workingDir = System.getProperty("user.dir") + File.separator + "server" + File.separator + "mediamtx";

                String exePath = workingDir + File.separator + mediamtxName;

                String ymlPath = workingDir + File.separator + "mediamtx.yml";

                List<String> cmd = new ArrayList<>();

                cmd.add(exePath);

               // cmd.add(ymlPath);

                if (CmdUtils.isProcessRunning(mediamtxName)) {

                    // 进程已经在运行，结束该进程

                    CmdUtils.stopProcess(mediamtxName);

                }

                // 启动后台进程

                CmdUtils.commandStart(workingDir, mediamtxName, cmd, null);

                // 启动cmd窗口

                //String[] command = {"cmd","/c","start",exePath,ymlPath};

                //CmdUtils.commandStart(command);

            }

        }

    }



    @PreDestroy

    public void destroy() {

        if (minioEnabled) {

            log.info("销毁minio");

            if (CmdUtils.isProcessRunning(minioName)) {

                // 进程已经在运行，结束该进程

                CmdUtils.stopProcess(minioName);

            }

        }

        if (mediamtxEnabled) {

            log.info("销毁mediaMtx");

            if (CmdUtils.isProcessRunning(mediamtxName)) {

                // 进程已经在运行，结束该进程

                CmdUtils.stopProcess(mediamtxName);

            }

        }

        if (true) {

            log.info("销毁redis");

            if (CmdUtils.isProcessRunning(redisName)) {

                // 进程已经在运行，结束该进程

                CmdUtils.stopProcess(redisName);

            }

        }

    }

//    @PostConstruct

//    @Order(1)

//    public void init() {

//        if (minioEnabled) {

//            log.info("初始化启动minio");

//            if (Platform.isWindows()) {

//                String workingDir = System.getProperty("user.dir") + File.separator + "server" + File.separator + "minio";

//                String exePath = workingDir + File.separator + minioName;

//                Map<String, String> env = new HashMap<>();

//                env.put("MINIO_ROOT_USER", accessKey);

//                env.put("MINIO_ROOT_PASSWORD", secretKey);

//                List<String> cmd = new ArrayList<>();

//                cmd.add(exePath);

//                cmd.add("server");

//                cmd.add(path);

//                cmd.add("--console-address=0.0.0.0:9000");

//                cmd.add("--address=0.0.0.0:9001");

//                if (CmdUtils.isProcessRunning(minioName)) {

//                    // 进程已经在运行，结束该进程

//                    CmdUtils.stopProcess(minioName);

//                }

//                // 启动后台进程

//                CmdUtils.commandStart(workingDir, minioName, cmd, env);

//                // 启动cmd窗口

//                //String[] command = {"cmd", "/c", "start", exePath};

//                //CmdUtils.commandStart(command);

//            }

//        }

//        if (mediamtxEnabled) {

//            log.info("初始化启动mediaMTX");

//            if (Platform.isWindows()) {

//                String workingDir = System.getProperty("user.dir") + File.separator + "server" + File.separator + "mediamtx";

//                String exePath = workingDir + File.separator + mediamtxName;

//                String ymlPath = workingDir + File.separator + "mediamtx.yml";

//                List<String> cmd = new ArrayList<>();

//                cmd.add(exePath);

//               // cmd.add(ymlPath);

//                if (CmdUtils.isProcessRunning(mediamtxName)) {

//                    // 进程已经在运行，结束该进程

//                    CmdUtils.stopProcess(mediamtxName);

//                }

//                // 启动后台进程

//                CmdUtils.commandStart(workingDir, mediamtxName, cmd, null);

//                // 启动cmd窗口

//                //String[] command = {"cmd","/c","start",exePath,ymlPath};

//                //CmdUtils.commandStart(command);

//            }

//        }

//    }

//

//    @PreDestroy

//    public void destroy() {

//        if (minioEnabled) {

//            log.info("销毁minio");

//            if (CmdUtils.isProcessRunning(minioName)) {

//                // 进程已经在运行，结束该进程

//                CmdUtils.stopProcess(minioName);

//            }

//        }

//        if (mediamtxEnabled) {

//            log.info("销毁mediaMtx");

//            if (CmdUtils.isProcessRunning(mediamtxName)) {

//                // 进程已经在运行，结束该进程

//                CmdUtils.stopProcess(mediamtxName);

//            }

//        }

//        if (true) {

//            log.info("销毁redis");

//            if (CmdUtils.isProcessRunning(redisName)) {

//                // 进程已经在运行，结束该进程

//                CmdUtils.stopProcess(redisName);

//            }

//        }

//    }

}