要通过Modbus协议采集数据,可以使用Java Modbus库。以下是一个基本的示例代码,可以通过Modbus TCP/IP协议读取保持寄存器的数据。
首先,需要引入Java Modbus库。可以在Maven项目中添加以下依赖项:
<dependency>
<groupId>com.ghgande.j2mod</groupId>
<artifactId>j2mod</artifactId>
<version>2.6-SNAPSHOT</version>
</dependency>
然后,可以使用以下代码来实现数据采集:
import com.ghgande.j2mod.modbus.facade.ModbusTCPMaster;
import com.ghgande.j2mod.modbus.util.SerialParameters;
import com.ghgande.j2mod.modbus.ModbusException;
public class ModbusDataCollector {
private static final int SLAVE_ID = 1; // Modbus设备的从站ID
private static final int START_ADDRESS = 0; // 起始寄存器地址
private static final int REGISTER_COUNT = 10; // 要读取的寄存器数量
private static final int TIMEOUT = 2000; // 超时时间(毫秒)
private ModbusTCPMaster modbusMaster;
public ModbusDataCollector(String ipAddress, int port) {
modbusMaster = new ModbusTCPMaster(ipAddress, port);
modbusMaster.setTimeout(TIMEOUT);
modbusMaster.setRetries(0);
}
public void connect() throws Exception {
modbusMaster.connect();
}
public void disconnect() {
modbusMaster.disconnect();
}
public int[] readRegisters() throws ModbusException {
return modbusMaster.readMultipleRegisters(SLAVE_ID, START_ADDRESS, REGISTER_COUNT);
}
public static void main(String[] args) {
String ipAddress = "192.168.1.1"; // Modbus设备的IP地址
int port = 502; // Modbus设备的端口号
ModbusDataCollector collector = new ModbusDataCollector(ipAddress, port);
try {
collector.connect();
int[] registers = collector.readRegisters();
// 处理读取到的寄存器数据
for (int i = 0; i < registers.length; i++) {
System.out.println("Register " + (START_ADDRESS + i) + ": " + registers[i]);
}
} catch (Exception e) {
e.printStackTrace();
} finally {
collector.disconnect();
}
}
}
在上面的代码中,首先创建了一个ModbusTCPMaster实例,并设置了连接的IP地址、端口号、超时时间和重试次数。然后通过connect()
方法连接到Modbus设备,通过readMultipleRegisters()
方法读取指定地址范围内的保持寄存器数据。最后,通过disconnect()
方法断开与Modbus设备的连接。
请注意,上述示例仅适用于Modbus TCP/IP协议,如果需要使用其他类型的Modbus协议(如Modbus RTU),则需要相应地调整代码中的相关部分。