#

luxiaotao1123

2022-03-14 412c5291467a5812af769156912dca6024abc8f1

 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(){
@@ -77,6 +82,13 @@
            CrnThread crnThread = new MelsecCrnThread(crn);
            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("初始化输送线线程...................................................");
@@ -100,12 +112,12 @@
            SlaveConnection.put(SlaveType.Led, led.getId(), ledThread);
        }
        // 初始化磅秤线程
        log.info("初始化磅秤线程...................................................");
        for (Slave scale : slaveProperties.getScale()) {
            ScaleThread barcodeThread = new ScaleThread(scale);
            new Thread(barcodeThread).start();
            SlaveConnection.put(SlaveType.Scale, scale.getId(), barcodeThread);
        }
//        log.info("初始化磅秤线程...................................................");
//        for (Slave scale : slaveProperties.getScale()) {
//            ScaleThread barcodeThread = new ScaleThread(scale);
//            new Thread(barcodeThread).start();
//            SlaveConnection.put(SlaveType.Scale, scale.getId(), barcodeThread);
//        }
    }