首页 > 其他分享 >SpringBoot+modbus4j实现ModebusTCP通讯读取数据

SpringBoot+modbus4j实现ModebusTCP通讯读取数据

时间：2024-01-04 11:01:11浏览次数：33  
标签：modbus4j 读取数据 serotonin master import com throws SpringBoot


场景

Windows上ModbusTCP模拟Master与Slave工具的使用：

Windows上ModbusTCP模拟Master与Slave工具的使用

Modebus TCP

Modbus由MODICON公司于1979年开发，是一种工业现场总线协议标准。

1996年施耐德公司推出基于以太网TCP/IP的Modbus协议：ModbusTCP。

Modbus协议是一项应用层报文传输协议，包括ASCII、RTU、TCP三种报文类型。

标准的Modbus协议物理层接口有RS232、RS422、RS485和以太网接口，采用master/slave方式通信。

Modbus的操作对象有四种：

线圈、离散输入、保持寄存器、输入寄存器。

Modbus功能码：

SpringBoot+modbus4j实现ModebusTCP通讯读取数据_spring boot

关于Java的开源库：

Jamod：

Java Modbus实现：Java Modbus库。该库由Dieter Wimberger实施。

ModbusPal：

ModbusPal是一个正在进行的Java项目，用于创建逼真的Modbus从站模拟器。

下面介绍基于Modebus4j实现读线圈状态数据。

由于预定义的数学函数和/或Python脚本，寄存器值是动态生成的。

ModbusPal依赖于RxTx进行串行通信，而Jython则依赖于脚本支持。

Modbus4J：

Serotonin Software用Java编写的Modbus协议的高性能且易于使用的实现。

支持ASCII，RTU，TCP和UDP传输作为从站或主站，自动请求分区，响应数据类型解析和节点扫描。

JLibModbus：

JLibModbus是java语言中Modbus协议的一种实现。jSSC和RXTX用于通过串行端口进行通信。

该库是一个经过积极测试和改进的项目。

注：

博客：
霸道流氓气质_C#,架构之路,SpringBoot

实现

1、基于modbus4j实现线圈状态数据的读取。

modbus4j

GitHub - MangoAutomation/modbus4j: A high-performance and ease-of-use implementation of the Modbus protocol written in Java. Supports ASCII, RTU, TCP, and UDP transports as slave or master, automatic request partitioning and response data type parsing.

按照官网介绍，需要在pom文件中添加repository的配置

<repositories>
        <repository>
            <releases>
                <enabled>false</enabled>
            </releases>
            <snapshots>
                <enabled>true</enabled>
            </snapshots>
            <id>ias-snapshots</id>
            <name>Infinite Automation Snapshot Repository</name>
            <url>https://maven.mangoautomation.net/repository/ias-snapshot/</url>
        </repository>
        <repository>
            <releases>
                <enabled>true</enabled>
            </releases>
            <snapshots>
                <enabled>false</enabled>
            </snapshots>
            <id>ias-releases</id>
            <name>Infinite Automation Release Repository</name>
            <url>https://maven.mangoautomation.net/repository/ias-release/</url>
        </repository>
    </repositories>

添加位置

SpringBoot+modbus4j实现ModebusTCP通讯读取数据_spring boot_02

然后添加依赖

<dependency>
            <groupId>com.infiniteautomation</groupId>
            <artifactId>modbus4j</artifactId>
            <version>3.0.3</version>
        </dependency>

2、新建modbus4j工具类

package com.badao.demo.utils;

import com.serotonin.modbus4j.BatchRead;
import com.serotonin.modbus4j.BatchResults;
import com.serotonin.modbus4j.ModbusFactory;
import com.serotonin.modbus4j.ModbusMaster;
import com.serotonin.modbus4j.exception.ErrorResponseException;
import com.serotonin.modbus4j.exception.ModbusInitException;
import com.serotonin.modbus4j.exception.ModbusTransportException;
import com.serotonin.modbus4j.ip.IpParameters;
import com.serotonin.modbus4j.locator.BaseLocator;

public class Modbus4jUtils {

    /**
     * 工厂。
     */
    static ModbusFactory modbusFactory;

    static {
        if (modbusFactory == null) {
            modbusFactory = new ModbusFactory();
        }
    }

    /**
     * 获取master
     *
     * @return
     * @throws ModbusInitException
     */
    public static ModbusMaster getMaster(String ip,int port) throws ModbusInitException {
        IpParameters params = new IpParameters();
        params.setHost(ip);
        params.setPort(port);
        // modbusFactory.createRtuMaster(wapper); //RTU 协议
        // modbusFactory.createUdpMaster(params);//UDP 协议
        // modbusFactory.createAsciiMaster(wrapper);//ASCII 协议
        ModbusMaster master = modbusFactory.createTcpMaster(params, false);// TCP 协议
        master.init();
        return master;
    }

    /**
     * 读取[01 Coil Status 0x]类型 开关数据
     *
     * @param slaveId
     *            slaveId
     * @param offset
     *            位置
     * @return 读取值
     * @throws ModbusTransportException
     *             异常
     * @throws ErrorResponseException
     *             异常
     */
    public static Boolean readCoilStatus(ModbusMaster master,int slaveId, int offset)
            throws ModbusTransportException, ErrorResponseException {
        // 01 Coil Status
        BaseLocator<Boolean> loc = BaseLocator.coilStatus(slaveId, offset);
        Boolean value = master.getValue(loc);
        return value;
    }

    /**
     * 读取[02 Input Status 1x]类型 开关数据
     *
     * @param slaveId
     * @param offset
     * @return
     * @throws ModbusTransportException
     * @throws ErrorResponseException
     */
    public static Boolean readInputStatus(ModbusMaster master,int slaveId, int offset)
            throws ModbusTransportException, ErrorResponseException {
        // 02 Input Status
        BaseLocator<Boolean> loc = BaseLocator.inputStatus(slaveId, offset);
        Boolean value = master.getValue(loc);
        return value;
    }

    /**
     * 读取[03 Holding Register类型 2x]模拟量数据
     *
     * @param slaveId
     *            slave Id
     * @param offset
     *            位置
     * @param dataType
     *            数据类型,来自com.serotonin.modbus4j.code.DataType
     * @return
     * @throws ModbusTransportException
     *             异常
     * @throws ErrorResponseException
     *             异常
     */
    public static Number readHoldingRegister(ModbusMaster master,int slaveId, int offset, int dataType)
            throws ModbusTransportException, ErrorResponseException {
        // 03 Holding Register类型数据读取
        BaseLocator<Number> loc = BaseLocator.holdingRegister(slaveId, offset, dataType);
        Number value = master.getValue(loc);
        return value;
    }

    /**
     * 读取[04 Input Registers 3x]类型 模拟量数据
     *
     * @param slaveId
     *            slaveId
     * @param offset
     *            位置
     * @param dataType
     *            数据类型,来自com.serotonin.modbus4j.code.DataType
     * @return 返回结果
     * @throws ModbusTransportException
     *             异常
     * @throws ErrorResponseException
     *             异常
     */
    public static Number readInputRegisters(ModbusMaster master,int slaveId, int offset, int dataType)
            throws ModbusTransportException, ErrorResponseException {
        // 04 Input Registers类型数据读取
        BaseLocator<Number> loc = BaseLocator.inputRegister(slaveId, offset, dataType);
        Number value = master.getValue(loc);
        return value;
    }

    /**
     * 批量读取使用方法
     *
     * @throws ModbusTransportException
     * @throws ErrorResponseException
     * @throws ModbusInitException
     * @return
     */
    public static BatchResults<Integer> batchRead(ModbusMaster master,BatchRead<Integer> batchRead) throws ModbusTransportException, ErrorResponseException, ModbusInitException {
        // 是否连续请求
        batchRead.setContiguousRequests(false);
        BatchResults<Integer> results = master.send(batchRead);
        return results;
    }
}

3、使用方式

新建master

ModbusMaster master = Modbus4jUtils.getMaster(modebustcpIp, port);

这里的ip和端口来自配置文件

单个读取数据

Boolean aBoolean = Modbus4jUtils.readCoilStatus(master, 1, 0);

这里1代表slaveId,0代表offset

批量读取数据

BatchRead<Integer> batch = new BatchRead<>();
        List<Locator> locatorList = locatorConfig.getLocatorList();
        locatorList.forEach(locator -> batch.addLocator(locator.getId(), BaseLocator.coilStatus(locator.getSlaveId(),locator.getOffset())));

        BatchResults<Integer> batchResults = Modbus4jUtils.batchRead(master, batch);
        Boolean valueOne = (Boolean) batchResults.getValue(0);
        Boolean valueTwo = (Boolean) batchResults.getValue(1);
        Boolean valueThree = (Boolean) batchResults.getValue(2);

这里批量读取的配置来自配置文件

4、业务示例

在定时任务中批量读取指定slaveId和offset的线圈状态数据

import com.badao.demo.config.LocatorConfig;
import com.badao.demo.entity.Locator;
import com.badao.demo.utils.Modbus4jUtils;
import com.serotonin.modbus4j.BatchRead;
import com.serotonin.modbus4j.BatchResults;
import com.serotonin.modbus4j.ModbusMaster;
import com.serotonin.modbus4j.exception.ErrorResponseException;
import com.serotonin.modbus4j.exception.ModbusInitException;
import com.serotonin.modbus4j.exception.ModbusTransportException;
import com.serotonin.modbus4j.locator.BaseLocator;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import java.time.LocalDateTime;
import java.util.List;

@Configuration
@EnableScheduling
public class GetModbusTCPDataTask {

    @Value("${modebustcp.ip}")
    private String modebustcpIp;

    @Value("${modebustcp.port}")
    private Integer port;

    @Autowired
    private LocatorConfig locatorConfig;

    @Scheduled(fixedRateString = "2000")
    public void  getData() throws ModbusInitException {
        ModbusMaster master = Modbus4jUtils.getMaster(modebustcpIp, port);
        BatchRead<Integer> batch = new BatchRead<>();
        List<Locator> locatorList = locatorConfig.getLocatorList();
        locatorList.forEach(locator -> batch.addLocator(locator.getId(), BaseLocator.coilStatus(locator.getSlaveId(),locator.getOffset())));
        try {
            //单个读取
            //Boolean aBoolean = Modbus4jUtils.readCoilStatus(master, 1, 0);
            //批量读取
            BatchResults<Integer> batchResults = Modbus4jUtils.batchRead(master, batch);
            Boolean valueOne = (Boolean) batchResults.getValue(0);
            Boolean valueTwo = (Boolean) batchResults.getValue(1);
            Boolean valueThree = (Boolean) batchResults.getValue(2);
            System.out.println(LocalDateTime.now());
            System.out.println("valueOne:"+valueOne);
            System.out.println("valueTwo:"+valueTwo);
            System.out.println("valueThree:"+valueThree);
        } catch (ModbusTransportException e) {
            e.printStackTrace();
        } catch (ErrorResponseException e) {
            e.printStackTrace();
        } catch (ModbusInitException e) {
            e.printStackTrace();
        }
    }
}

5、本地测试效果

SpringBoot+modbus4j实现ModebusTCP通讯读取数据_数据_03

6、线上测试效果

线上使用RS485转以太网模块，会将其转换成MODBUS TCP服务端，端口为默认502，slaveid为2

SpringBoot+modbus4j实现ModebusTCP通讯读取数据_后端_04

通讯测试效果

SpringBoot+modbus4j实现ModebusTCP通讯读取数据_数据_05

7、SpringBoot中进行ModbusTCP通讯时提示：

com.serotonin.modbus4j.exception.ErrorResponseException:Illegal function

SpringBoot+modbus4j实现ModebusTCP通讯读取数据_数据_06

这是因为功能码不对应，使用Modbus Slave Definition定义的功能码为03 Holding Register(4x),而在代码中连接后执行的是读取线圈状态的功能码

SpringBoot+modbus4j实现ModebusTCP通讯读取数据_Boo_07

所以将功能码修改对应即可

SpringBoot+modbus4j实现ModebusTCP通讯读取数据_数据_08

标签：modbus4j,读取数据,serotonin,master,import,com,throws,SpringBoot
From： https://blog.51cto.com/BADAOLIUMANGQZ/9097091

相关文章

  • SpringBoot中读取yml中配置的list对象的配置项
    场景SpringBoot中通过ConfigurationProperties注解的方式读取application.yml中配置的属性值：SpringBoot中通过ConfigurationProperties注解的方式读取application.yml中配置的属性值_demoenabled:true参考上面获取yml配置文件中简单的配置项的方式。如果需要获取application.yml中......
  • 记录Springboot项目部署到服务器
    搞了一个月，开发了一个缩减版的管理系统，主要功能：对于进入海康门禁的老师，需要填报使用记录。用Springboot开发真的是便捷，专注于业务开发，不关心底层和架构。第一步：搭建配置服务器服务器：虚拟机Windows2016Server 64bit，内存32G，磁盘400GMysql：8.0.34Springboot：3.0.11IDEA：2023.1Ja......
  • 【微服务】springboot整合kafka-stream使用详解
    目录一、前言二、kafkastream概述2.1什么是kafkastream2.2为什么需要kafkastream2.2.1对接成本低2.2.2节省资源2.2.3使用简单2.3kafkastream特点2.4kafkastream中的一些概念2.5 KafkaStream应用场景三、环境准备3.1搭建zk3.1.1自定义docker网络3.1.2 拉取zk镜像3.......
  • 【JDK新特性】JDK和Springboot各版本新特性介绍
    目录参考资料以下是一些较新版本的JDK的主要新特性介绍：JDK8：Lambda表达式：引入了函数式编程的概念，使得代码更简洁、可读性更强。StreamAPI：提供了一种高效处理集合数据的方式，支持并行处理。默认方法（DefaultMethods）：接口可以包含具有默认实现的方法。方法引用（MethodReferences）：通过......
  • SpringBoot接入Mybatis-Flex
    相信不少的伙伴在日常开发中应该都用过MyBatis增强框架吧，目前来说国内用的比较多的无非就是MyBatis-Plus，那么今天我再给大家介绍一款新的MyBatis增强框架，它就是MyBatis-Flex。那么这个框架到底怎么样呢，跟MyBatis-Plus有什么不一样的呢，下面我们先来看下它的介绍，这是官网的一段介......
  • SpringBoot2 整合 Eurkea 实例
    文章目录1.概述2.注册示例2.1工程目录2.2引入依赖2.3启动类2.4配置文件2.5启动服务注册中心3.服务提供者(eurekaclient)实例3.1工程目录3.2引入依赖3.3Java源文件3.5配置文件3.6启动服务提供者参考文献1.概述Eurkea主要负责服务治理功能。服务治理主要用来实现各......
  • SpringBoot2 整合 SpringCloud Feign 实例
    文章目录1.简介2.工程实例2.1注册中心springcloud-study-eureka-server2.1.1依赖pom.xml2.1.2配置文件application.properties2.1.3启动类EurekaServerApplication.java2.2服务提供者springcloud-study-hello-service2.2.1依赖pom.xml2.2.2配置文件application.ym......
  • SpringBoot2 整合 SpringCloud 的 Hystrix断路器 实例
    文章目录1.概述2.短路器3.SpringFeign使用Hystrix断路器3.1工程实例3.2修改Fegin模块3.3测试运行参考文献1.概述微服务架构中服务之间互相调用，单个服务通常会集群部署，由于网络等原因，服务不能保证100%可用，如果单个服务出现问题会出现请求的堆积，Servlet容器的线程资源......
  • SpringBoot2 整合 Redis 实例，实现写入和读取的操作
    1.启动RedisServer启动redisserver，如下图所示，端口号6379：2.工程实例2.1工程目录工程目录如下图所示：2.2pom.xml引入依赖：<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId>......
  • SpringBoot原理学习
    一、IoC/DI相关1.如何进行依赖注入？①依赖注入的三种方式Ⅰ.属性注入/***Field注入/属性注入**///@Resource(name="mySQLDbServiceImpl")//@Autowired@Qualifier(value="mySQLDbServiceImpl")privateDbServicedbService;@Aut......

赞助商

阅读排行

网站主页关于我们联系我们网站地图

本网站内容转载自其他媒体，侵权联系[admin##ips99.com]。

Copyright © 2020-2023 IPS99 版权所有 IPS99