配置文件增加自定义tcp重连间隔时间

‘liusuyi’

2024-03-12 8e0b2b23294ac1fdce43b9076b93e29e9aa51530

 src/main/java/com/ard/utils/netty/tcp/ClientInitialize.java

@@ -74,7 +74,7 @@
                                }

                            });

                        }

                        Thread.sleep(10000);

                        Thread.sleep(nettyTcpConfig.getReConnectInterval());

                    } catch (Exception e) {

                        log.error("Netty初始化配置监听地址出现异常");

                        e.printStackTrace();

@@ -135,18 +135,20 @@
    /**

     * 监测雷达连接状态

     */

    @Scheduled(cron = "0/5 * * * * ?")

    @Scheduled(cron = "0/3 * * * * ?")

    public void monitorConnectStatus() {

        log.debug("定时监测雷达连接状态");

        List<ArdEquipRadar> ardEquipRadars = ardEquipRadarService.selectArdEquipRadarList(new ArdEquipRadar());

        ardEquipRadars.stream().forEach(ardEquipRadar -> {

            if (trueConnectMap.contains(ardEquipRadar.getIp() + "_" + ardEquipRadar.getPort())) {

                if (ardEquipRadar.getState() != null && !ardEquipRadar.getState().equals("1")) {



            boolean online = trueConnectMap.containsKey(ardEquipRadar.getIp() + ":" + ardEquipRadar.getPort());

            if (online) {

                if (ardEquipRadar.getState() == null || !ardEquipRadar.getState().equals("1")) {

                    ardEquipRadar.setState("1");

                    ardEquipRadarService.updateArdEquipRadar(ardEquipRadar);

                }

            } else {

                if (ardEquipRadar.getState() == null || (ardEquipRadar.getState() != null && !ardEquipRadar.getState().equals("0"))) {

                if (ardEquipRadar.getState() == null || !ardEquipRadar.getState().equals("0")) {

                    ardEquipRadar.setState("0");

                    ardEquipRadarService.updateArdEquipRadar(ardEquipRadar);

                }