【物联网】Modbus 协议及Qinghub物联网平台应用

Modbus 协议简介

QingHub设计器在设计物联网数据采集时不可避免的需要针对Modbus协议的设备做相关数据采集，这里就我们的实际项目经验分享Modbus协议

你可以通过QingHub作业直接体验试用，也可以根据手册开发相应的代码块。 qinghub项目已经全面开源。

源码文件地址: https://gitee.com/qingplus/qingcloud-platform

QingHub设计器体验

简介

Modbus由MODICON公司于1979年开发，是一种工业现场总线协议标准。1996年施耐德公司推出基于以太网TCP/IP的Modbus协议：ModbusTCP。Modbus协议是一项应用层报文传输协议，包括ASCII、RTU、TCP三种报文类型。 标准的Modbus协议物理层接口有RS232、RS422、RS485和以太网接口，采用master/slave方式通信。

功能码

重点介绍常用如下几个功能码:
1: 读线圈寄存器
2: 读离散输入寄存器
3: 读保持寄存器
4: 读输入寄存器
5: 写单个线圈寄存器
6: 写单个保持寄存器
15: 写多个线圈寄存器
16: 写多个保持寄存器

几种继承器介绍

线圈寄存器

实际上就可以类比为开关量，每个bit都对应一个信号的开关状态。所以一个byte就可以同时控制8路的信号。

离散输入寄存器

如果线圈寄存器理解了这个自然也明白了。离散输入寄存器就相当于线圈寄存器的只读模式，他也是每个bit表示一个开关量，而他的开关量只能读取输入的开关信号，是不能够写的。

保持寄存器

这个寄存器的单位不再是bit而是两个byte，也就是可以存放具体的数据量的，并且是可读写的。比如设置时间年月日，不但可以写也可以读出来现在的时间。写分为单个写和多个写。

输入寄存器

只剩下这最后一个了，这个和保持寄存器类似，但是也是只支持读而不能写。一个寄存器也是占据两个byte的空间。

通信协议 (重点看这里就可以了)

Modbus设备可分为主站(poll)和从站(slave)。主站只有一个，从站有多个，主站向各从站发送请求帧，从站给予响应。在使用TCP通信时，主站为client端，主动建立连接；从站为server端，等待连接(当然只要你愿意并足够熟悉，也可以反向操作)。

Mobus 的报文大致分为两类： MBAP+PDU。
MBAP= Modbus Application Protocol Header(Modbus应用协议) 头部
PDU = Protocol Data Unit （数据单元）

MBAP报文

  • MBAP为报文头，长度为7字节，组成如下：
事务处理标识协议标识长度单元标识符
2字节2字节2字节1字节

含义:
事务处理标识：可以理解为报文的序列号，一般每次通信之后就要加1以区别不同的通信数据报文。
协议标识符：00 00表示ModbusTCP协议。
长度：表示接下来的数据长度，单位为字节。
单元标识符：可以理解为设备地址。

PDU报文结构

PDU结构
PDU由功能码+数据组成。功能码为1字节，数据长度不定，由具体功能决定。
主站请求：功能码+数据
从站正常响应：请求功能码+响应数据
从站异常响应：异常功能码+异常码，其中异常功能码即将请求功能码的最高有效位置1，异常码指示差错类型

指令实例

查询（功能码0x03）

基本流程就是:
发送:地址 + 我要查 +（寄存器起始地址+个数）+校验
回复:地址 +（回）我要查 +（数据的字节数+数据） +校验

主机发送: 01 03 00 00 00 01 84 0A
含义:
01-地址
03-功能码,代表查询功能,其他功能后面再说
00 00-代表查询的起始寄存器地址.说明从0x0000开始查询.
00 01-代表查询了一个寄存器.结合前面的00 00,意思就是查询从0开始的1个寄存器值;
84 0A-CRC

从机回复: 01 03 02 12 34 B5 33
含义:
01-地址
03-功能码
02-代表后面数据的字节数,因为上面说到,一个寄存器有2个字节,所以后面的字节数肯定是2*查询的寄存器个数;
12 34-寄存器的值是12 34,结合发送的数据看出,01这个寄存器的值为12 34
B5 33-CRC校验码

修改单个寄存器（功能码0x06）

主机送: 01 06 00 00 00 01 48 0A
01-从机地址
06-功能码:修改单个寄存器功能,修改有些不同,有修改一个寄存器和修改多个寄存器;
00 00-修改的起始寄存器地址.说明从0x0000开始.
00 01-修改的值为00 01.结合前面的00 00,意思就是修改0号寄存器值为00 01;
48 0A-CRC

从机回复: 01 06 00 00 00 01 48 0A
01-从机地址
06-功能码:修改单个寄存器功能;
00 00-修改的起始寄存器地址.说明是0x0000.
00 01-修改的值为00 01.结合前面的00 00,意思就是修改0号寄存器值为00 01;
48 0A-CRC

修改多个寄存器（功能码0x10）

主机发送: 01 10 00 00 00 02 04 11 22 33 44 42 5A
01-从机地址
10-功能码,代表修改多个寄存器功能;
00 00-代表修改的起始寄存器地址.说明从0x0000开始.
00 02代表修改的寄存器数量
04 -表示修改的总字节数，由于只修改了1个寄存器，所以数据要有两个字节；
11 22 33 44-表示修改的值，结合上面，就是从第0000寄存器开始修改2寄存器值为11 22 33 44，就是把0000寄存器改为11 22，0001为33 44，
42 5A -循环冗余校验,是modbus的校验公式,从首个字节开始到22前面为止;

从机回复: 01 10 00 00 00 02 41 C8
01-从机地址
10-功能码
00 00-代表修改的起始寄存器地址.说明是0x0000.
00 02-代表修改的寄存器数量，只需要回复这么多久足够了，从机告诉主机修改了哪几个寄存器就足够了;
41 C8-循环冗余校验;

java 开发

maven 依赖
<!-- Modbus -->
<dependency><groupId>com.infiniteautomation</groupId><artifactId>modbus4j</artifactId><version>3.1.0</version>
</dependency>
<dependency><groupId>com.digitalpetri.modbus</groupId><artifactId>modbus-master-tcp</artifactId><version>1.2.0</version>
</dependency>
API 实例

第一：建立连接

/*** 获取 Modbus Master* @return ModbusMaster* @throws ModbusInitException ModbusInitException*/
public ModbusMaster getMaster(ModbusConfig modbusConfig) throws ModbusInitException {log.debug("Modbus Tcp Connection Info {},{}", modbusConfig.getHostName(),modbusConfig.getPort());ModbusMaster modbusMaster = masterMap.get(modbusConfig.getEquipmentId());if (null == modbusMaster) {IpParameters params = new IpParameters();params.setHost(modbusConfig.getHostName());params.setPort(modbusConfig.getPort());**params.setEncapsulated(true);**modbusMaster = modbusFactory.createTcpMaster(params, true);modbusMaster.init();masterMap.put(modbusConfig.getEquipmentId(), modbusMaster);}return modbusMaster;
}

注意
这里有一个需要特别关注的地方，params.setEncapsulated(true)

如果encapsulated=true时：API 在构建消息是会自动加上CRC 校验码。

public byte[] getMessageData() {ByteQueue msgQueue = new ByteQueue();modbusMessage.write(msgQueue);ModbusUtils.pushShort(msgQueue, ModbusUtils.calculateCRC(modbusMessage));return msgQueue.popAll();
}

如果encapsulated=false时：消息会加上事务处理标识，协议标识6个字节:

public byte[] getMessageData() {ByteQueue msgQueue = new ByteQueue();modbusMessage.write(msgQueue);ByteQueue xaQueue = new ByteQueue();ModbusUtils.pushShort(xaQueue, transactionId);ModbusUtils.pushShort(xaQueue, ModbusUtils.IP_PROTOCOL_ID);ModbusUtils.pushShort(xaQueue, msgQueue.size());xaQueue.push(msgQueue);return xaQueue.popAll();
}

第二： API实例

/*** 读线圈寄存器* @param modbusMaster* @param slaveId* @param initOffset* @param count* @return* @throws ModbusTransportException*/
private static String batchCoilStatus01(ModbusMaster modbusMaster,Integer slaveId,Integer initOffset,Integer count) throws ModbusTransportException {ReadCoilsRequest request= new ReadCoilsRequest(slaveId,initOffset,count);ReadCoilsResponse response = (ReadCoilsResponse) modbusMaster.send(request);byte[] data  = response.getData();String bytes = ByteUtils.toHexAscii(data);return bytes;
}/*** 读离散输入寄存器* @param modbusMaster* @param slaveId* @param initOffset* @param count* @return* @throws ModbusTransportException*/
private static String batchInputStatus02(ModbusMaster modbusMaster,Integer slaveId,Integer initOffset,Integer count) throws ModbusTransportException {ReadDiscreteInputsRequest request= new ReadDiscreteInputsRequest(slaveId,initOffset,count);ReadDiscreteInputsResponse response = (ReadDiscreteInputsResponse) modbusMaster.send(request);byte[] data  = response.getData();String bytes = ByteUtils.toHexAscii(data);return bytes;
}
/***批量读取保持继承器* @param modbusMaster* @param slaveId* @param initOffset* @param count* @return* @throws ModbusTransportException*/
private static String batchRead03(ModbusMaster modbusMaster,Integer slaveId,Integer initOffset,Integer count) throws  ModbusTransportException {ReadHoldingRegistersRequest request= new ReadHoldingRegistersRequest(slaveId,initOffset,count);ReadHoldingRegistersResponse response = (ReadHoldingRegistersResponse) modbusMaster.send(request);byte[] data  = response.getData();String bytes = ByteUtils.toHexAscii(data);return bytes;
}/*** 批量读取输入继承器* @param modbusMaster* @param slaveId* @param initOffset* @param count* @return* @throws ModbusTransportException*/
private static String batchRead04(ModbusMaster modbusMaster ,Integer slaveId,Integer initOffset, Integer count) throws  ModbusTransportException {ReadInputRegistersRequest request= new ReadInputRegistersRequest(slaveId,initOffset,count);ReadInputRegistersResponse response = (ReadInputRegistersResponse) modbusMaster.send(request);byte[] data  = response.getData();String bytes = ByteUtils.toHexAscii(data);return bytes;
}

轻云UC设计器实例

基础信息

组件名称 ： modbus-connector
组件版本： 1.0.0
组件类型： 系统默认
状 态： 正式发布
组件描述：通过MODBUS 连接网关，采集或下发相关指令到设备端。

配置文件：

配置文件作为MODBUS配置界面元素的基础，MODBUS所有高级配置均可以通过重构该配置文件体现在前端界面上。配置参数分为三组： 基础配置，连接配置，高级配置，一般情况可以随意扩展高级配置。

注： 配置文件仅供修改升级组件式利用，一般情况下对用户透明。无需做任何更改，除非用户需要手动维护组件心跳或通信端口时，一般情况下禁止修改。

df:component:name: modbus-connectortype: 2   #1:采集器;2:接收器;3:转换器;4:存储器;5:解析器;6:状态解析器:7:同步器;8:消息通知transportPort: 49096    #内部akka通信端口heartbeatCron: 0/30 * * ? * * *       #网关心跳数据上报时间#########本地环境用##########instance-id: 998topic: DEMO-TOPIC-998response-topic: DEMO-TOPIC-RESPONSE-198executor:akka-address: 192.168.3.195:49095rest-address: 192.168.3.195:49090#############结束##############parameter:connection[0]:                      #组件连接参数数组name: Host                        #参数名称，自定义key: hostName                     #参数key，自定义required: true                    #是否必传 true或falsevalue-type: string                #参数值类型，支持 string, int, floatdefault-value: 127.0.0.1          #参数默认值，自定义input-type: input                 #参数输入类型，支持 input-输入框，select-下拉框description: 数据采集端TCP 连接地址                 #参数值描述，自定义connection[1]:name: Portkey: portrequired: truevalue-type: intinput-type: inputdefault-value: 502description: Modbus数据采集端TCP连接端口号connection[2]:name: 设备编号key: equipmentIdrequired: truevalue-type: stringinput-type: inputdefault-value: 80100012description: 设备编号(平台分配得设备编号)base[0]:name: 从站编号key: slaveIdrequired: truevalue-type: intinput-type: inputdescription: 采集设备序号（slaveId即设备地址)base[1]:name: 功能码key: functionCoderequired: falsevalue-type: intinput-type: selectselect-option: 01|1,02|2,03|3,04|4,05|5,15|15,6|6,16|16description: 命名空间功能码 [1:读线圈状态、2:读离散输入状态、3:读保持寄存器、4:读输入寄存器,5:写单个线圈,15:写多个线圈,6:写单个保持寄存器,16:写多个保持寄存器]base[2]:name: 偏移量key: offsetrequired: falsevalue-type: intinput-type: inputdescription: 偏移量base[3]:name: 数量key: numberOfRegistersrequired: truevalue-type: intinput-type: inputdefault-value: 1description: 继承器数量(从偏移量开始读取多少个继承器）base[4]:name: Encapsulatedkey: encapsulatedrequired: falsevalue-type: intinput-type: selectselect-option: true|1,false|2default-value: 1description: Master发送指令到slave时得消息格式为EncapMessage或者XaMessageadvance[0]:name: CRONkey: cronrequired: truevalue-type: stringinput-type: inputdefault-value: 1/10 * * ? * * *description: 网关采集器定时任务

组件测试

  1. 配置网关

从组件列表中选择modbus-connector并拖动到作业设计器。
image.png

  1. 参数说明

修改右侧配置参数并保存，参数使用说明可以通过每个参数旁边的?查看。
image.png
参数含义可以对照Modbus Slave 软件中的相关信息。 Modbus Slave 下载
image.png

  1. 启动网关

注意观察执行日志，确保网关正常运行，状态status 字段为1时表示正常运行中
image.png

  1. 测试验证

1）前提准备：
下载并启动 Modbus Slave 调试工具
image.png

连接成功后记录相关信息：
IP： 192.168.3.45
Port : 502
Slave ID: 1
function code ： 3
偏移量： 0 （我们以0位作为测试数据）

2）进入到轻云UC通用设计中心，进入到设计器，并拖动modbus-connector组件到画板。
按规上面modbus slave 中的配置信息，设定好modbus-connector配置信息：
image.png
image.png
注意配置中的功能码，偏移量，从站编号，IP ，端口，需要与测试工具中的配置信息一致。
3）切换到UC设计器，重启modbus-connector网关，可以从执行日志板块看到数据。
这里的数据时定时获取的，通过配置参照中的表达式。如： 1/10 * * ? * * * 每10秒获取一次数据。
image.png

你可以通过Qinghub作业直接体验试用，也可以根据手册开发相应的代码块。 qinghub项目已经全面开源。
源码文件地址: https://gitee.com/qingplus/qingcloud-platform
qinghub作业配置

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/748077.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

sqllab第十九关通关笔记

sqllab第十九关通关笔记

知识点&#xff1a; 错误注入 最大长度为32位&#xff1b;如果目标长度>32时&#xff0c;需要利用截取函数进行分段读取referer注入 insert语句update语句 通过admin admin进行登录发现页面打印除了referer字段的信息 这应该是一个referer注入 首先进行测试一下 构造payl…
阅读更多...
基于SpringBoot和Echarts的全国地震可视化分析实战

基于SpringBoot和Echarts的全国地震可视化分析实战

目录 前言 一、后台数据服务设计 1、数据库查询 2、模型层对象设计 3、业务层和控制层设计 二、Echarts前端配置 1、地图的展示 2、次数排名统计 三、最终结果展示 1、地图展示 2、图表展示 总结 前言 在之前的博客中基于SpringBoot和PotsGIS的各省地震震发可视化分…
阅读更多...
C++提高笔记（四）---STL容器（stack、queue、list）

C++提高笔记（四）---STL容器（stack、queue、list）

1、stack容器&#xff08;栈&#xff09; 1.1 栈stack基本概念 概念&#xff1a;stack是一种先进后出&#xff08;First In Last Out&#xff0c;FILO&#xff09;的数据结构&#xff0c;它只有一个出口 栈中只有顶端的元素才可以被外界调用&#xff0c;因此栈不允许有遍历行…
阅读更多...
使用C#的winform控制数据库实例服务的运行状态

使用C#的winform控制数据库实例服务的运行状态

一、得到sqlserver的实例名 二、引用对应的程序集和命名空间 using System.ServiceProcess; C#操作服务要用的类 ServiceController 声明类 private ServiceController serviceController new ServiceController("MSSQLSERVER"); 三、判断服务状态 serviceCon…
阅读更多...
上证指数000001行情数据API接口

上证指数000001行情数据API接口

# 测试&#xff1a;返回不超过10条数据&#xff08;2年历史&#xff09; https://tsanghi.com/api/fin/index/CHN/daily?tokendemo&ticker000001&order2Python示例 import requestsurl f"https://tsanghi.com/api/fin/index/CHN/daily?tokendemo&ticker000…
阅读更多...
要将镜像推送到GitLab的Registry中的步骤

要将镜像推送到GitLab的Registry中的步骤

1、通过cli 模式登录gitlab &#xff08;命令行模式&#xff09; docker login git.asc-dede.de Username: haiyang Password: Login Succeeded 2、查看我的本地镜像&#xff1a; 3&#xff0c;推送镜像apollo_core到对应的gitlab项目的Registry 中 docker push registry.gi…
阅读更多...
「Linux系列」Linux简介及常见的Linux系统

「Linux系列」Linux简介及常见的Linux系统

文章目录 一、Linux简介二、常见的Linux系统三、Linux 应用领域四、Linux对比Windows五、相关链接 一、Linux简介 Linux是一种自由和开放源代码的类Unix操作系统&#xff0c;它最初是作为Unix操作系统的替代品而开发的。Linux操作系统的内核由林纳斯托瓦兹在1991年首次发布&am…
阅读更多...
Sunday 算法介绍

Sunday 算法介绍

1. Sunday 算法介绍 「Sunday 算法」 是一种在字符串中查找子串的算法&#xff0c;是 Daniel M.Sunday 于1990年提出的字符串模式匹配算法。 Sunday 算法思想&#xff1a;对于给定文本串 T 与模式串 p&#xff0c;先对模式串 p 进行预处理。然后在匹配的过程中&#xff0c;当发…
阅读更多...
UE5.1 iClone8 正确导入角色骨骼与动作

UE5.1 iClone8 正确导入角色骨骼与动作

使用iClone8插件Auto Setup 附录下载链接 里面有两个文件夹,使用Auto Setup C:\Program Files\Reallusion\Shared Plugins 在UE内新建Plugins,把插件复制进去 在工具栏出现这三个人物的图标就安装成功了 iClone选择角色,导入动作 选择导出FBX UE内直接导入 会出现是否启动插件…
阅读更多...
docker的常用指令

docker的常用指令

docker的常用指令 从docker镜像仓库&#xff0c;搜索所有和mysql有关的镜像 docker search mysql 从docker仓库拉取mysql docker pull mysql这里的mysql是指使用search搜索出来的所有容器的NAME 如果和我一样遇到以下问题&#xff1a; 我可以登录阿里云的官网&#xff0c;找…
阅读更多...
基于springboot+vue实现计算机等级考试报名系统项目【项目源码+论文说明】计算机毕业设计

基于springboot+vue实现计算机等级考试报名系统项目【项目源码+论文说明】计算机毕业设计

基于springbootvue实现计算机等级考试报名演示 摘要 在进入二十一世纪之后&#xff0c;网络发展越来越迅速&#xff0c;人们的很多生活习惯与消费习惯都随之发生了改变&#xff0c;计算机技术为人们的生活带来了很多的便利。而计算机技术是我国各个教育阶段中的一门必修课程&a…
阅读更多...
Golang中map数据结构字段解析

Golang中map数据结构字段解析

Golang里map底层数据结构具体如下图所示&#xff1a; map其实就是一个指向 hmap 的指针&#xff0c;占用了8个字节 hmap各自段存放的字段意义如下&#xff1a; 字段含义countmap中元素的个数&#xff0c;对应len (map)的值flags状态标志位&#xff0c;标记map的一些状态B桶数…
阅读更多...
Spring中使用内置的tomcat容器启动后自动退出问题解决方法

Spring中使用内置的tomcat容器启动后自动退出问题解决方法

在Spring中使用内置的tomcat 启动后自动退出 退出代码为0 且不报任务错误的解决方法. 日志如下: Connected to the target VM, address: 127.0.0.1:51129, transport: socket 三月 15, 2024 11:55:00 下午 org.apache.coyote.AbstractProtocol init 信息: Initializing Proto…
阅读更多...
C/C++ Socket 获取或设置 TCP MSS 大小

C/C++ Socket 获取或设置 TCP MSS 大小

通过 Socket 系统接口&#xff0c;链接到一个TCP服务器&#xff0c;那么在链接成功之后会被配置一个从本地端到目的端最佳的TCP_MSS大小。 我们通过这个特点&#xff0c;即可轻松的实现&#xff0c;链路MTU大小发现功能&#xff0c;在不依赖ROOT管理员权限的情况下&#xff0c;…
阅读更多...
免费阅读篇 | 芒果YOLOv8改进111：注意力机制CBAM：轻量级卷积块注意力模块，无缝集成到任何CNN架构中，开销可以忽略不计

免费阅读篇 | 芒果YOLOv8改进111：注意力机制CBAM：轻量级卷积块注意力模块，无缝集成到任何CNN架构中，开销可以忽略不计

&#x1f4a1;&#x1f680;&#x1f680;&#x1f680;本博客 改进源代码改进 适用于 YOLOv8 按步骤操作运行改进后的代码即可 该专栏完整目录链接&#xff1a; 芒果YOLOv8深度改进教程 该篇博客为免费阅读内容&#xff0c;YOLOv8CBAM改进内容&#x1f680;&#x1f680;&am…
阅读更多...
ansible 部署FATE集群单边场景

ansible 部署FATE集群单边场景

官方文档&#xff1a; https://github.com/FederatedAI/AnsibleFATE/blob/main/docs/ansible_deploy_FATE_manual.md https://github.com/FederatedAI/AnsibleFATE/blob/main/docs/ansible_deploy_two_sides.md gitee详细文档&#xff1a; docs/ansible_deploy_one_side.md…
阅读更多...
确保云原生部署中的网络安全

确保云原生部署中的网络安全

数字环境正在以惊人的速度发展&#xff0c;组织正在迅速采用云原生部署和现代化使用微服务和容器构建的应用程序&#xff08;通常运行在 Kubernetes 等平台上&#xff09;&#xff0c;以推动增长。 无论我们谈论可扩展性、效率还是灵活性&#xff0c;对于努力提供无与伦比的用…
阅读更多...
服务器遭遇挖矿病毒syst3md及其伪装者rcu-sched：原因、症状与解决方案

服务器遭遇挖矿病毒syst3md及其伪装者rcu-sched：原因、症状与解决方案

01 什么是挖矿病毒 挖矿病毒通常是恶意软件的一种&#xff0c;它会在受感染的系统上无授权地挖掘加密货币。关于"syst3md"&#xff0c;是一种特定的挖矿病毒&#xff0c;它通过在受感染的Linux系统中执行一系列复杂操作来达到其目的。这些操作包括使用curl从网络下载…
阅读更多...
爬虫逆向实战(36)-某建设监管平台(RSA，魔改)

爬虫逆向实战(36)-某建设监管平台(RSA，魔改)

一、数据接口分析 主页地址&#xff1a;某建设监管平台 1、抓包 通过抓包可以发现网站首先是请求了一个/prod-api/mohurd-pub/vcode/genVcode的接口&#xff0c;用于获取滑块验证码的图片 滑块验证之后&#xff0c;请求了/prod-api/mohurd-pub/dataServ/findBaseEntDpPage这…
阅读更多...
【C语言】—— 指针一 ： 初识指针（上）

【C语言】—— 指针一 ： 初识指针（上）

【C语言】—— 指针一 &#xff1a; 初识指针&#xff08;上&#xff09; 一、内存和地址1.1、如何理解内存和地址1.2、 如何理解编址 二、指针变量和地址2.1、取地址操作符 &2.2、 指针变量2.3、 解引用操作符 ∗ * ∗2.4、指针变量的大小 三、指针变量类型的意义3.1、 指…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023