【MODBUS】j2mod 模拟量输入输出AIAO示例

本文主要是介绍【MODBUS】j2mod 模拟量输入输出AIAO示例，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

一、示例介绍

二、示例代码

2.1 关键代码

三、代码总结

一、示例介绍

该Java示例是一个用于读取和写入工业自动化设备输入输出寄存器的程序。主要功能包括：

解析命令行参数，获取设备地址、输入寄存器和输出寄存器的参考编号。
建立与设备的TCP连接。
创建读取输入寄存器和写入输出寄存器的请求，并设置单元ID。
创建事务，将请求与连接关联，并执行事务。
循环读取输入寄存器的值，并将值写入输出寄存器中，仅在值发生变化时更新输出寄存器。
关闭与设备的连接。

注意：该程序使用了Modbus协议进行通信，并依赖于j2mod库。

二、示例代码

package com.ghgande.j2mod.modbus.cmd;import com.ghgande.j2mod.modbus.Modbus;
import com.ghgande.j2mod.modbus.io.ModbusTCPTransaction;
import com.ghgande.j2mod.modbus.io.ModbusTransaction;
import com.ghgande.j2mod.modbus.msg.ModbusRequest;
import com.ghgande.j2mod.modbus.msg.ReadInputRegistersRequest;
import com.ghgande.j2mod.modbus.msg.ReadInputRegistersResponse;
import com.ghgande.j2mod.modbus.msg.WriteSingleRegisterRequest;
import com.ghgande.j2mod.modbus.net.TCPMasterConnection;
import com.ghgande.j2mod.modbus.procimg.SimpleRegister;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;import java.net.InetAddress;public class AIAOExample {private static final Logger logger = LoggerFactory.getLogger(AIAOExample.class);private static void printUsage() {System.out.printf("\nUsage:\n    java com.ghgande.j2mod.modbus.cmd.AIAOExample <address{:<port>} [String]> <register a_in [int16]> <register a_out [int16]>");}/*** 程序主入口。** @param args 命令行参数*          args[0]: 服务器地址，格式为 address[:port][unit_id]，可选地包含单元标识符。*          args[1]: 输入寄存器(a_in)的参考编号。*          args[2]: 输出寄存器(a_out)的参考编号。*/public static void main(String[] args) {InetAddress addr = null; // 服务器地址TCPMasterConnection con = null; // Modbus TCP 主连接ModbusRequest ai_req; // 用于读取输入寄存器的请求WriteSingleRegisterRequest ao_req; // 用于写入单个寄存器的请求ModbusTransaction ai_trans; // 输入寄存器的事务ModbusTransaction ao_trans; // 输出寄存器的事务int ai_ref = 0; // 输入寄存器参考编号int ao_ref = 0; // 输出寄存器参考编号int port = Modbus.DEFAULT_PORT; // 默认端口号int unit_in = 0; // 输入单元标识符int unit_out = 0; // 输出单元标识符// 参数设置阶段if (args.length < 3) {printUsage();System.exit(1);}try {try {// 解析服务器地址参数String serverAddress = args[0];String parts[] = serverAddress.split(" *: *");String address = parts[0];if (parts.length > 1) {port = Integer.parseInt(parts[1]);if (parts.length > 2) {unit_in = unit_out = Integer.parseInt(parts[2]);if (parts.length > 3) {unit_out = Integer.parseInt(parts[3]);}}}addr = InetAddress.getByName(address);ai_ref = Integer.parseInt(args[1]);ao_ref = Integer.parseInt(args[2]);}catch (Exception ex) {ex.printStackTrace();printUsage();System.exit(1);}// 建立连接con = new TCPMasterConnection(addr);con.setPort(port);con.connect();System.out.printf("Connected to %s:%d", addr.toString(), con.getPort());// 准备请求ai_req = new ReadInputRegistersRequest(ai_ref, 1);ao_req = new WriteSingleRegisterRequest();ao_req.setReference(ao_ref);// 设置单元标识符ai_req.setUnitID(unit_in);ao_req.setUnitID(unit_out);// 准备事务ai_trans = new ModbusTCPTransaction(con);ai_trans.setRequest(ai_req);ao_trans = new ModbusTCPTransaction(con);ao_trans.setRequest(ao_req);// 准备只在变化时更新的持有器SimpleRegister new_out = new SimpleRegister(0);ao_req.setRegister(new_out);int last_out = Integer.MIN_VALUE; // 上一次输出寄存器的值// 循环执行事务，仅在输入寄存器值变化时更新输出寄存器do {ai_trans.execute();int new_in = ((ReadInputRegistersResponse)ai_trans.getResponse()).getRegister(0).getValue();// 仅在值变化时写入if (new_in != last_out) {new_out.setValue(new_in); // 更新寄存器值ao_trans.execute();last_out = new_in;System.out.printf("Updated Output Register with value from Input Register");}} while (true);}catch (Exception ex) {ex.printStackTrace();}finally {// 关闭连接if (con != null) {con.close();}}}
}

2.1 关键代码

// 循环执行事务，仅在输入寄存器值变化时更新输出寄存器
do {ai_trans.execute();int new_in = ((ReadInputRegistersResponse)ai_trans.getResponse()).getRegister(0).getValue();// 仅在值变化时写入if (new_in != last_out) {new_out.setValue(new_in); // 更新寄存器值ao_trans.execute();last_out = new_in;System.out.printf("Updated Output Register with value from Input Register");}
} while (true);