温控采集器对接-java版-modbus4j

时间：2022-10-15 19:58:27

@​​TOC​​​ ​​​看此文说明你已经了解了modbus协议，这里不再赘述​​

业务需求

采集冷柜温控采集器的温度，web端显示各个冷柜的温度（​​定时采集​​）

需求分析

1，采集温度

2.将采集的温度与对应冷柜做绑定( 本文主要采集温度，这里就不讲解绑定了。根据自身业务实现即可）

需求实现

环境准备

1.modbus-RTU转TCP

模块通过串口传输数据，由于我们要收集多个温控，显然通过串口采集数据不现实，这里我们需要将modbus-RTU转为TCP协议，然后通过TCP协议采集温度。使用​​modbus-RTU转TCP​​的设备即可满足需求。这个某宝某东一搜一大堆，如下所示：

温控采集器对接-java版-modbus4j

然后我们通过tcp采集模块中的数据即可。

2.必要参数

参数

说明

host

一般通过温控器所附带的客户端进行设置

post

一般通过温控器所附带的客户端进行设置

slaveId

设备地址

offset

寄存器地址

numberOfBits

采集数（通道）

代码实现

以下以采集一个温控设备上的数据为例 ​​以下数据均为16进制​​,假设已知如下设备信息:

设备地址

01

起始寄存器地址

00 28

通道

07

ip地址

192.168.1.154

端口

502

1.需知

​​modbus是十六进制传输协议，下文是十进制采集​​，

1

2

3

4

采集数据时需将寄存器地址（十六进制）转换为十进制

获取温度时，返回的也是十进制，唯一需要处理的是数据值除以10为实际温度

返回的温度数据2248（-2248）代表当前通道无温度数据

功能码03

2.实现

1在项目根目录下创建lib文件夹，并添加jar包​​jar包下载​​

温控采集器对接-java版-modbus4j

2.pom.xml引入依赖

<dependency>
<groupId>com.infiniteautomation</groupId>
<artifactId>modbus4j</artifactId>
<version>3.0.0</version>
<scope>system</scope>
<systemPath>${basedir}/lib/modbus4j-3.0.0.jar</systemPath>
</dependency>
<dependency>
<groupId>com.infiniteautomation</groupId>
<artifactId>modbus4j-javadoc</artifactId>
<version>3.0.0</version>
<scope>system</scope>
<systemPath>${basedir}/lib/modbus4j-3.0.0-javadoc.jar</systemPath>
</dependency>
<dependency>
<groupId>com.infiniteautomation</groupId>
<artifactId>modbus4j-sources</artifactId>
<version>3.0.0</version>
<scope>system</scope>
<systemPath>${basedir}/lib/modbus4j-3.0.0-sources.jar</systemPath>
</dependency>
<dependency>
<groupId>commons-lang</groupId>
<artifactId>commons-lang</artifactId>
<version>2.6</version>
</dependency>

3.开启定时任务启动类中添加 @EnableScheduling

4.WKJob

package com.lvyq.controller;

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.ip.IpParameters;
import com.serotonin.modbus4j.msg.ReadHoldingRegistersRequest;
import com.serotonin.modbus4j.msg.ReadHoldingRegistersResponse;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import java.io.BufferedWriter;
import java.io.File;
import java.io.FileWriter;
import java.io.IOException;
import java.text.DecimalFormat;
import java.text.SimpleDateFormat;
import java.util.*;

/**
* 温控监控测试
*/
@Component
public class WKJob {

public static ModbusFactory modbusFactory=new ModbusFactory();
/**
* 温控
* @throws Exception
*/
@Scheduled(fixedRate = 1000)
public void  job3() throws Exception{
List<String> lis = new ArrayList<>();
System.out.println("进入温控");
short[] data = readHoldingRegister("192.168.1.154",502,1,40,7);
if (data.length>0){
for (int i=0;i<data.length;i++){
System.out.println("温控:"+data[i]);
            }

        }
    }

/**
* @description: 读保持寄存器 功能码03 offset为10进制，modbus rtu 为16进制 28（十六）转40（十）
* @author: lvyq
* @date: 2022/5/17 13:53
* @version 1.0
*/

public static short[] readHoldingRegister(String host,int post,int slaveId, int offset, int numberOfBits)throws ModbusTransportException {
IpParameters params = new IpParameters();
params.setHost(host);
params.setPort(post);
params.setEncapsulated(true);
ModbusFactory modbusFactory =new ModbusFactory();
ModbusMaster master = modbusFactory.createTcpMaster(params, false);
try {
master.setTimeout(1000);
master.setRetries(3);
master.init();
        } catch (ModbusInitException e) {  e.printStackTrace(); }
//读取
ReadHoldingRegistersRequest request = new ReadHoldingRegistersRequest(slaveId, offset, numberOfBits);
ReadHoldingRegistersResponse response = (ReadHoldingRegistersResponse) master.send(request);
return response.getShortData();
    }
}

执行结果：

温控采集器对接-java版-modbus4j

至此，采集温度结束!!!

其它=

其它

写入寄存器

public static boolean writeRegisters(int slaveId, int startOffset, short[] sdata)
throws ModbusTransportException, ModbusInitException {
// 获取master
IpParameters params = new IpParameters();
params.setHost("192.168.1.154");
params.setPort(502);
params.setEncapsulated(true);
ModbusMaster master = modbusFactory.createTcpMaster(params, false);
try {
master.setTimeout(1000);
master.setRetries(3);
master.init();
        } catch (ModbusInitException e) {  e.printStackTrace(); }
// 创建请求对象
WriteRegistersRequest request = new WriteRegistersRequest(slaveId, startOffset, sdata);
// 发送请求并获取响应对象
ModbusResponse response = master.send(request);
if (response.isException()) {
//  log.error(response.getExceptionMessage());
return false;
        } else {
return true;
        }
    }

温控采集器对接-java版-modbus4j

执行上文中读的方法，结果如下：

温控采集器对接-java版-modbus4j

更多实现参考

​​https://github.com/MangoAutomation/modbus4j​​


标签：

相关文章