lsh
2024-04-22 7c2e048de56976c6ee3757cebf414a0f5c8dcb58
src/main/java/com/zy/core/ServerBootstrap.java
@@ -3,10 +3,7 @@
import com.zy.core.cache.MessageQueue;
import com.zy.core.cache.SlaveConnection;
import com.zy.core.enums.SlaveType;
import com.zy.core.model.CrnSlave;
import com.zy.core.model.DevpSlave;
import com.zy.core.model.LedSlave;
import com.zy.core.model.RgvSlave;
import com.zy.core.model.*;
import com.zy.core.properties.SlaveProperties;
import com.zy.core.thread.*;
import lombok.extern.slf4j.Slf4j;
@@ -64,6 +61,11 @@
        for (Slave rgv : slaveProperties.getRgv()) {
            MessageQueue.init(SlaveType.Rgv, rgv);
        }
        // 初始化机械臂mq
        for (Slave ext : slaveProperties.getExt()) {
            MessageQueue.init(SlaveType.Ext, ext);
        }
//        // 初始化Led灯mq
//        for (Slave led : slaveProperties.getLed()) {
//            MessageQueue.init(SlaveType.Led, led);
@@ -107,6 +109,13 @@
            new Thread((Runnable) rgvThread).start();
            SlaveConnection.put(SlaveType.Rgv, rgv.getId(), rgvThread);
        }
        // 初始化机械臂线程
        log.info("初始化Ext线程...................................................");
        for (ExtSlave ext : slaveProperties.getExt()) {
            MelsecExtThread extThread = new MelsecExtThread(ext);
            new Thread(extThread).start();
            SlaveConnection.put(SlaveType.Ext, ext.getId(), extThread);
        }
//        // 初始化LED线程
//        log.info("初始化LED线程...................................................");
//        for (LedSlave led : slaveProperties.getLed()) {