12345678910111213141516171819202122232425262728293031323334 |
- package at.acdp.urweb.fhpp;
- import com.digitalpetri.modbus.master.ModbusTcpMaster;
- import com.digitalpetri.modbus.master.ModbusTcpMasterConfig;
- import com.digitalpetri.modbus.requests.ReadHoldingRegistersRequest;
- import com.digitalpetri.modbus.responses.ReadHoldingRegistersResponse;
- import io.netty.buffer.ByteBufUtil;
- import io.netty.util.ReferenceCountUtil;
- import java.util.concurrent.CompletableFuture;
- public class FHPP {
- public FHPP() {
- }
- public void connect() {
- ModbusTcpMasterConfig config = new ModbusTcpMasterConfig.Builder("localhost").build();
- ModbusTcpMaster master = new ModbusTcpMaster(config);
- master.connect();
- CompletableFuture<ReadHoldingRegistersResponse> future =
- master.sendRequest(new ReadHoldingRegistersRequest(0, 10), 0);
- future.thenAccept(response -> {
- System.out.println("Response: " + ByteBufUtil.hexDump(response.getRegisters()));
- ReferenceCountUtil.release(response);
- });
- }
- }
|