三菱PLC以太网通讯C#实现与优化实践-嵌云网-嵌入式AI开发资源站

三菱PLC以太网通讯C#实现与优化实践

行影旅行

1. 项目背景与核心价值

在工业自动化领域，上位机与PLC的稳定通讯是系统集成的关键环节。三菱FX5U/Q系列PLC作为日系主流控制器，其基于3E帧SLMP/MC协议的以太网通讯方案因实时性强、可靠性高而广泛应用。但官方文档对协议细节的说明较为分散，实际开发中常遇到报文构造错误、响应超时等问题。

这个开源项目提供了完整的C#实现方案，包含协议栈封装、异常处理机制和典型功能示例。我曾在一家汽车零部件厂的MES系统集成中采用类似方案，实测单条指令平均响应时间可控制在15ms以内，满足绝大多数工业场景的实时性需求。

2. 协议栈核心技术解析

2.1 SLMP/MC协议帧结构

3E帧协议采用二进制报文传输，标准请求帧结构如下：

偏移量	字节数	说明	示例值(Q系列)
0	2	子头部(固定5000H)	0x50 0x00
2	2	网络编号	0x00 0x00
4	2	PLC站号	0xFF 0x03
6	2	请求目标模块IO编号	0xFF 0xFF
8	2	请求目标模块站号	0x10 0x00
10	2	请求数据长度	可变
12	2	定时器设置	0x00 0x00
14	n	指令数据	可变

注意：FX5U与Q系列的站号默认值不同，FX5U为0xFF 0x03，Q系列为0x00 0x00，这是实际开发中最容易混淆的点。

2.2 核心通讯指令实现

项目中的核心指令封装类MelsecMcProtocol.cs包含以下关键方法：

csharp复制// 读取位元件（如M0-M100）
public bool ReadBitDevice(string deviceCode, int address, int points)
{
    // 构造读指令报文
    byte[] command = new byte[21];
    // 设置子头部
    command[0] = 0x50; command[1] = 0x00;
    // 设置站号（根据PLC类型自动适配）
    command[4] = (this.PlcType == MelsecPlcType.FX5U) ? (byte)0xFF : (byte)0x00;
    // 设置读指令码 0401H
    command[14] = 0x01; command[15] = 0x04;
    // 设置元件类型和地址
    byte[] deviceBytes = Encoding.ASCII.GetBytes(deviceCode);
    Array.Copy(deviceBytes, 0, command, 16, 1);
    BitConverter.GetBytes(address).CopyTo(command, 17);
    // ... 完整实现见源码
}

实测中发现，位元件读取时地址需要乘以16（即左移4位），这是三菱地址编码的特殊规则。例如读取M100的实际地址值为1600（100×16）。

3. 完整通讯流程实现

3.1 连接建立与保活机制

csharp复制public class PlcEthernetCommunicator : IDisposable
{
    private TcpClient _tcpClient;
    private NetworkStream _stream;
    private Timer _keepAliveTimer;
    
    public bool Connect(string ip, int port = 4999)
    {
        try {
            _tcpClient = new TcpClient();
            _tcpClient.Connect(ip, port);
            _stream = _tcpClient.GetStream();
            
            // 设置保活定时器（每30秒发送空包）
            _keepAliveTimer = new Timer(30000);
            _keepAliveTimer.Elapsed += (s,e) => SendHeartbeat();
            return true;
        } catch {...}
    }
    
    private void SendHeartbeat()
    {
        byte[] heartbeat = { 0x50, 0x00, 0x00, 0x00, 0xFF, 0x03 };
        _stream.Write(heartbeat, 0, heartbeat.Length);
    }
}

重要提示：三菱PLC默认不主动断开连接，但网络设备可能因NAT超时断开。实测建议保活间隔不超过60秒。

3.2 数据读写典型流程

以批量读取D寄存器为例：

构造请求报文（指令码0401H）
发送报文并等待响应
解析响应数据（成功时首字节为0xD0）
处理大端序转换

csharp复制public float[] ReadFloat(string device, int address, int points)
{
    // 1. 构造请求
    byte[] request = BuildReadCommand(device, address, points*2); // float占2个字
    
    // 2. 发送并接收
    byte[] response = SendAndReceive(request);
    
    // 3. 校验响应
    if(response[9] != 0xD0) throw new PlcException("读取失败");
    
    // 4. 转换数据
    float[] results = new float[points];
    for(int i=0; i<points; i++){
        int offset = 11 + i*4;
        byte[] temp = new byte[4];
        // 三菱PLC使用大端序，需要转换
        temp[3] = response[offset];
        temp[2] = response[offset+1];
        temp[1] = response[offset+2];
        temp[0] = response[offset+3];
        results[i] = BitConverter.ToSingle(temp, 0);
    }
    return results;
}

4. 实战问题排查指南

4.1 常见错误代码速查表

错误代码	含义	解决方案
0xC050	头帧错误	检查子头部是否为5000H
0xC054	指令不支持	确认PLC型号支持该指令
0xC059	地址超出范围	检查元件地址是否有效
0xC05B	点数超出限制	单次读写点数不超过960字
0xC0D3	连接数超限	检查PLC最大连接数设置

4.2 典型问题处理实录

案例1：读取数据全为0

现象：读取D寄存器时返回数据长度正确，但值全为0
排查：
1. 用GX Works3监控确认PLC侧数据正常
2. 抓包发现请求报文中的元件类型误设为"W"（字）而非"D"
3. 检查代码发现deviceCode参数传递错误
修复：确保元件类型代码与手册一致（M/SM/X/Y/D等）

案例2：间歇性通讯中断

现象：运行一段时间后突然无响应
排查：
1. 网络抓包发现TCP连接被路由器主动断开
2. 检查PLC发现Socket连接数已达上限（默认8个）
3. 原代码未正确释放连接资源

修复：

csharp复制// 修改为using语句确保资源释放
using(var communicator = new PlcEthernetCommunicator())
{
    communicator.Connect("192.168.1.10");
    // ...操作代码
} // 自动调用Dispose()

5. 性能优化实践

5.1 批量读写优化

通过合并多个请求可显著提升效率。实测对比：

操作方式	100次单点读取	1次100点读取
总耗时(ms)	3200	85
网络包数量	200	2
CPU占用率	15%	3%

优化后的批量读取实现：

csharp复制public Dictionary<string, object> BatchRead(params ReadRequest[] requests)
{
    // 合并所有请求到单个报文
    byte[] mergedCommand = MergeCommands(requests);
    
    // 发送并接收合并响应
    byte[] response = SendAndReceive(mergedCommand);
    
    // 拆分并解析各部分数据
    return ParseBatchResponse(response, requests);
}

5.2 异步通讯模式

对于需要高并发的场景，建议采用async/await模式：

csharp复制public async Task<bool> WriteDeviceAsync(string device, int address, short value)
{
    byte[] command = BuildWriteCommand(device, address, value);
    
    await _stream.WriteAsync(command, 0, command.Length);
    
    byte[] buffer = new byte[1024];
    int bytesRead = await _stream.ReadAsync(buffer, 0, buffer.Length);
    
    return buffer[9] == 0xD0;
}

在汽车生产线测试中，异步模式使系统吞吐量从120次/秒提升到350次/秒。

6. 扩展应用场景

6.1 与数据库集成示例

将PLC数据定时存储到SQL Server：

csharp复制public void StartDataLogging(string[] devices, int interval)
{
    _loggingTimer = new Timer(interval);
    _loggingTimer.Elapsed += async (s,e) => {
        var values = await BatchReadAsync(devices);
        
        using(var conn = new SqlConnection(_dbConnStr))
        {
            await conn.OpenAsync();
            var cmd = new SqlCommand(
                "INSERT INTO PlcLog VALUES(@time, @dev1, @dev2)", conn);
            
            cmd.Parameters.AddWithValue("@time", DateTime.Now);
            for(int i=0; i<devices.Length; i++){
                cmd.Parameters.AddWithValue($"@dev{i+1}", values[i]);
            }
            
            await cmd.ExecuteNonQueryAsync();
        }
    };
}

6.2 上位机界面绑定

通过WPF实现数据绑定：

xml复制<!-- XAML界面 -->
<TextBlock Text="{Binding PlcData[0], StringFormat={}{0:F2}}"/>
<Button Command="{Binding WriteCommand}" Content="写入"/>

csharp复制// ViewModel实现
public class PlcViewModel : INotifyPropertyChanged
{
    private PlcEthernetCommunicator _plc;
    
    public float[] PlcData { get; set; }
    
    public ICommand ReadCommand => new RelayCommand(async () => {
        PlcData = await _plc.ReadFloat("D100", 0, 10);
        OnPropertyChanged(nameof(PlcData));
    });
    
    // ...完整实现见源码
}

这个方案在某包装机械HMI项目中，实现了200ms级别的数据刷新率。