C#实现ModbusRTU详解【四】—— 实战通讯与报文解析

1. ModbusRTU通讯实战准备在完成前三篇的报文生成方法后我们现在要进入最激动人心的实战环节了。想象一下你手里拿着精心准备的武器报文生成方法现在终于要上战场实际通讯了。不过在正式开战前我们需要做好充分准备。首先明确我们的目标构建一个完整的ModbusRTU主站通讯模块。这个模块需要能够通过串口与从站设备比如Modbus Slave仿真软件进行数据交互。具体来说我们要实现以下几个核心功能发送生成的请求报文接收从站的响应报文解析响应数据包括异常情况处理验证读写操作的正确性为了完成这个目标我们需要准备以下工具和环境开发环境Visual Studio2017或更高版本串口调试工具Modbus Slave用于模拟从站设备串口虚拟工具可选如果物理串口不足可以使用Virtual Serial Port Driver创建虚拟串口对基础代码前三篇已经完成的报文生成模块在实际项目中我强烈建议先搭建一个简单的测试环境。你可以这样操作安装Modbus Slave并配置好从站参数确保串口连接正常如果是虚拟串口记住配对的端口号准备好报文生成模块的代码2. 串口通讯基础实现2.1 串口配置与初始化在C#中我们使用System.IO.Ports命名空间下的SerialPort类来实现串口通讯。下面是一个基础的串口配置示例using System.IO.Ports; public class ModbusRTUCommunicator { private SerialPort _serialPort; public void InitializePort(string portName, int baudRate 9600, Parity parity Parity.None, int dataBits 8, StopBits stopBits StopBits.One) { _serialPort new SerialPort(portName, baudRate, parity, dataBits, stopBits); _serialPort.ReadTimeout 500; // 读取超时时间(ms) _serialPort.WriteTimeout 500; // 写入超时时间(ms) // 其他可能需要的配置 _serialPort.Handshake Handshake.None; _serialPort.RtsEnable true; // 启用RTS信号线 } public bool OpenConnection() { try { if (!_serialPort.IsOpen) { _serialPort.Open(); return true; } return false; } catch (Exception ex) { Console.WriteLine($打开串口失败: {ex.Message}); return false; } } public void CloseConnection() { if (_serialPort ! null _serialPort.IsOpen) { _serialPort.Close(); } } }在实际使用中我发现有几个关键点需要注意波特率必须与从站设备完全一致常见的值有9600、19200、38400等超时设置ReadTimeout和WriteTimeout要根据实际网络状况合理设置RTS控制有些设备需要RTS信号控制数据流需要根据设备手册配置2.2 报文发送与接收基础方法有了串口连接后我们需要实现基本的报文发送和接收方法。这里我分享一个经过实战检验的实现public byte[] SendMessage(byte[] message) { if (_serialPort null || !_serialPort.IsOpen) { throw new InvalidOperationException(串口未初始化或未打开); } try { // 清空输入输出缓冲区 _serialPort.DiscardInBuffer(); _serialPort.DiscardOutBuffer(); // 发送报文 _serialPort.Write(message, 0, message.Length); // 等待响应根据设备响应时间调整 Thread.Sleep(100); // 读取响应 Listbyte response new Listbyte(); while (_serialPort.BytesToRead 0) { byte[] buffer new byte[_serialPort.BytesToRead]; int bytesRead _serialPort.Read(buffer, 0, buffer.Length); response.AddRange(buffer); // 小延迟防止读取不完整 Thread.Sleep(50); } return response.ToArray(); } catch (TimeoutException) { Console.WriteLine(读取响应超时); return null; } catch (Exception ex) { Console.WriteLine($通讯发生异常: {ex.Message}); return null; } }这个方法有几个值得注意的细节缓冲区清理每次发送前清空缓冲区避免残留数据干扰延迟处理适当延迟确保数据完整接收异常处理捕获可能出现的超时和其他异常3. 报文解析与处理3.1 正常响应解析ModbusRTU的响应报文格式与功能码相关。我们先来看最常见的几种正常响应情况读取操作响应功能码与请求相同数据返回的字节数 实际数据写入操作响应单个写入返回与请求完全相同的报文多个写入返回站地址、功能码、起始地址和写入数量下面是一个通用的响应解析方法public static bool TryParseResponse(byte[] response, byte expectedFunctionCode, out byte[] data, out string errorMessage) { data null; errorMessage null; // 基本检查 if (response null || response.Length 5) // 最小长度站地址功能码2字节CRC { errorMessage 响应报文长度不足; return false; } // 检查CRC校验 byte[] messageWithoutCrc new byte[response.Length - 2]; Array.Copy(response, 0, messageWithoutCrc, 0, messageWithoutCrc.Length); byte[] calculatedCrc CRC16(messageWithoutCrc); if (!response[response.Length - 2].Equals(calculatedCrc[0]) || !response[response.Length - 1].Equals(calculatedCrc[1])) { errorMessage CRC校验失败; return false; } // 检查功能码 byte actualFunctionCode response[1]; // 如果是异常响应功能码最高位为1 if ((actualFunctionCode 0x80) ! 0) { byte errorCode response[2]; errorMessage $从站返回异常错误码: {errorCode} - {GetErrorDescription(errorCode)}; return false; } // 检查功能码是否匹配 if (actualFunctionCode ! expectedFunctionCode) { errorMessage $功能码不匹配期望:{expectedFunctionCode}实际:{actualFunctionCode}; return false; } // 提取数据部分 data new byte[response.Length - 4]; // 减去站地址、功能码和CRC Array.Copy(response, 2, data, 0, data.Length); return true; } private static string GetErrorDescription(byte errorCode) { return errorCode switch { 0x01 非法功能码, 0x02 非法数据地址, 0x03 非法数据值, 0x04 从站设备故障, _ 未知错误 }; }3.2 异常响应处理Modbus协议定义了标准的异常响应格式。当从站无法处理请求时会返回异常响应其特征是功能码的最高位被置为1即原功能码0x80后面跟着异常代码。在我们的代码中已经包含了异常响应处理但为了更健壮的系统我们可以专门为异常响应设计一个解析方法public static bool IsExceptionResponse(byte[] response, out byte originalFunctionCode, out byte errorCode) { originalFunctionCode 0; errorCode 0; if (response null || response.Length 5) { return false; } byte functionCode response[1]; if ((functionCode 0x80) 0) { return false; } originalFunctionCode (byte)(functionCode 0x7F); errorCode response[2]; return true; }在实际项目中我建议对每种可能的异常情况都做专门处理比如if (IsExceptionResponse(response, out var originalFuncCode, out var errCode)) { switch (errCode) { case 0x02: Console.WriteLine($地址 {requestAddress} 不存在或不可访问); break; case 0x03: Console.WriteLine($写入值 {writeValue} 超出允许范围); break; // 其他异常处理... } return; }4. 完整通讯流程实现4.1 读取操作完整示例现在我们把前面学到的所有内容整合起来实现一个完整的读取保持寄存器功能码03的流程public short[] ReadHoldingRegisters(byte slaveAddress, ushort startAddress, ushort numberOfRegisters) { // 生成请求报文 byte[] request MessageGenerationModule.GetMultipleDataReadMessage( slaveAddress, startAddress, numberOfRegisters, ReadType.Read03); // 发送报文并获取响应 byte[] response SendMessage(request); // 解析响应 if (TryParseResponse(response, 0x03, out var data, out var errorMsg)) { // 数据格式字节数 寄存器值每个寄存器2字节 int byteCount data[0]; if (byteCount ! numberOfRegisters * 2) { throw new InvalidDataException(返回数据长度与预期不符); } short[] result new short[numberOfRegisters]; for (int i 0; i numberOfRegisters; i) { int offset 1 i * 2; // 跳过字节数 result[i] BitConverter.ToInt16(new byte[] { data[offset 1], data[offset] }, 0); } return result; } else { throw new ModbusException(errorMsg); } }这个方法展示了完整的处理流程使用之前实现的报文生成方法创建请求通过串口发送请求接收并解析响应处理数据注意字节序转换4.2 写入操作完整示例同样地我们实现一个写入多个寄存器的完整示例public bool WriteMultipleRegisters(byte slaveAddress, ushort startAddress, short[] values) { // 生成请求报文 byte[] request MessageGenerationModule.GetArrayDataWriteMessage( slaveAddress, (short)startAddress, values); // 发送报文并获取响应 byte[] response SendMessage(request); // 解析响应 if (TryParseResponse(response, 0x10, out var data, out var errorMsg)) { // 正常响应格式站地址(1) 功能码(1) 起始地址(2) 寄存器数量(2) if (data.Length ! 4) { throw new InvalidDataException(响应数据长度异常); } // 验证起始地址和数量是否匹配 ushort returnedStartAddress (ushort)((data[0] 8) | data[1]); ushort returnedQuantity (ushort)((data[2] 8) | data[3]); return returnedStartAddress startAddress returnedQuantity values.Length; } else { throw new ModbusException(errorMsg); } }在实际测试中我发现有几个常见问题需要注意字节序问题不同设备可能有不同的字节序要求超时处理要根据实际设备响应速度调整超时时间重试机制对于不稳定的串口连接建议实现简单的重试逻辑4.3 综合测试案例下面是一个完整的控制台应用示例演示如何测试我们的ModbusRTU通讯模块class Program { static void Main(string[] args) { var communicator new ModbusRTUCommunicator(); try { // 初始化串口根据实际情况修改参数 communicator.InitializePort(COM3, 9600, Parity.None, 8, StopBits.One); communicator.OpenConnection(); // 测试读取保持寄存器 Console.WriteLine(测试读取保持寄存器...); short[] registers communicator.ReadHoldingRegisters(1, 0, 5); Console.WriteLine(读取结果:); for (int i 0; i registers.Length; i) { Console.WriteLine($寄存器 {i}: {registers[i]}); } // 测试写入多个寄存器 Console.WriteLine(\n测试写入多个寄存器...); short[] valuesToWrite { 100, 200, 300, 400, 500 }; bool writeSuccess communicator.WriteMultipleRegisters(1, 0, valuesToWrite); Console.WriteLine($写入操作{(writeSuccess ? 成功 : 失败)}); // 验证写入结果 Console.WriteLine(\n验证写入结果...); registers communicator.ReadHoldingRegisters(1, 0, 5); Console.WriteLine(读取结果:); for (int i 0; i registers.Length; i) { Console.WriteLine($寄存器 {i}: {registers[i]} (期望值: {valuesToWrite[i]})); } } catch (Exception ex) { Console.WriteLine($发生异常: {ex.Message}); } finally { communicator.CloseConnection(); } Console.WriteLine(\n测试完成按任意键退出...); Console.ReadKey(); } }这个测试案例展示了完整的读写操作流程包括初始化串口连接读取寄存器当前值写入新值再次读取验证写入结果异常处理和资源清理在实际项目中我建议为每个功能码都编写类似的测试案例确保所有功能都能正常工作。同时可以添加更多的错误处理和数据验证逻辑使系统更加健壮。