#

luxiaotao1123

2022-03-03 7d2c445d4d27bf6a16eed7634e3b5eb1212620eb

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

@@ -6,6 +6,7 @@
import com.zy.core.model.CrnSlave;
import com.zy.core.model.DevpSlave;
import com.zy.core.model.LedSlave;
import com.zy.core.model.SteSlave;
import com.zy.core.properties.SlaveProperties;
import com.zy.core.thread.*;
import lombok.extern.slf4j.Slf4j;
@@ -68,6 +69,10 @@
        for (Slave car : slaveProperties.getCar()) {
            MessageQueue.init(SlaveType.Car, car);
        }
        // 初始化穿梭车mq
        for (Slave ste : slaveProperties.getSte()) {
            MessageQueue.init(SlaveType.Ste, ste);
        }
    }

    private void initThread(){
@@ -78,6 +83,13 @@
            new Thread((Runnable) crnThread).start();
            SlaveConnection.put(SlaveType.Crn, crn.getId(), crnThread);
        }
        // 初始化穿梭车线程
        log.info("初始化穿梭车线程...................................................");
        for (SteSlave crn : slaveProperties.getSte()) {
            SteThread steThread = new SteThread(crn);
            new Thread((Runnable) steThread).start();
            SlaveConnection.put(SlaveType.Ste, crn.getId(), steThread);
        }
        // 初始化输送线线程
        log.info("初始化输送线线程...................................................");
        for (DevpSlave devp : slaveProperties.getDevp()) {