Modbus RTU 与 Modbus TCP 深入指南-性能分析与优化

八、性能分析与优化8.1 性能基准测试8.1.1 理论最大吞吐量RTU 9600 bps每字节时间10位/9600 1.0417 ms请求帧读10个寄存器地址1 功能码3 起始地址2 数量2 CRC2 8字节 → 8.33 ms3.5字符间隔3.65 ms响应帧20字节数据地址1 功能码3 字节数1 数据20 CRC2 25字节 → 26.04 ms单次总耗时8.33 3.65 26.04 ~38 ms每秒次数1000/38 ≈26 次/秒寄存器吞吐量26 × 10 260 寄存器/秒RTU 115200 bps线长50米每字节时间10/115200 0.0868 ms单次总耗时~4 ms寄存器吞吐量~2500 寄存器/秒TCP 100 Mbps局域网网络延迟 1 ms协议栈开销 0.5 ms寄存器吞吐量50000 寄存器/秒受限于应用层处理8.1.2 影响性能的因素因素RTUTCP波特率/带宽最重要因素通常足够报文长度线性影响线性影响设备响应时间取决于设备取决于设备网络延迟N/A局域网1ms广域网可能100ms并发连接数不支持影响较大协议栈开销几乎无有TCPNagle8.2 RTU优化技巧8.2.1 提高波特率# 前提所有设备支持且线缆长度足够短 ser serial.Serial(/dev/ttyUSB0, baudrate115200, timeout0.5)8.2.2 批量读取# 不好每次读1个寄存器来回20次 for addr in addresses: val read_holding_register(addr) # 好一次读10个连续寄存器 vals read_holding_registers(start_addr0x0000, count10)8.2.3 减少轮询频率# 静态数据设备型号、版本只读一次 device_info read_device_info() # 动态数据温度、压力根据需要轮询 temperature read_temperature() # 每2秒8.2.4 使用功能码23原子读写# 传统方式读-处理-写3次往返 old_val read_register(addr) new_val calculate(old_val) write_register(addr, new_val) # 读写方式1次往返且无竞争 result read_write_registers(read_addr, read_count, write_addr, write_data)8.3 TCP优化技巧8.3.1 禁用Nagle算法# Nagle会合并小报文延迟最多40ms sock.setsockopt(socket.IPPROTO_TCP, socket.TCP_NODELAY, 1)8.3.2 使用连接池from queue import Queue class ModbusTCPPool: def __init__(self, host, port, pool_size10): self.pool Queue(maxsizepool_size) for _ in range(pool_size): client ModbusTCPClient(host, port) client.connect() self.pool.put(client) def acquire(self): return self.pool.get() def release(self, client): self.pool.put(client)8.3.3 调整TCP缓冲区# 增大接收缓冲区减少丢包重传 sock.setsockopt(socket.SOL_SOCKET, socket.SO_RCVBUF, 65536) sock.setsockopt(socket.SOL_SOCKET, socket.SO_SNDBUF, 65536)8.3.4 广域网优化# 对于高延迟链路增加超时时间 client ModbusTCPClient(host, port, timeout_ms5000) # 5秒 # 使用管道化请求需服务器支持 # 发送多个请求而不等待响应事务ID区分8.4 性能测试脚本import time def benchmark_rtu(port, count100): ser serial.Serial(port, 9600, timeout1) start time.time() for i in range(count): # 发送读10个寄存器请求 frame bytes([0x01, 0x03, 0x00, 0x00, 0x00, 0x0A]) crc modbus_crc(frame) ser.write(frame crc.to_bytes(2, little)) response ser.read(100) elapsed time.time() - start print(fRTU: {count} requests in {elapsed:.2f}s - {count/elapsed:.1f} req/s) def benchmark_tcp(host, count1000): client ModbusTCPClient(host) start time.time() for i in range(count): client.read_holding_registers(0, 10) elapsed time.time() - start print(fTCP: {count} requests in {elapsed:.2f}s - {count/elapsed:.1f} req/s) client.close()