使用Java编程设置读取ModbusSlave寄存器的数据

快来打我* 2023-07-18 02:32 12阅读 0赞

### 文章参考自： ###

[会飞的李小浩图书馆][Link 1]

这篇文章是我在参考上面这篇文章之后，做出的一些调整和补充，如有不足之处，还请多指教。

**设置通信方式Modbus TCP/IP，，端口设置为502，配置功能码为0x03**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDEzMzA5OQ_size_16_color_FFFFFF_t_70]  
提供一个读取及写入的工具类：

依赖jar包：  
**modbus4J.jar seroUtils.jar**

package com.hxz.mdbus;
    
    import com.serotonin.modbus4j.ModbusFactory;
    import com.serotonin.modbus4j.ModbusMaster;
    import com.serotonin.modbus4j.exception.ModbusInitException;
    import com.serotonin.modbus4j.exception.ModbusTransportException;
    import com.serotonin.modbus4j.ip.IpParameters;
    import com.serotonin.modbus4j.msg.ModbusRequest;
    import com.serotonin.modbus4j.msg.ModbusResponse;
    import com.serotonin.modbus4j.msg.ReadHoldingRegistersRequest;
    import com.serotonin.modbus4j.msg.WriteRegistersRequest;
    import com.serotonin.modbus4j.msg.WriteRegistersResponse;
    import com.serotonin.util.queue.ByteQueue;
    
    public class ReadAWriteUtil { 
    
        /** * 批量写数据到保持寄存器 * @param ip 从站IP * @param port modbus端口 * @param slaveId 从站ID * @param start 起始地址偏移量 * @param values 待写数据 */
        public static void modbusWTCP(String ip, int port, int slaveId, int start, short[] values) {  
            ModbusFactory modbusFactory = new ModbusFactory(); 
            // 设备ModbusTCP的Ip与端口，如果不设定端口则默认为502 
            IpParameters params = new IpParameters(); 
            params.setHost(ip);
            // 设置端口，默认502
            if (502 != port) {  
                params.setPort(port); 
            }
            ModbusMaster tcpMaster = null; 
            // 参数1：IP和端口信息 参数2：保持连接激活 
            tcpMaster = modbusFactory.createTcpMaster(params, true); 
            try {  
                tcpMaster.init(); 
                System.out.println("=======初始化成功========"); 
            } catch (ModbusInitException e) {  
                 System.out.println("初始化异常"); 
            } 
            try {   
                WriteRegistersRequest request = new WriteRegistersRequest(slaveId, start, values); 
                WriteRegistersResponse response = (WriteRegistersResponse) tcpMaster.send(request); 
                if (response.isException()){ 
                    System.out.println("Exception response: message=" + response.getExceptionMessage());
                }else{ 
                    System.out.println("Success");
                }     
            } catch (ModbusTransportException e) {  
                e.printStackTrace(); 
            }
        } 
        
       
        /** * 读保持寄存器上的内容 * @param ip 从站IP * @param port modbus端口 * @param start 起始地址偏移量 * @param readLenth 待读寄存器个数 * @return */
        public static ByteQueue modbusTCP(String ip, int port, int start,int readLenth) {  
            ModbusFactory modbusFactory = new ModbusFactory(); 
            // 设备ModbusTCP的Ip与端口，如果不设定端口则默认为502 
            IpParameters params = new IpParameters(); 
            params.setHost(ip);
            //设置端口，默认502
            if(502!=port){ 
                params.setPort(port);
            } 
            ModbusMaster tcpMaster = null; 
            tcpMaster = modbusFactory.createTcpMaster(params, true); 
            try {  
                tcpMaster.init(); 
                System.out.println("========初始化成功======="); 
            } catch (ModbusInitException e) {  
                return null; 
            } 
            ModbusRequest modbusRequest=null; 
            try {  
                //功能码03 读取保持寄存器的值
                modbusRequest = new ReadHoldingRegistersRequest(1, start, readLenth); 
            } catch (ModbusTransportException e) {  
                e.printStackTrace(); 
            } 
            ModbusResponse modbusResponse=null; 
            try {  
                modbusResponse = tcpMaster.send(modbusRequest); 
            } catch (ModbusTransportException e) {  
                e.printStackTrace(); 
            } 
            ByteQueue byteQueue= new ByteQueue(1024); 
            modbusResponse.write(byteQueue);
            System.out.println("功能码:"+modbusRequest.getFunctionCode()); 
            System.out.println("从站地址:"+modbusRequest.getSlaveId()); 
            System.out.println("收到的响应信息大小:"+byteQueue.size());
            System.out.println("收到的响应信息值:"+byteQueue); 
            return byteQueue; 
        }
        public static void main(String[] args) { 
           short [] list={ 100,20,30,9,67,0,65,0,89,90};
           modbusWTCP("127.0.0.1",502,1,0,list);
            //读数据
            modbusTCP("127.0.0.1",502,0,10);
        }
    }

运行结果：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDEzMzA5OQ_size_16_color_FFFFFF_t_70 1]  
相关jar包网盘分享：  
链接：https://pan.baidu.com/s/1frYH5Ch5aWh8elKC9–qZw  
提取码：juig

[Link 1]: http://www.360doc.com/content/16/1201/10/38545610_610969779.shtml
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDEzMzA5OQ_size_16_color_FFFFFF_t_70]: /images/20230528/c007ba2d37724f649ee91512880e38ed.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDEzMzA5OQ_size_16_color_FFFFFF_t_70 1]: /images/20230528/b3a2a4d31c4f44c282d5bd8e2ebf73ba.png