#

Junjie

1 天以前 6c8ee211ae63de5f4ce0bd13b9c34f0524cd656f

 src/main/java/com/zy/core/ServerBootstrap.java

@@ -25,6 +25,8 @@
@Component
public class ServerBootstrap {

    private static boolean initThread = false;

    @Autowired
    private MainProcess mainProcess;
    @Autowired
@@ -34,6 +36,9 @@

    @Async
    public void init() throws InterruptedException {
        if (initThread) {
            return;
        }
        News.info("核心控制层开始初始化...............................................");
        clearStartupRuntimeLocks();
        // 初始化消息队列
@@ -42,11 +47,16 @@
        initThread();
        // 开始主流程进程
        mainProcess.start();
        initThread = true;
        News.info("核心控制层已启动...............................................");
    }

    private void clearStartupRuntimeLocks() {
        redisUtil.del(RedisKeyType.STATION_EXECUTE_COMMAND_LOCK.key);
        java.util.Set<String> stationSendLockKeys = redisUtil.scanKeys(RedisKeyType.STATION_EXECUTE_COMMAND_LOCK.key + ":", 2048);
        if (stationSendLockKeys != null && !stationSendLockKeys.isEmpty()) {
            redisUtil.del(stationSendLockKeys.toArray(new String[0]));
        }
//        News.info("系统启动时已清理输送站命令执行锁，key={}", RedisKeyType.STATION_EXECUTE_COMMAND_LOCK.key);
    }

@@ -142,8 +152,6 @@
                    thread = new ZyStationThread(deviceConfig, redisUtil);
                } else if (deviceConfig.getThreadImpl().equals("ZyStationV3Thread")) {
                    thread = new ZyStationV3Thread(deviceConfig, redisUtil);
                } else if (deviceConfig.getThreadImpl().equals("ZyStationV4Thread")) {
                    thread = new ZyStationV4Thread(deviceConfig, redisUtil);
                } else if (deviceConfig.getThreadImpl().equals("ZyStationV5Thread")) {
                    thread = new ZyStationV5Thread(deviceConfig, redisUtil);
                } else {