#

luxiaotao1123

2020-09-24 b17e2a3f2bd85d18630cb447d65368e430c887f8

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

@@ -6,6 +6,8 @@
import com.zy.core.model.CrnSlave;
import com.zy.core.model.DevpSlave;
import com.zy.core.properties.SlaveProperties;
import com.zy.core.thread.BarcodeThread;
import com.zy.core.thread.CarThread;
import com.zy.core.thread.CrnThread;
import com.zy.core.thread.DevpThread;
import lombok.extern.slf4j.Slf4j;
@@ -31,8 +33,9 @@

    @PostConstruct
    @Async
    public void init(){
    public void init() throws InterruptedException {
        log.info("核心控制层开始初始化...............................................");
        Thread.sleep(2000);
        // 初始化消息队列
        initMq();
        // 初始化下位机线程
@@ -63,6 +66,10 @@
        for (Slave scale : slaveProperties.getScale()) {
            MessageQueue.init(SlaveType.Scale, scale);
        }
        // 初始化台车mq
        for (Slave car : slaveProperties.getCar()) {
            MessageQueue.init(SlaveType.Car, car);
        }
    }

    private void initThread(){
@@ -82,12 +89,27 @@
            SlaveConnection.put(SlaveType.Devp, devp.getId(), devpThread);
        }

//        // 初始化条码扫描仪线程
//        for (Slave barcode : slaveProperties.getBarcode()) {
//            BarcodeThread barcodeThread = new BarcodeThread(barcode);
//            new Thread(barcodeThread).start();
//            SlaveConnection.put(SlaveType.Barcode, barcode.getId(), barcodeThread);
        // 初始化条码扫描仪线程
        log.info("初始化条码扫描仪线程...................................................");
        for (Slave barcode : slaveProperties.getBarcode()) {
            BarcodeThread barcodeThread = new BarcodeThread(barcode);
            new Thread(barcodeThread).start();
            SlaveConnection.put(SlaveType.Barcode, barcode.getId(), barcodeThread);
        }
        // 初始化LED线程
//        log.info("初始化LED线程...................................................");
//        for (LedSlave led : slaveProperties.getLed()) {
//            LedThread ledThread = new LedThread(led);
//            new Thread(ledThread).start();
//            SlaveConnection.put(SlaveType.Led, led.getId(), ledThread);
//        }
        // 初始化台车线程
        log.info("初始化台车线程...................................................");
        for (Slave car : slaveProperties.getCar()) {
            CarThread carThread = new CarThread(car);
            new Thread(carThread).start();
            SlaveConnection.put(SlaveType.Car, car.getId(), carThread);
        }
    }