ModBus开源库jlibmodbus

package com.intelligt.modbus.jlibmodbus.master; import com.intelligt.modbus.jlibmodbus.Modbus; import com.intelligt.modbus.jlibmodbus.data.CommStatus; import com.intelligt.modbus.jlibmodbus.exception.ModbusIOException; import com.intelligt.modbus.jlibmodbus.exception.ModbusNumberException; import com.intelligt.modbus.jlibmodbus.exception.ModbusProtocolException; import com.intelligt.modbus.jlibmodbus.msg.ModbusRequestBuilder; import com.intelligt.modbus.jlibmodbus.msg.ModbusRequestFactory; import com.intelligt.modbus.jlibmodbus.msg.base.ModbusFileRecord; import com.intelligt.modbus.jlibmodbus.msg.base.ModbusMessage; import com.intelligt.modbus.jlibmodbus.msg.base.ModbusRequest; import com.intelligt.modbus.jlibmodbus.msg.base.ModbusResponse; import com.intelligt.modbus.jlibmodbus.msg.base.mei.MEIReadDeviceIdentification; import com.intelligt.modbus.jlibmodbus.msg.base.mei.ReadDeviceIdentificationCode; import com.intelligt.modbus.jlibmodbus.msg.response.*; import com.intelligt.modbus.jlibmodbus.net.ModbusConnection; import com.intelligt.modbus.jlibmodbus.net.transport.ModbusTransport; import com.intelligt.modbus.jlibmodbus.utils.FrameEvent; import com.intelligt.modbus.jlibmodbus.utils.FrameEventListener; import com.intelligt.modbus.jlibmodbus.utils.FrameEventListenerList; import com.intelligt.modbus.jlibmodbus.utils.ModbusExceptionCode; /* * Copyright (C) 2016 "Invertor" Factory", JSC * [http://www.sbp-invertor.ru] * * This file is part of JLibModbus. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. * * Authors: Vladislav Y. Kochedykov, software engineer. * email: vladislav.kochedykov@gmail.com */ abstract public class ModbusMaster implements FrameEventListenerList { final private ModbusConnection conn; final private BroadcastResponse broadcastResponse = new BroadcastResponse(); private int transactionId = 0; private long requestTime = 0; public ModbusMaster(ModbusConnection conn) { this.conn = conn; } public int getTransactionId() { return transactionId; } public void setTransactionId(int transactionId) { this.transactionId = Math.min(Math.abs(transactionId), Modbus.TRANSACTION_ID_MAX_VALUE); } protected ModbusConnection getConnection() { return conn; } /** * this method allows you to implement your own behavior of connect method. * * @throws ModbusIOException */ protected void connectImpl() throws ModbusIOException { getConnection().open(); } /** * this method allows you to implement your own behavior of disconnect method. * * @throws ModbusIOException */ protected void disconnectImpl() throws ModbusIOException { getConnection().close(); } final public void connect() throws ModbusIOException { if (!isConnected()) { connectImpl(); } } final public void disconnect() throws ModbusIOException { if (isConnected()) { disconnectImpl(); } } public boolean isConnected() { return getConnection().isOpened(); } protected void sendRequest(ModbusMessage msg) throws ModbusIOException { ModbusTransport transport = getConnection().getTransport(); if (transport == null) throw new ModbusIOException("transport is null"); transport.send(msg); requestTime = System.currentTimeMillis(); } protected ModbusMessage readResponse(ModbusRequest request) throws ModbusProtocolException, ModbusNumberException, ModbusIOException { return getConnection().getTransport().readResponse(request); } /** * this function allows you to process your own ModbusRequest. * Each request class has a compliant response class for instance ReadHoldingRegistersRequest and ReadHoldingRegistersResponse. * If you process an instance of ReadHoldingRegistersRequest this function exactly either returns a ReadHoldingRegistersResponse instance or throws an exception. * * @param request an instance of ModbusRequest. * @return an instance of ModbusResponse. * @throws ModbusProtocolException * @throws ModbusIOException * @see ModbusRequestFactory * @see ModbusRequest * @see ModbusResponse * @see com.intelligt.modbus.jlibmodbus.msg.request * @see com.intelligt.modbus.jlibmodbus.msg.request */ synchronized public ModbusResponse processRequest(ModbusRequest request) throws ModbusProtocolException, ModbusIOException { sendRequest(request); if (request.getServerAddress() != Modbus.BROADCAST_ID) { do { try { ModbusResponse msg = (ModbusResponse) readResponse(request); request.validateResponse(msg); /* * if you have received an ACKNOWLEDGE, * it means that operation is in processing and you should be waiting for the answer */ if (msg.getModbusExceptionCode() != ModbusExceptionCode.ACKNOWLEDGE) { if (msg.isException()) throw new ModbusProtocolException(msg.getModbusExceptionCode()); return msg; } } catch (ModbusNumberException mne) { Modbus.log().warning(mne.getLocalizedMessage()); } } while (System.currentTimeMillis() - requestTime < getConnection().getReadTimeout()); /* * throw an exception if there is a response timeout */ throw new ModbusIOException("Response timeout."); } else { /* return because slaves do not respond broadcast requests */ broadcastResponse.setFunction(request.getFunction()); return broadcastResponse; } } /** * ModbusMaster will block for only this amount of time. * If the timeout expires, a ModbusTransportException is raised, though the ModbusMaster is still valid. * * @param timeout the specified timeout, in milliseconds. */ public void setResponseTimeout(int timeout) { try { getConnection().setReadTimeout(timeout); } catch (Exception e) { Modbus.log().warning(e.getLocalizedMessage()); } } /** * This function code is used to read the contents of a contiguous block of holding registers in a * remote device. The Request PDU specifies the starting register address and the number of * registers. In the PDU Registers are addressed starting at zero. Therefore registers numbered * 1-16 are addressed as 0-15. * * @param serverAddress a slave address * @param startAddress starting register address * @param quantity the number of registers * @return the register data * @throws ModbusProtocolException if modbus-exception is received * @throws ModbusNumberException if response is invalid * @throws ModbusIOException if remote slave is unavailable */ final public int[] readHoldingRegisters(int serverAddress, int startAddress, int quantity) throws ModbusProtocolException, ModbusNumberException, ModbusIOException { ModbusRequest request = ModbusRequestBuilder.getInstance().buildReadHoldingRegisters(serverAddress, startAddress, quantity); ReadHoldingRegistersResponse r