C#实现三菱PLC以太网通讯的技术解析与实践

1. 项目概述：C#与三菱PLC以太网通讯的核心价值

在工业自动化领域，上位机与PLC的稳定通讯是系统集成的基石。三菱PLC作为日系控制器的代表型号，其3E帧以太网协议在制造业、智能仓储、流水线控制等场景应用广泛。通过C#实现基于3E帧协议的通讯程序，可以突破传统组态软件的局限，实现高度定制化的数据采集、设备控制和状态监控功能。

我曾在汽车焊接生产线改造项目中，用这套技术方案替代了原有的OPC中转方案，通讯延迟从平均120ms降至35ms，同时实现了PLC批量寄存器的原子化读写。这种直接通讯方式特别适合需要高频数据交互的场景，比如：

• 实时视觉检测系统与PLC的协同控制
• 多轴运动控制中的位置反馈处理
• 能源管理系统中的设备状态监控

2. 通讯协议深度解析

2.1 三菱3E帧协议解剖

三菱Q/L系列PLC的MC协议（Melsec Communication Protocol）3E帧采用TCP/IP传输，其报文结构包含：

plaintext复制[副头部][网络编号][PLC编号][请求目标模块IO编号][请求目标模块站编号][请求数据长度][监控定时器][命令][子命令][请求数据]

典型读指令示例（十六进制表示）：

csharp复制byte[] readCommand = {
    0x50, 0x00,       // 副头部
    0x00,             // 网络编号
    0xFF,             // PLC编号
    0xFF, 0x03,       // 目标模块IO编号
    0x00,             // 目标模块站编号
    0x0C, 0x00,       // 请求数据长度
    0x01, 0x04,       // 监控定时器
    0x01, 0x00,       // 命令(读)
    0x00,             // 子命令
    0xA8, 0x00, 0x00, // 起始地址(D100)
    0x04, 0x00        // 读取点数(4个寄存器)
};

2.2 通讯异常处理机制

在实际部署中，必须实现完善的异常处理：

1. 超时重试机制：建议设置300-500ms的响应超时，配合指数退避算法进行重试

csharp复制int retryCount = 0;
int maxRetries = 3;
int baseTimeout = 300;

while(retryCount < maxRetries)
{
    try 
    {
        var response = await client.SendAsync(command, baseTimeout * (int)Math.Pow(2, retryCount));
        break;
    }
    catch(TimeoutException)
    {
        retryCount++;
        if(retryCount == maxRetries) throw;
    }
}

2. 心跳检测：每30秒发送心跳帧（命令码0x0619）检测连接状态
3. 数据校验：响应帧中的结束代码（0x0000表示成功）必须校验

3. C#实现核心架构

3.1 通讯层封装

推荐采用异步Socket实现基础通讯类：

csharp复制public class MelsecTcpClient : IDisposable
{
    private Socket _socket;
    private readonly IPEndPoint _endPoint;
    private readonly ushort _port;
    
    public async Task ConnectAsync(CancellationToken token)
    {
        _socket = new Socket(AddressFamily.InterNetwork, 
                           SocketType.Stream, 
                           ProtocolType.Tcp);
        await _socket.ConnectAsync(_endPoint, token);
    }

    public async Task<byte[]> SendCommandAsync(byte[] command, int timeout)
    {
        using var cts = new CancellationTokenSource(timeout);
        await _socket.SendAsync(command, SocketFlags.None, cts.Token);
        
        var buffer = new ArraySegment<byte>(new byte[4096]);
        var received = await _socket.ReceiveAsync(buffer, cts.Token);
        return buffer.Take(received).ToArray();
    }
}

3.2 数据转换处理

三菱PLC采用大端序(Big-Endian)存储，需特殊处理：

csharp复制public static float ToFloat(byte[] bytes, int startIndex)
{
    if (BitConverter.IsLittleEndian)
    {
        Array.Reverse(bytes, startIndex, 4);
    }
    return BitConverter.ToSingle(bytes, startIndex);
}

public static byte[] GetBytes(int value)
{
    byte[] bytes = BitConverter.GetBytes(value);
    if (BitConverter.IsLittleEndian)
    {
        Array.Reverse(bytes);
    }
    return bytes;
}

4. 上位机功能实现

4.1 实时数据监控

建议采用双缓冲队列实现数据采集：

csharp复制ConcurrentQueue<PlcData> _dataQueue = new();

private async Task StartMonitoringAsync()
{
    while (!_cts.IsCancellationRequested)
    {
        var data = await ReadDeviceDataAsync("D100", 10);
        _dataQueue.Enqueue(new PlcData(DateTime.Now, data));
        
        if(_dataQueue.Count > 1000)
        {
            _dataQueue.TryDequeue(out _);
        }
        await Task.Delay(100);
    }
}

4.2 批量写入优化

对于需要批量写入的场景，使用连续地址写入命令（命令码0x1401）可提升效率：

csharp复制public async Task BatchWriteAsync(string startDevice, object[] values)
{
    using var ms = new MemoryStream();
    // 构建批量写入指令头
    ms.Write(new byte[]{0x50,0x00,0x00,0xFF,0xFF,0x03,0x00});
    
    // 计算数据区长度
    int dataLength = values.Sum(v => GetValueLength(v));
    ms.Write(BitConverter.GetBytes((short)dataLength));
    
    // 添加批量写入指令
    ms.Write(new byte[]{0x14,0x01,0x00});
    
    // 添加数据内容
    foreach(var value in values)
    {
        byte[] data = GetDeviceBytes(value);
        ms.Write(data);
    }
    
    await _client.SendCommandAsync(ms.ToArray());
}

5. 实战经验与避坑指南

5.1 性能优化要点

1. TCP连接复用：保持长连接而非每次通讯新建连接
2. 读写合并：将相邻地址的读写请求合并为单次通讯
3. 异步处理：使用async/await避免UI线程阻塞
4. 数据压缩：对于历史数据存储可采用GZip压缩

5.2 常见故障排查

5.3 安全防护建议

1. 访问控制：在PLC侧设置允许通讯的IP白名单
2. 数据校验：关键控制指令添加CRC校验
3. 操作日志：记录所有写入操作的时间戳和操作者
4. 权限分级：不同功能模块设置操作权限等级

6. 扩展功能实现

6.1 配方管理

通过JSON序列化实现配方存储与加载：

csharp复制public class Recipe
{
    public Dictionary<string, object> Parameters { get; set; }
    
    public void SaveToPlc(MelsecTcpClient client)
    {
        foreach(var param in Parameters)
        {
            string address = GetDeviceAddress(param.Key);
            byte[] data = ConvertToBytes(param.Value);
            client.WriteDevice(address, data);
        }
    }
}

6.2 报警处理

实现报警优先处理机制：

csharp复制private void ProcessAlarms()
{
    var alarms = _dataQueue
        .Where(d => d.IsAlarm)
        .OrderByDescending(d => d.Priority);
    
    foreach(var alarm in alarms)
    {
        _alarmList.Add(new AlarmLog
        {
            Code = alarm.Code,
            Time = alarm.Timestamp,
            Message = GetAlarmMessage(alarm.Code)
        });
        
        if(alarm.Priority > AlarmPriority.Warning)
        {
            PlaySound(alarm.SoundFile);
        }
    }
}

在实际项目中，我曾遇到PLC寄存器地址跨区块导致的通讯异常。例如当读取D7999开始的10个寄存器时，会跨越D区到扩展D区边界。解决方案是通过分段读取再合并：

csharp复制public async Task<byte[]> ReadAcrossBlocksAsync(string startDevice, int length)
{
    int blockSize = 0x10000 - GetAddressOffset(startDevice);
    var firstPart = await ReadDeviceAsync(startDevice, blockSize);
    var secondPart = await ReadDeviceAsync("D0", length - blockSize);
    return firstPart.Concat(secondPart).ToArray();
}