modbus4j ser通讯
[cpp]view plain copy
- modbus4j.jar实现modbus urt模式
- 使用modbus4j开源项目,通过串口读取数据,过程中遇到点小问题。(转的demo按自己的需求修改的)
- 1.串口不对应,导致 gnu.io.NoSuchPortException。
- 2.PLC485串口转COMM口,发/送线连接不对,导致读不到数据
- 3.rxtxSerial.dll放置的路径,查了下有人说放到myeclipse/jre/bin下,可我是放到C:\Windows\System32下,不知道原因。
- 4.RXTXcomm.jar包和rxtxSerial.dll文件不对应,可去官网下载同一版本。
- 5.读保持型寄存器和读输入型寄存器方法不一样。这是由于modbus协议,保持型功能码为03,输入型为04。通过api可找到对应的方法,用法也差不多一样。
- class="java">package com.test.modbus;
- 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();
- }
- }
- }
推荐阅读
- gitlab|gitlab 通过备份还原 admin/runner 500 Internal Server Error
- 使用composer自动加载类文件
- 全职妈妈在4岁孩子眼中只是一个loser
- Java|Java spi(service provider interface)
- 核心
- javaweb|基于Servlet+jsp+mysql开发javaWeb学生成绩管理系统
- The|The ideal servant
- android系统分享分析Intent.createChooser
- SqlServer|sql server的UPDLOCK、HOLDLOCK试验
- day|day 28 设置路由表