Spring Boot Maven项目基于Modbus实现数字IO脉冲调用的方案与问题排查

云原生阿岚

2026-11-3

场景适配的最优Modbus实现选型

Maven构建的Spring Boot项目中，实现主站控制Web Relay从站、支持指定时长脉冲触发的场景，直接采用当前代码所使用的、基于Netty的异步Modbus组件即可，无需从零开发协议栈。该组件对TCP长连接的管理能力稳定，适配Spring生态的异步编程模型，相比其他Modbus实现，更适合对接Web Relay这类嵌入式Modbus设备。

脉冲触发逻辑需匹配Web Relay的寄存器设计：利用设备原生的脉冲模式寄存器，将设定的持续时长（如5秒）写入对应寄存器后触发继电器输出，由设备自身在时长达到后自动断开IO，无需在应用层通过定时任务维持输出状态，既保证脉冲精度，也不会因为应用重启导致继电器异常开启。

报错成因

not connected报错、添加sendRequest().get()后功能才正常，本质是Modbus库的异步模型和原代码的时序逻辑不匹配：

当前使用的Modbus组件为全异步非阻塞设计：master.connect()仅发起TCP连接建立动作，不等待三次握手完成、通道就绪就直接返回；sendRequest()仅将请求投递到异步任务队列，不等待请求真正发送、收到从站响应就返回。
原代码投递完异步请求后，没有等待异步任务执行完成，就立刻在主线程调用master.disconnect()。此时底层TCP连接尚未建立完成，请求通道未就绪，自然抛出连接错误。
手动添加.get()能正常工作的原因是，该方法会阻塞当前线程，直到连接建立完成、请求发送并收到响应后才继续执行，刚好规避了时序错误。但这种把异步逻辑强行转为同步阻塞的写法，会长期占用Spring业务线程池资源，高并发场景下极易引发线程池耗尽。
原代码还存在寄存器参数传值错误：WriteMultipleRegistersRequest的构造参数顺序为「起始寄存器地址、写入寄存器数量、数据缓冲区」，原代码将继电器序号作为起始地址传入，和Web Relay的寄存器映射规则不匹配，即使连接正常也可能触发设备异常。

优化实现方案

连接复用：不要每次调用都新建ModbusTcpMaster实例、反复建连断连。Web Relay类嵌入式设备的TCP连接数上限较低，反复建连极易打满设备连接资源，需在Spring容器中按设备IP维护可复用的长连接实例，配置合理的连接、请求超时参数，仅在连接异常时触发重连。
时序对齐：将连接建立、寄存器写入、触发控制、异常处理的逻辑全部串联到CompletableFuture的异步执行链中，严禁在投递异步请求后直接执行断连或其他收尾操作。等请求完成、异常捕获处理完毕后，再根据连接健康度判断是否需要重连。
脉冲原生实现：不依赖应用层定时任务控制IO通断，直接将目标持续时长写入设备对应的脉冲模式保持寄存器，再写入继电器触发位，由设备硬件完成计时和断开动作。
参数对齐设备规范：对照寄存器映射规则修正控制请求的地址、数据长度参数，避免传值错误。

附优化后的核心业务代码：

@Override
public void callDigitalIO(String ipAddress, String relay, int pulseDurationMs) {
    checkNotEmpty(ipAddress, relay);
    int relayNum = Integer.parseInt(relay);
    
    // 从本地连接池获取复用的设备连接，不每次新建实例
    ModbusTcpMaster master = modbusMasterPool.getOrCreateMaster(ipAddress);
    
    master.connect()
        .thenCompose(connectOk -> {
            // 写入当前继电器的脉冲持续时长，地址对齐设备寄存器规范
            ByteBuf durationBuf = Unpooled.buffer();
            durationBuf.writeShort(pulseDurationMs);
            WriteSingleRegisterRequest durationRequest = new WriteSingleRegisterRequest(
                0x02 * relayNum, // 单路继电器对应的脉冲时长寄存器地址
                durationBuf
            );
            return master.sendRequest(durationRequest, 0xFF);
        })
        .thenCompose(durationWriteOk -> {
            // 触发继电器开启，设备将按设置的时长自动断开
            ByteBuf triggerBuf = Unpooled.buffer();
            triggerBuf.writeShort(0x0001);
            WriteSingleRegisterRequest triggerRequest = new WriteSingleRegisterRequest(
                0x00 * relayNum, // 单路继电器对应的状态控制寄存器地址
                triggerBuf
            );
            return master.sendRequest(triggerRequest, 0xFF);
        })
        .whenCompleteAsync((result, error) -> {
            if (error != null) {
                log.error("Modbus控制失败，目标IP:{}, 继电器:{}", ipAddress, relayNum, error);
                modbusMasterPool.markConnectionUnhealthy(ipAddress);
                return;
            }
            log.info("Modbus控制成功，继电器:{}，脉冲时长:{}ms", relayNum, pulseDurationMs);
            // 保持长连接，不主动断开，供后续调用复用
        });
}

内容的提问来源于stack exchange，提问作者catch32