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

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

业务需求

采集冷柜温控采集器的温度，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 {
        // 获取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;
        }
    }

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

更多实现参考

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