基于C#实现Modbus RTU通信_Asp.net

一、环境配置与依赖安装

# nuget包安装（支持.net framework 4.5+）
install-package nmodbus4
install-package system.io.ports

二、核心代码实现

1. 串口初始化与连接

using system.io.ports;
using modbus.device;

public class modbusrtumaster
{
    private serialport _serialport;
    private imodbusserialmaster _master;

    public void connect(string portname, int baudrate = 9600, parity parity = parity.none, 
                       int databits = 8, stopbits stopbits = stopbits.one)
    {
        try
        {
            _serialport = new serialport(portname, baudrate, parity, databits, stopbits)
            {
                readtimeout = 3000,
                writetimeout = 3000
            };
            
            _serialport.open();
            _master = modbusserialmaster.creatertu(_serialport);
            _master.transport.retries = 3; // 设置重试次数
            _master.transport.writetimeout = 2000;
            _master.transport.readtimeout = 2000;
        }
        catch (exception ex)
        {
            console.writeline($"连接失败: {ex.message}");
            throw;
        }
    }

    public void disconnect()
    {
        _master?.close();
        _serialport?.close();
    }
}

2. 数据读取操作

public ushort[] readholdingregisters(byte slaveid, ushort startaddr, ushort count)
{
    try
    {
        return _master.readholdingregisters(slaveid, startaddr, count);
    }
    catch (modbusexception ex)
    {
        console.writeline($"modbus错误: {ex.errorcode}");
        return null;
    }
    catch (ioexception ex)
    {
        console.writeline($"通信异常: {ex.message}");
        return null;
    }
}

// 示例调用
var data = master.readholdingregisters(1, 0, 10); // 从站1读取保持寄存器0-9

3. 数据写入操作

public void writesingleregister(byte slaveid, ushort address, ushort value)
{
    _master.writesingleregister(slaveid, address, value);
}

public void writemultiplecoils(byte slaveid, ushort startaddr, bool[] values)
{
    _master.writemultiplecoils(slaveid, startaddr, values);
}

三、关键功能实现

1. crc16校验（modbus标准）

public static class crc16
{
    public static byte[] compute(byte[] data)
    {
        ushort crc = 0xffff;
        foreach (byte b in data)
        {
            crc ^= (ushort)b;
            for (int i = 0; i < 8; i++)
            {
                if ((crc & 0x0001) != 0)
                {
                    crc >>= 1;
                    crc ^= 0xa001;
                }
                else
                {
                    crc >>= 1;
                }
            }
        }
        return new[] { (byte)crc, (byte)(crc >> 8) };
    }

    public static bool validate(byte[] datawithcrc)
    {
        if (datawithcrc.length < 2) return false;
        byte[] data = datawithcrc.take(datawithcrc.length - 2).toarray();
        byte[] crc = compute(data);
        return crc[0] == datawithcrc[datawithcrc.length - 2] 
            && crc[1] == datawithcrc[datawithcrc.length - 1];
    }
}

2. 帧间延迟计算

private int calculateinterframedelay()
{
    int charbits = 1 + _serialport.databits + 
                  (_serialport.stopbits == stopbits.one ? 1 : 2) + 
                  (_serialport.parity == parity.none ? 0 : 1);
    return (int)(3500.0 * charbits / _serialport.baudrate); // 3.5字符时间
}

四、错误处理与调试

1. 异常处理策略

try
{
    var data = readholdingregisters(1, 0, 10);
    if (data == null) throw new invalidoperationexception("读取失败");
}
catch (timeoutexception)
{
    console.writeline("通信超时，请检查设备状态");
    reconnect();
}
catch (invalidoperationexception ex)
{
    console.writeline($"操作失败: {ex.message}");
}

2. 自动重连机制

private void reconnect()
{
    disconnect();
    thread.sleep(1000);
    connect(_config.portname, _config.baudrate);
}

五、性能优化

1批量操作优化

// 批量读取多个寄存器区域
public dictionary<ushort, ushort[]> batchread(
    params (byte slaveid, ushort startaddr, ushort count)[] requests)
{
    var results = new dictionary<ushort, ushort[]>();
    parallel.foreach(requests, request => 
    {
        var data = readholdingregisters(request.slaveid, request.startaddr, request.count);
        lock (results) results[request.slaveid] = data;
    });
    return results;
}

2异步通信实现

public async task<ushort[]> readasync(byte slaveid, ushort startaddr, ushort count)
{
    return await task.run(() => readholdingregisters(slaveid, startaddr, count));
}

参考代码 c#利用modbus rtu模式与下位机通讯 www.youwenfan.com/contentcsr/112701.html

六、完整项目结构

modbusrtudemo/
├── src/
│   ├── modbusmaster/          // 主站核心逻辑
│   ├── serialportconfig.cs    // 串口配置管理
│   └── protocolhandler.cs     // 协议解析器
├── tests/
│   ├── modbustests.cs         // 单元测试
│   └── stresstests.cs         // 压力测试
└── docs/
    └── 开发指南.md

七、调试与测试工具

虚拟串口工具

使用vspd创建虚拟串口对（如com3<->com4），方便调试
wireshark抓包分析

过滤modbus rtu协议，观察完整的请求/响应帧结构
modbus从站模拟

使用modbus slave工具创建测试从站设备

八、扩展应用场景

1.多从站管理

public class modbusnetwork
{
    private dictionary<byte, modbusrtumaster> _slaves = new();
    
    public void addslave(byte address, string portname)
    {
        var master = new modbusrtumaster();
        master.connect(portname);
        _slaves[address] = master;
    }
}

2.数据缓存机制

public class datacache
{
    private dictionary<ushort, (datetime timestamp, ushort value)[]> _cache = new();
    
    public void updatecache(ushort[] data, ushort startaddr)
    {
        _cache[startaddr] = data.select((v, i) => 
            (datetime.now, v)).toarray();
    }
}