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

2024-03-14 19:12

本文主要是介绍【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);

三、代码总结

该示例实现了一个简单的命令行工具,该工具演示了如何将模拟输入与模拟输出绑定。

注意!!!,如果您使用Modbus协议栈向远程I/O进行写入,则很可能会在第一次写入消息后保持通信有效。这可以通过发送任何类型的消息来实现,也可以通过在给定的时间段内重复写入消息来实现。

如果超过该时间段,则设备可能会通过输出I/O模块的所有信号来做出反应。在此超时之后,设备可能需要一条重置消息。

这篇关于【MODBUS】j2mod 模拟量输入输出AIAO示例的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/809449

相关文章

Go语言使用select监听多个channel的示例详解

《Go语言使用select监听多个channel的示例详解》本文将聚焦Go并发中的一个强力工具,select,这篇文章将通过实际案例学习如何优雅地监听多个Channel,实现多任务处理、超时控制和非阻... 目录一、前言:为什么要使用select二、实战目标三、案例代码:监听两个任务结果和超时四、运行示例五

MySQL常用字符串函数示例和场景介绍

《MySQL常用字符串函数示例和场景介绍》MySQL提供了丰富的字符串函数帮助我们高效地对字符串进行处理、转换和分析,本文我将全面且深入地介绍MySQL常用的字符串函数,并结合具体示例和场景,帮你熟练... 目录一、字符串函数概述1.1 字符串函数的作用1.2 字符串函数分类二、字符串长度与统计函数2.1

SQL Server 中的 WITH (NOLOCK) 示例详解

《SQLServer中的WITH(NOLOCK)示例详解》SQLServer中的WITH(NOLOCK)是一种表提示,等同于READUNCOMMITTED隔离级别,允许查询在不获取共享锁的情... 目录SQL Server 中的 WITH (NOLOCK) 详解一、WITH (NOLOCK) 的本质二、工作

MySQL CTE (Common Table Expressions)示例全解析

《MySQLCTE(CommonTableExpressions)示例全解析》MySQL8.0引入CTE,支持递归查询,可创建临时命名结果集,提升复杂查询的可读性与维护性,适用于层次结构数据处... 目录基本语法CTE 主要特点非递归 CTE简单 CTE 示例多 CTE 示例递归 CTE基本递归 CTE 结

Spring AI使用tool Calling和MCP的示例详解

《SpringAI使用toolCalling和MCP的示例详解》SpringAI1.0.0.M6引入ToolCalling与MCP协议,提升AI与工具交互的扩展性与标准化,支持信息检索、行动执行等... 目录深入探索 Spring AI聊天接口示例Function CallingMCPSTDIOSSE结束语

go动态限制并发数量的实现示例

《go动态限制并发数量的实现示例》本文主要介绍了Go并发控制方法,通过带缓冲通道和第三方库实现并发数量限制,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面... 目录带有缓冲大小的通道使用第三方库其他控制并发的方法因为go从语言层面支持并发,所以面试百分百会问到

PyTorch中的词嵌入层(nn.Embedding)详解与实战应用示例

《PyTorch中的词嵌入层(nn.Embedding)详解与实战应用示例》词嵌入解决NLP维度灾难,捕捉语义关系,PyTorch的nn.Embedding模块提供灵活实现,支持参数配置、预训练及变长... 目录一、词嵌入(Word Embedding)简介为什么需要词嵌入?二、PyTorch中的nn.Em

Python Web框架Flask、Streamlit、FastAPI示例详解

《PythonWeb框架Flask、Streamlit、FastAPI示例详解》本文对比分析了Flask、Streamlit和FastAPI三大PythonWeb框架:Flask轻量灵活适合传统应用... 目录概述Flask详解Flask简介安装和基础配置核心概念路由和视图模板系统数据库集成实际示例Stre

Spring Bean初始化及@PostConstruc执行顺序示例详解

《SpringBean初始化及@PostConstruc执行顺序示例详解》本文给大家介绍SpringBean初始化及@PostConstruc执行顺序,本文通过实例代码给大家介绍的非常详细,对大家的... 目录1. Bean初始化执行顺序2. 成员变量初始化顺序2.1 普通Java类(非Spring环境)(

Java Spring的依赖注入理解及@Autowired用法示例详解

《JavaSpring的依赖注入理解及@Autowired用法示例详解》文章介绍了Spring依赖注入(DI)的概念、三种实现方式(构造器、Setter、字段注入),区分了@Autowired(注入... 目录一、什么是依赖注入(DI)?1. 定义2. 举个例子二、依赖注入的几种方式1. 构造器注入(Con