1. Modbus协议与Java实现概述
工业自动化领域的数据采集离不开各种通信协议的支持，其中Modbus因其简单、开放的特点成为最常用的工业通信协议之一。在实际项目中，我们经常需要通过Java程序与PLC、传感器等设备进行Modbus通信。modbus4j是一个优秀的Java Modbus库，它封装了TCP、RTU等传输方式，支持功能码01-04的读写操作。
我曾在消防数据采集系统中使用modbus4j实现过温度、压力等传感器的数据采集。虽然最终我们转向了基于Netty的自定义协议解析，但modbus4j作为快速原型开发工具仍然很有价值。下面我将分享两个实用的工具类，分别实现单点读取和批量读取功能。
2. Modbus TCP通信基础配置
2.1 建立TCP连接
Modbus TCP通信需要先配置IP参数并初始化Master对象。以下是核心配置代码：
java复制public static ModbusMaster getMaster(String host, int port) throws ModbusInitException {
IpParameters params = new IpParameters();
params.setHost(host); // 设备IP地址
params.setPort(port); // 默认502端口
ModbusMaster master = modbusFactory.createTcpMaster(params, false);
master.init(); // 必须初始化
return master;
}
关键点：createTcpMaster的第二个参数keepAlive建议设为false，避免连接保持导致的资源占用。实际项目中建议使用连接池管理Master实例。
2.2 数据类型映射
Modbus寄存器存储的是原始字节数据，需要根据实际数据类型进行解析。modbus4j支持的常用数据类型：
| 数据类型 | 代码 | 字节长度 | 适用场景 |
|---|---|---|---|
| TWO_BYTE_INT | 1 | 2 | 短整型数据 |
| FOUR_BYTE_FLOAT | 2 | 4 | 浮点数 |
| EIGHT_BYTE_DOUBLE | 3 | 8 | 双精度浮点 |
3. 单点数据读取实现
3.1 四种功能码的读取方法
Modbus协议定义了四种基本读取操作，对应不同的寄存器类型：
java复制// 01功能码 - 读取线圈状态（开关量）
Boolean coilValue = readCoilStatus(1, 0);
// 02功能码 - 读取输入状态（开关量）
Boolean inputStatus = readInputStatus(1, 0);
// 03功能码 - 读取保持寄存器（模拟量）
Number holdingValue = readHoldingRegister(1, 0, DataType.FOUR_BYTE_FLOAT);
// 04功能码 - 读取输入寄存器（模拟量）
Number inputValue = readInputRegisters(1, 0, DataType.FOUR_BYTE_FLOAT);
3.2 写入操作实现
对于可写寄存器，可以使用以下写入方法：
java复制// 单个线圈写入
writeCoil(1, 0, true);
// 批量线圈写入
boolean[] values = {true, false, true};
writeCoils(1, 0, values);
注意事项：写入操作需要确保寄存器地址是可写的，否则会触发异常。实际项目中建议先读取寄存器属性表确认权限。
4. 批量读取优化方案
4.1 批量读取实现
单点读取在需要获取多个寄存器值时效率较低。modbus4j提供了BatchRead批量读取功能：
java复制BatchRead<Integer> batch = new BatchRead<>();
batch.addLocator(0, BaseLocator.inputRegister(1, 0, DataType.FOUR_BYTE_FLOAT));
batch.addLocator(1, BaseLocator.inputRegister(1, 2, DataType.FOUR_BYTE_FLOAT));
BatchResults<Integer> results = batchRead(master, batch);
float value1 = results.getValue(0).floatValue();
float value2 = results.getValue(1).floatValue();
4.2 性能优化技巧
-
非连续请求设置：
batch.setContiguousRequests(false)可以避免自动合并相邻地址请求，提高兼容性 -
合理设置超时：通过
master.setTimeout(500)设置适当的超时时间（毫秒） -
批量大小控制：单次批量请求建议不超过20个寄存器，过大可能导致响应超时
5. 常见问题排查指南
5.1 连接问题
| 现象 | 可能原因 | 解决方案 |
|---|---|---|
| ModbusInitException | 网络不通/端口错误 | 检查IP和端口，使用telnet测试连通性 |
| 响应超时 | 从站设备忙 | 增加超时时间或降低请求频率 |
5.2 数据解析异常
java复制try {
Number value = readInputRegisters(1, 0, DataType.FOUR_BYTE_FLOAT);
} catch (ErrorResponseException e) {
// 捕获设备返回的错误码
System.out.println("错误码：" + e.getErrorCode());
}
常见错误码：
- 01：非法功能码
- 02：非法数据地址
- 03：非法数据值
5.3 字节序问题
不同设备可能采用不同的字节序（Endian）。如果读取的数值明显异常，可以尝试：
java复制// 在BaseLocator后设置字节序
BaseLocator<Number> loc = BaseLocator.inputRegister(1, 0, DataType.FOUR_BYTE_FLOAT);
loc.setEndian(Endian.BIG); // 或Endian.LITTLE
6. 进阶开发建议
虽然modbus4j使用方便，但在高并发场景下性能有限。我们的项目后期改用Netty实现自定义协议解析，主要出于以下考虑：
- 性能需求：需要支持1000+设备的并发连接
- 协议扩展：需要在Modbus基础上添加自定义字段
- 精细控制：需要优化TCP包的拆分/合并策略
对于大多数常规应用场景，modbus4j已经完全够用。建议在以下情况考虑自定义实现：
- 设备数量超过500台
- 需要每秒多次高频采集
- 协议有特殊扩展需求
最后分享一个调试技巧：使用Modbus Poll工具先验证通信正常，再用代码实现。这样可以快速定位是网络问题还是代码问题。