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

业务需求

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

需求分析

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

需求实现

环境准备

1.modbus-RTU转TCP

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

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

2.必要参数

代码实现

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

1.需知

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

2.实现

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

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();}
}

执行结果：

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

其它

写入寄存器

    public static boolean writeRegisters(int slaveId, int startOffset, short[] sdata)throws ModbusTransportException, ModbusInitException {// 获取masterIpParameters 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;}}

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

更多实现参考

https://github.com/MangoAutomation/modbus4j

如有问题，可在下方留言👇👇👇