999

zhangc

2025-04-19 bfc0d002ee31ceb7f74bd3ecd5008177ba31425b

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

@@ -58,6 +58,10 @@
        for (Slave shuttle : slaveProperties.getShuttle()) {
            MessageQueue.init(SlaveType.Shuttle, shuttle);
        }
        // 初始化输送线mq
        for (Slave devp : slaveProperties.getDevp()) {
            MessageQueue.init(SlaveType.Devp, devp);
        }
    }

    private void initThread() {
@@ -127,23 +131,16 @@
            } else {
                throw new CoolException("未知的线程实现");
            }

            new Thread(thread).start();
            SlaveConnection.put(SlaveType.Shuttle, devpSlave.getId(), thread);
            SlaveConnection.put(SlaveType.Devp, devpSlave.getId(), thread);
        }

        // 初始化电视机
        for (LedSlave ledSlave : slaveProperties.getLed()) {
            News.info("初始化电视机......................................................");
            ThreadHandler thread = null;
            if (ledSlave.getThreadImpl().equals("NormalLedThread")) {
                thread = new NormalLedThread(ledSlave);
            } else {
                throw new CoolException("未知的线程实现");
            }

            ThreadHandler thread = new NormalLedThread(ledSlave);
            new Thread(thread).start();
            SlaveConnection.put(SlaveType.Shuttle, ledSlave.getId(), thread);
            SlaveConnection.put(SlaveType.Led, ledSlave.getId(), thread);
        }
    }