999

zhangc

2025-04-19 bfc0d002ee31ceb7f74bd3ecd5008177ba31425b

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

@@ -7,7 +7,6 @@
import com.zy.core.enums.SlaveType;
import com.zy.core.model.*;
import com.zy.core.properties.SlaveProperties;
import com.zy.core.thread.*;
import com.zy.core.thread.impl.*;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
@@ -46,7 +45,7 @@
        News.info("核心控制层已启动...............................................");
    }

    private void initMq(){
    private void initMq() {
        // 初始化货叉提升机mq
        for (Slave forkLift : slaveProperties.getForkLift()) {
            MessageQueue.init(SlaveType.ForkLift, forkLift);
@@ -59,9 +58,13 @@
        for (Slave shuttle : slaveProperties.getShuttle()) {
            MessageQueue.init(SlaveType.Shuttle, shuttle);
        }
        // 初始化输送线mq
        for (Slave devp : slaveProperties.getDevp()) {
            MessageQueue.init(SlaveType.Devp, devp);
        }
    }

    private void initThread(){
    private void initThread() {
        // 初始化货叉提升机
        for (ForkLiftSlave forkLiftSlave : slaveProperties.getForkLift()) {
            News.info("初始化货叉提升机........................................................");
@@ -119,6 +122,26 @@
            new Thread(thread).start();
            SlaveConnection.put(SlaveType.Shuttle, shuttleSlave.getId(), thread);
        }
        // 初始化输送线
        for (DevpSlave devpSlave : slaveProperties.getDevp()) {
            News.info("初始化输送线......................................................");
            ThreadHandler thread = null;
            if (devpSlave.getThreadImpl().equals("FyDevpThread")) {
                thread = new FyDevpThread(devpSlave);
            } else {
                throw new CoolException("未知的线程实现");
            }
            new Thread(thread).start();
            SlaveConnection.put(SlaveType.Devp, devpSlave.getId(), thread);
        }

        // 初始化电视机
        for (LedSlave ledSlave : slaveProperties.getLed()) {
            News.info("初始化电视机......................................................");
            ThreadHandler thread = new NormalLedThread(ledSlave);
            new Thread(thread).start();
            SlaveConnection.put(SlaveType.Led, ledSlave.getId(), thread);
        }
    }