要通過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),則需要相應地調整代碼中的相關部分。