java中使用modbusTcp与plc通信

本人只是用此协议写过上位机，所以这里介绍的只是在java中的一些使用

首先引入jar包

    <dependency><groupId>com.intelligt.modbus</groupId><artifactId>jlibmodbus</artifactId><version>1.2.9.7</version></dependency>

下面是自己封装的统一连接类

@Data
@Slf4j
public class ModBusConnector {private static final Map<InetAddress, ModBusConnector> connectorMap = new HashMap<>();private static final int MOD_BUS_PORT = 502;private static final int SERVER_ADDRESS = 1;private static final boolean KEEP_ALIVE = true;private final ModbusMaster modbusMaster;private final InetAddress ip;protected ModBusConnector(ModbusMaster modbusMaster,InetAddress ip) {this.modbusMaster = modbusMaster;this.ip = ip;}public static ModBusConnector fetchOrCreate(InetAddress ip, int timeout) {ModBusConnector connector = connectorMap.get(ip);if (connector == null) {ModbusMaster masterTCP = ModbusMasterFactory.createModbusMasterTCP(new TcpParameters(ip, MOD_BUS_PORT, KEEP_ALIVE));connector = new ModBusConnector(masterTCP, ip);}log.info("ModBus connector connecting: {}", connector);connector.getModbusMaster().setResponseTimeout(timeout);try {connector.getModbusMaster().connect();log.info("ModBus connector connected: {}", connector);} catch (ModbusIOException e) {throw new IllegalStateException(e+ip.getHostAddress());}return connector;}public static ModBusConnector fetchOrCreate(InetAddress ip) {return fetchOrCreate(ip, 3000);}public ReadHoldingRegistersResponse readRegisters(PlcReadRequest readRequest) {return WrappingUtil.runWithRetry(() -> {final long sending = System.currentTimeMillis();
//                log.debug("sending modbus read request: " +
//                        "waiting consume {}ms, ip={}, request={}", (sending - wait), ip, readRequest);ModbusRequest request;synchronized (modbusMaster) {try {if (!modbusMaster.isConnected()) {modbusMaster.connect();}request = ModbusRequestBuilder.getInstance().buildReadHoldingRegisters(SERVER_ADDRESS,readRequest.getStartAddress(),readRequest.getQuantity());final ReadHoldingRegistersResponse response = (ReadHoldingRegistersResponse) modbusMaster.processRequest(request);if (response.isException()) {throw new IllegalStateException("ModBus返回异常：" + response.getModbusExceptionCode());}final long sent = System.currentTimeMillis();log.debug("Successfully sent modbus read request : " +"sending consume {}ms, ip={}, request={}, response: {}",(sent - sending),ip,readRequest,response.getHoldingRegisters().getRegisters());return response;} catch (Exception e) {if (isConnected()) {disconnect();}throw new IllegalStateException(e);}}}, PlcConfig.getRetryTimes(),new IllegalStateException("failed refresh rgv status"+ip.getHostAddress()));}public void writeRegisters(PlcWriteRequest writeRequest) {WrappingUtil.runWithRetry (() -> {final long wait = System.currentTimeMillis ();final long sending = System.currentTimeMillis ();log.debug ("sending modbus write request: " +"waiting consume {}ms, ip={}, request={}", (sending - wait), ip, writeRequest);ModbusRequest request;synchronized (modbusMaster) {try {if (!modbusMaster.isConnected()) {modbusMaster.connect();}request = ModbusRequestBuilder.getInstance().buildWriteMultipleRegisters(SERVER_ADDRESS,writeRequest.getStartAddress(),writeRequest.getRegisters());ModbusResponse response = modbusMaster.processRequest(request);final long sent = System.currentTimeMillis();log.info("successfully sent modbus write request : time={}" +"sending consume {}ms, ip={},  request={}, response: {}",System.currentTimeMillis(),(sent - sending),ip,writeRequest,response.getModbusExceptionCode());} catch (Exception e) {if (isConnected()) {disconnect();}throw new IllegalStateException(e);}}}, PlcConfig.getRetryTimes (),new IllegalStateException("failed send command rgv status"+ip.getHostAddress()));}public boolean isConnected() {return modbusMaster.isConnected();}public void disconnect() {if (modbusMaster != null) {if (!modbusMaster.isConnected()) {log.info("connection already disconnected {}",this);} else {try {modbusMaster.disconnect();} catch (ModbusIOException e) {log.info("modbus disconnected false: {}",this,e);throw new IllegalStateException(e);}log.info("modbus disconnected success: {}",this);}}}}

代码快中用到了自己封装的工具类会放在文章结尾，这里截图解释以下关键部分

建立连接

读请求

写请求

关键理解

java中每个 int 是 4个字节 32位，但是寄存器中int数据类型是 16 位，而一个int类型就是寄存器中的一个地址位。
好比我想在寄存器的第2个地址位的倒数第2个bit位写入 1，那么java中构建的就是
int [2] = new int[2]
int[1] = 1<<2//第几个bit位就要向前移几位
注意，此时随在第二个地址位写了数值 2，但是由于java中int默认值是0，所以这样构建还会把第一个地址位数据置0，所以如果不想影响到第一个地址为数值，需要如下构建
int [1] = new int[1]
int[0] = 1<<2//第几个bit位就要向前移几位
此时下发时起始地址为要携程 1，不能再是 0

还有一点要注意的，一个plc中一个int如果只用了 8 个bit位，那么这 8个bit位是 16位中的高8位，即先高8位后低8位。

java中使用modbusTcp与plc通信相关推荐

java中实现与USB硬件通信
目前在网络上查询java与usb的设备通信资源都非常的少大多都来自一个05年的文章,本人也摘取了网上的例子,例子中直接运行也出现了一些问题,经过debug还是可以直接在windows上直接使用java ...
JAVA与西门子S7 PLC通信，方式一：S7connector
背景在公司项目中,需要用到和PLC进行通讯,经过搜索后查询到使用JAVA与PLC通信两种方式,测试后达到正常读写的目的,于是记录下学习过程. 环境 Spring+SpringMVC+MybatisP ...
Java中利用socket实现简单的服务端与客户端的通信（中级）——实现任意双向通信
本文计划采用socket实现客户端和服务端的任意双向通信,即客户端可以随时给服务端发消息,服务端也可以随时给客户端发消息,最终结果就是一个类似与QQ的聊天软件的功能. 以下代码可以直接拷贝到Eclip ...
Java中利用socket实现简单的服务端与客户端的通信（基础级）
在上一篇文章中,简单的介绍了java中入门级的socket编程,简单的实现了客户端像服务器端发送数据,服务器端将数据接收并显示在控制台,没有涉及多线程.上一篇文章的链接:Java中利用socket实现 ...
gPRC简介以及Java中使用gPRC实现客户端与服务端通信(附代码下载)
场景 ProtoBuf的介绍以及在Java中使用protobuf将对象进行序列化与反序列化: https://blog.csdn.net/BADAO_LIUMANG_QIZHI/article/det ...
Java中Socket通信-客户端与服务端相互传输对象数据
场景 Java中Socket通信-服务端和客户端双向传输字符串实现: https://blog.csdn.net/BADAO_LIUMANG_QIZHI/article/details/1084885 ...
Java中Socket通信-客户端向服务端发送照片
场景 Java中Socket通信-服务端和客户端双向传输字符串实现: https://blog.csdn.net/BADAO_LIUMANG_QIZHI/article/details/1084885 ...
Java中Socket通信-服务端和客户端双向传输字符串实现
场景什么是socket 在计算机通信领域,socket 被翻译为"套接字",它是计算机之间进行通信的一种约定或一种方式.通过 socket 这种约定,一台计算机可以接收其他计算机 ...
connect: 网络不可达_Java网络编程和NIO详解1：JAVA 中原生的 socket 通信机制
本文转自:https://github.com/jasonGeng88/blog 本系列文章将整理到我在GitHub上的<Java面试指南>仓库,更多精彩内容请到我的仓库里查看 https ...
asp.core api 通过socket和服务器通信发送udp_读懂Java中的Socket编程
Socket,又称为套接字,Socket是计算机网络通信的基本的技术之一.如今大多数基于网络的软件,如浏览器,即时通讯工具甚至是P2P下载都是基于Socket实现的.本文会介绍一下基于TCP/IP的S ...