modbus4j使用（java）

import java.util.Arrays;
import com.serotonin.io.serial.SerialParameters;
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.msg.ReadDiscreteInputsRequest;
import com.serotonin.modbus4j.msg.ReadDiscreteInputsResponse;
import com.serotonin.modbus4j.msg.ReadHoldingRegistersRequest;
import com.serotonin.modbus4j.msg.ReadHoldingRegistersResponse;
import com.serotonin.modbus4j.msg.WriteRegistersRequest;
import com.serotonin.modbus4j.msg.WriteRegistersResponse;


/**
 * 通过串口解析MODBUS协议
 * @author cl2
 *
 */
public class TestModbusDemo {
    /*
     * 设定MODBUS网络上从站地址 private final static int SLAVE_ADDRESS = 1;
     * 串行波特率
     */
    private final static int BAUD_RATE = 9600;
    public static void main( String[] args )
    {
        SerialParameters serialParameters = new SerialParameters();
        /* 设定MODBUS通讯的串行口 */
        serialParameters.setCommPortId( "COM3" );
        /* 设定成无奇偶校验 */
        serialParameters.setParity( 0 );
        /* 设定成数据位是8位 */
        serialParameters.setDataBits( 8 );
        /* 设定为1个停止位 */
        serialParameters.setStopBits( 1 );
        /* 设定端口名称 */
        serialParameters.setPortOwnerName( "Numb nuts" );
        /* 设定端口波特率 */
        serialParameters.setBaudRate( BAUD_RATE );
        /* 创建ModbusFactory工厂实例 */
        ModbusFactory modbusFactory = new ModbusFactory();
        /* 创建ModbusMaster实例 */
        ModbusMaster master = modbusFactory.createRtuMaster( serialParameters );
        /* 初始化 */
        try {
            　 　 master.init();
            　 　 readHoldingRegistersTest( master, SLAVE_ADDRESS, 0, 100 );
            　 　
        } catch ( ModbusInitException e ) {
            　 　 e.printStackTrace();
            　 　
        } finally {
            　 　 master.destroy();
            　 　
        }
    }


/**
 * 读开关量型的输入信号
 * @param master 主站
 * @param slaveId 从站地址
 * @param start 起始偏移量
 * @param len 待读的开关量的个数
 */
    private static void readDiscreteInputTest( ModbusMaster master, int slaveId, int start, int len )
    {
        try {
            ReadDiscreteInputsRequest    request        = new ReadDiscreteInputsRequest( slaveId, start, len );
            ReadDiscreteInputsResponse    response    = (ReadDiscreteInputsResponse) master.send( request );
            if ( response.isException() )
                System.out.println( "Exception response: message=" + response.getExceptionMessage() );
            else
                System.out.println( Arrays.toString( response.getBooleanData() ) );
        } catch ( ModbusTransportException e ) {
            e.printStackTrace();
        }
    }


    /**
     * 读保持寄存器上的内容
     * @param master 主站
     * @param slaveId 从站地址
     * @param start 起始地址的偏移量
     * @param len 待读寄存器的个数
     */
    private static void readHoldingRegistersTest( ModbusMaster master, int slaveId, int start, int len )
    {
        try {
            ReadHoldingRegistersRequest    request        = new ReadHoldingRegistersRequest( slaveId, start, len );
            ReadHoldingRegistersResponse    response    = (ReadHoldingRegistersResponse) master.send( request );
            if ( response.isException() )
            {
                System.out.println( "Exception response: message=" + response.getExceptionMessage() );
            } else {
                System.out.println( Arrays.toString( response.getShortData() ) );
                short[] list = response.getShortData();
                for ( int i = 0; i < list.length; i++ )
                {
                    System.out.print( list[i] + " " );
                }
            }
        } catch ( ModbusTransportException e ) {
            e.printStackTrace();
        }
    }


    /**
     * 批量写数据到保持寄存器
     * @param master 主站
     * @param slaveId 从站地址
     * @param start 起始地址的偏移量
     * @param values 待写数据
     */
    public static void writeRegistersTest( ModbusMaster master, int slaveId, int start, short[] values )
    {
        try {
            WriteRegistersRequest    request        = new WriteRegistersRequest( slaveId, start, values );
            WriteRegistersResponse    response    = (WriteRegistersResponse) master.send( request );
            if ( response.isException() )
            {
                System.out.println( "Exception response: message=" + response.getExceptionMessage() );
            } else {
                System.out.println( "Success" );
            }
        } catch ( ModbusTransportException e ) {
            e.printStackTrace();
        }
    }
}