一、maven配置
<dependency>
<groupId>com.infiniteautomation</groupId>
<artifactId>modbus4j</artifactId>
<version>3.0.3</version>
</dependency>
二、代码（包含02 03 04 05功能码）
说明：目前工具类中定义了一个静态的tcpMaster，可以在main方法中调用不同功能码函数时传入。这种方式在实际开发时可以定一个连接池，可以避免一直创建连接，避免未知错误。
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.*;
import com.serotonin.modbus4j.sero.util.queue.ByteQueue;
import lombok.extern.slf4j.Slf4j;
import java.util.Arrays;
/**
* @author xiehan
* @version 1.0
* @date 2020/6/24 14:38
*/
@Slf4j
public class Modbus4jUtils {
/**
* 工厂。
*/
static ModbusFactory modbusFactory;
//建立链接
static ModbusMaster tcpMaster;
static {
if (modbusFactory == null) {
modbusFactory = new ModbusFactory();
tcpMaster = getMaster("192.168.1.xxx",502);
}
}
/**
* 获取master
*
* @return
* @throws ModbusInitException
*/
public static ModbusMaster getMaster(String ip,Integer port){
IpParameters params = new IpParameters();
params.setHost(ip);
params.setPort(port);
//params.setHost("192.168.1.xxx");
//params.setPort(502);
// modbusFactory.createRtuMaster(wapper); //RTU 协议
// modbusFactory.createUdpMaster(params);//UDP 协议
// modbusFactory.createAsciiMaster(wrapper);//ASCII 协议
ModbusMaster master = modbusFactory.createTcpMaster(params, true);// TCP 协议
try {
master.setTimeout(5000);
master.setRetries(3);
master.init();
} catch (ModbusInitException e) {
e.printStackTrace();
}
return master;
}
/**
* 读取离散输入状态[02]
* @param start 开始位
* @param readLenth 位数
* @return
* @throws ModbusInitException
*/
public static ByteQueue modbusTCP02(int slaveId,ModbusMaster tcpMaster,int start, int readLenth) throws ModbusInitException {
//建立链接
//ModbusMaster tcpMaster = getMaster(ip,port);
//发送请求
ModbusRequest modbusRequest=null;
try {
modbusRequest = new ReadDiscreteInputsRequest(slaveId, start, readLenth);//功能码02
} catch (ModbusTransportException e) {
e.printStackTrace();
}
//收到响应
ReadResponse modbusResponse=null;
try {
modbusResponse = (ReadResponse) tcpMaster.send(modbusRequest);
System.out.println(modbusResponse.getData());
System.out.println(Arrays.toString(modbusResponse.getBooleanData()));
} catch (ModbusTransportException e) {
e.printStackTrace();
}
ByteQueue byteQueue= new ByteQueue(12);
modbusResponse.write(byteQueue);
System.out.println("功能码:"+modbusRequest.getFunctionCode());
System.out.println("从站地址:"+modbusRequest.getSlaveId());
System.out.println("开始地址:"+start);
System.out.println("收到的响应信息大小:"+byteQueue.size());
System.out.println("收到的响应信息值:"+byteQueue);
return byteQueue;
}
/**
* 读取离散输入状态[02]
* @param start 开始位
* @param readLength 位数
* @return 返回boolean数组
* @throws
*/
public static boolean[] modbusTCP02Boolean(int slaveId, ModbusMaster tcpMaster, int start, int readLength) {
ModbusRequest modbusRequest;
ReadResponse modbusResponse;
boolean [] ret = null;
try {
modbusRequest = new ReadDiscreteInputsRequest(slaveId, start, readLength);//功能码02
modbusResponse = (ReadResponse) tcpMaster.send(modbusRequest);
if(modbusResponse.isException()){
log.error("读取异常 {}",modbusResponse.getExceptionMessage());
return ret;
}
ret = modbusResponse.getBooleanData();
} catch (ModbusTransportException e) {
log.error("02功能码读取异常 ",e);
}
return ret;
}
/**
* 读取保持寄存器[03]
* @param start 开始地址
* @param readLenth 读取数量
* @return 返回short 数组
* @throws
*/
public static short[] modbusTCP03Short(int slaveId,ModbusMaster tcpMaster,int start, int readLenth) {
ModbusRequest modbusRequest = null;
ReadResponse modbusResponse = null;
short [] ret = null;
try {
modbusRequest = new ReadHoldingRegistersRequest(slaveId, start, readLenth);//功能码03
modbusResponse = (ReadResponse) tcpMaster.send(modbusRequest);
ret = modbusResponse.getShortData();
} catch (ModbusTransportException e) {
log.error("03功能码读取异常 ",e);
}
return ret;
}
/**
* 读取保持寄存器[03]
* @param start 开始地址
* @param readLenth 读取数量
* @return
* @throws ModbusInitException
*/
public static ByteQueue modbusTCP03(int slaveId,ModbusMaster tcpMaster,int start, int readLenth) throws ModbusInitException {
//建立链接
//ModbusMaster tcpMaster = getMaster(ip,port);
//发送请求
ModbusRequest modbusRequest=null;
try {
modbusRequest = new ReadHoldingRegistersRequest(slaveId, start, readLenth);//功能码03
} catch (ModbusTransportException e) {
e.printStackTrace();
}
//收到响应
ModbusResponse modbusResponse=null;
try {
modbusResponse = tcpMaster.send(modbusRequest);
} catch (ModbusTransportException e) {
e.printStackTrace();
}
ByteQueue byteQueue= new ByteQueue(12);
modbusResponse.write(byteQueue);
System.out.println("功能码:"+modbusRequest.getFunctionCode());
System.out.println("从站地址:"+modbusRequest.getSlaveId());
System.out.println("开始地址:"+start);
System.out.println("收到的响应信息大小:"+byteQueue.size());
System.out.println("收到的响应信息值:"+byteQueue);
return byteQueue;
}
/**
* 读取输入寄存器[04]
* @param start 开始地址
* @param readLenth 读取数量
* @return
* @throws ModbusInitException
*/
public static ByteQueue modbusTCP04(int slaveId, ModbusMaster tcpMaster, int start, int readLenth) throws ModbusInitException {
//建立链接
// ModbusMaster tcpMaster = getMaster(ip,port);
//发送请求
ModbusRequest modbusRequest=null;
try {
modbusRequest = new ReadInputRegistersRequest(slaveId, start, readLenth);//功能码04
} catch (ModbusTransportException e) {
e.printStackTrace();
}
//收到响应
ModbusResponse modbusResponse=null;
try {
modbusResponse = tcpMaster.send(modbusRequest);
} catch (ModbusTransportException e) {
e.printStackTrace();
}
ByteQueue byteQueue= new ByteQueue(12);
modbusResponse.write(byteQueue);
System.out.println("功能码:"+modbusRequest.getFunctionCode());
System.out.println("从站地址:"+modbusRequest.getSlaveId());
System.out.println("开始地址:"+start);
System.out.println("收到的响应信息大小:"+byteQueue.size());
System.out.println("收到的响应信息值:"+byteQueue);
return byteQueue;
}
/**
* 读取输入寄存器[04]
* @param start 开始地址
* @param readLenth 读取数量
* @return
* @throws ModbusInitException
*/
public static short[] modbusTCP04Short(int slaveId, ModbusMaster tcpMaster, int start, int readLenth){
ModbusRequest modbusRequest = null;
ReadResponse modbusResponse = null;
short [] ret = null;
try {
modbusRequest = new ReadInputRegistersRequest(slaveId, start, readLenth);//功能码03
modbusResponse = (ReadResponse) tcpMaster.send(modbusRequest);
ret = modbusResponse.getShortData();
System.out.println("功能码:"+modbusRequest.getFunctionCode());
System.out.println("从站地址:"+modbusRequest.getSlaveId());
System.out.println("开始地址:"+start);
System.out.println("收到的响应信息值:"+Arrays.toString(ret));
} catch (ModbusTransportException e) {
log.error("04功能码读取异常 ",e);
}
return ret;
}
/**
* 写单个线圈[05]
* @param writeOffset 开始位
* @param writeValue true false
* @return
* @throws ModbusInitException
*/
public static ByteQueue modbusTCP05(int slaveId,ModbusMaster tcpMaster,int writeOffset, boolean writeValue) throws ModbusInitException {
//建立链接
//ModbusMaster tcpMaster = getMaster(ip,port);
//发送请求
ModbusRequest modbusRequest=null;
try {
modbusRequest = new WriteCoilRequest(slaveId, writeOffset, writeValue);//功能码05
} catch (ModbusTransportException e) {
e.printStackTrace();
}
//收到响应
ModbusResponse modbusResponse=null;
try {
modbusResponse = tcpMaster.send(modbusRequest);
} catch (ModbusTransportException e) {
e.printStackTrace();
}
ByteQueue byteQueue= new ByteQueue(12);
modbusResponse.write(byteQueue);
System.out.println("功能码:"+modbusRequest.getFunctionCode());
System.out.println("从站地址:"+modbusRequest.getSlaveId());
System.out.println("收到的响应信息大小:"+byteQueue.size());
System.out.println("收到的响应信息值:"+byteQueue);
return byteQueue;
}
}
网友评论