Modbus TCP读取寄存器数据

今天药忘吃喽~ 2022-05-08 08:48 573阅读 0赞

## modbus4j读取寄存器数据 ##

**ModbusReadUtil读取工具类**

package cn.sync.modbus;
    
    import org.apache.log4j.Logger;
    
    import com.serotonin.modbus4j.BatchRead;
    import com.serotonin.modbus4j.BatchResults;
    import com.serotonin.modbus4j.ModbusFactory;
    import com.serotonin.modbus4j.ModbusMaster;
    import com.serotonin.modbus4j.code.DataType;
    import com.serotonin.modbus4j.exception.ErrorResponseException;
    import com.serotonin.modbus4j.exception.ModbusInitException;
    import com.serotonin.modbus4j.exception.ModbusTransportException;
    import com.serotonin.modbus4j.ip.IpParameters;
    import com.serotonin.modbus4j.locator.BaseLocator;
    
    /**
     * 
     * Modbus TCP协议读取数据
     * @author zyl
     *
     */
    public class ModbusReadUtil {
        
    	private static Logger logger = Logger.getLogger(ModbusReadUtil.class);
    	
    	/**
    	 * 单列工厂。
    	 */
    	static ModbusFactory modbusFactory;
    	static {
    		if (modbusFactory == null) {
    			modbusFactory = new ModbusFactory();
    		}
    	}
    	
    	/**
    	 * 获取master 
    	 * @param host  IP地址
    	 * @param port  端口号
    	 * @return
    	 * @throws ModbusInitException
    	 */
    	public static ModbusMaster getMaster(String host,int port) throws ModbusInitException {
    		try {
    			IpParameters params = new IpParameters();
    			params.setHost(host);
    			params.setPort(port);
    			ModbusMaster master = modbusFactory.createTcpMaster(params, false);// TCP 协议
    			master.init();  //master初始化
    			return master;
    		} catch (Exception e) {
    			logger.error("获取master出现异常"+e);
    			e.printStackTrace();
    		}
             return null;
    	}
    	
    	
    	/**
    	 * 读取[03 Holding Register类型 2x]模拟量数据
    	 * @param master ModbusMaster对象
    	 * @param slaveId  
    	 *            slave Id  设备ID
    	 * @param offset
    	 *            偏移截止位置
    	 * @param dataType
    	 *            数据类型,来自com.serotonin.modbus4j.code.DataType
    	 * @return
    	 * @throws ModbusTransportException
    	 *             异常
    	 * @throws ErrorResponseException
    	 *             异常
    	 * @throws ModbusInitException
    	 *             异常
    	 */
    	public static Number readHoldingRegister(ModbusMaster master,int slaveId, int offset, int dataType)
    			throws ModbusTransportException, ErrorResponseException, ModbusInitException {
    		// 03 Holding Register类型数据读取
    		BaseLocator<Number> loc = BaseLocator.holdingRegister(slaveId, offset, dataType);
    		System.out.println("loc:"+loc);
    		Number value =master.getValue(loc);
    		System.out.println();
    		return value;
       }
    	
       
    	/**
    	 * 批量读取使用寄存器数据
    	 * @param  master ModbusMaster对象
    	 * @param batchRead   批量读取集合
    	 * @throws ModbusTransportException
    	 * @throws ErrorResponseException
    	 * @throws ModbusInitException
    	 */
    	public static BatchResults<Integer> batchRead(ModbusMaster master,BatchRead<Integer> batchRead)throws Exception {
    		try {
    			batchRead.setContiguousRequests(false);
    			BatchResults<Integer> results = master.send(batchRead);
    			return results;
    		} catch (Exception e) {
    			logger.error("批量读取使用寄存器数据出现异常"+e);
    			e.printStackTrace();
    		}
    		return null;
    		
    	}
    	
    	//测试
    	public static void main(String[] args) {
    		try {
    			ModbusMaster master=getMaster("127.0.0.1",502);
    			 BatchRead<Integer> batch = new BatchRead<Integer>();
    
    				batch.addLocator(0, BaseLocator.holdingRegister(1,1002, DataType.FOUR_BYTE_FLOAT_SWAPPED));
    				batch.addLocator(1, BaseLocator.holdingRegister(1,1004, DataType.FOUR_BYTE_FLOAT_SWAPPED));
    				batch.addLocator(2, BaseLocator.holdingRegister(1,1006, DataType.FOUR_BYTE_FLOAT_SWAPPED));
    				batch.addLocator(3, BaseLocator.holdingRegister(1,1008, DataType.FOUR_BYTE_FLOAT_SWAPPED));
    				
    				BatchResults<Integer> batchRead=batchRead(master,batch);
    				System.out.println(batchRead.getValue(0));
    				System.out.println(batchRead.getValue(1));
    				System.out.println(batchRead.getValue(2));
    				System.out.println(batchRead.getValue(3));
    				//DataType.FOUR_BYTE_FLOAT_SWAPPED  float高低位数据处理
    				Number v031 = readHoldingRegister(master,1,1010, DataType.FOUR_BYTE_FLOAT_SWAPPED);// 注意,float
    				System.out.println("v031："+v031);
    		} catch (Exception e) {
    			e.printStackTrace();
    		}
    		
    	}
    	
       
    }

[代码以及依赖JAR下载][JAR]

[JAR]: https://download.csdn.net/download/qq_32168087/10711211