优化设备状态解析

CZT

2023-08-30 38ab8fbd4355070def9e3b39f362731dd4dea6d1

 igds-protocol-modbus/src/main/java/com/ld/igds/protocol/modbus/ModbusUtil2.java

@@ -10,9 +10,6 @@
import com.serotonin.modbus4j.locator.BaseLocator;
import com.serotonin.modbus4j.msg.*;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

import java.util.HashMap;

/**
 * @Desc: 工具类
@@ -25,13 +22,10 @@
    //从机默认值
    private static Integer slaveId = 1;

    private static HashMap<String, ModbusMaster> masterMap = new HashMap<>();

    /**
     * 工厂
     */
    static ModbusFactory modbusFactory;
    //static ModbusMaster modbusMaster;

    static {
        if (modbusFactory == null) {
@@ -46,22 +40,16 @@
     * @return
     */
    public static ModbusMaster getMaster(String ip, int port) throws ModbusInitException, InterruptedException {
        String key = ip;
        ModbusMaster modbusMaster = masterMap.get(key);
        if (modbusMaster == null || !modbusMaster.isConnected()) {
            IpParameters ipParameters = new IpParameters();
            ipParameters.setHost(ip);
            ipParameters.setPort(port);
            modbusMaster = modbusFactory.createTcpMaster(ipParameters, true);
            modbusMaster.init();

            //初始化之后等待，避免出现连接未创建
            Thread.sleep(2500);
        IpParameters ipParameters = new IpParameters();
        ipParameters.setHost(ip);
        ipParameters.setPort(port);
        ModbusMaster modbusMaster = modbusFactory.createTcpMaster(ipParameters, false);
        modbusMaster.init();

            masterMap.put(key, modbusMaster);
        //初始化之后等待，避免出现连接未创建
        Thread.sleep(3000);

            return modbusMaster;
        }
        return modbusMaster;
    }