三菱FX3U PLC以太网MC协议C#开发实战

1. 项目背景与核心价值

三菱FX3U系列PLC作为工业自动化领域的经典控制器，在中小型产线中占据重要市场份额。传统上，工程师需要通过专用编程电缆（如USB-SC09）连接PLC进行调试，这种点对点连接方式在需要远程监控或多设备集成的场景中显得力不从心。以太网MC协议（MELSEC Communication Protocol）的引入，使得通过标准以太网接口访问PLC内部寄存器成为可能。

我在去年参与的一个食品包装产线改造项目中，就遇到了需要将12台FX3U PLC数据集中采集到MES系统的需求。如果采用传统的串口服务器方案，不仅布线复杂，而且实时性难以保证。最终我们通过MC协议实现PLC直连交换机，数据采集周期从原来的2秒缩短到200毫秒以内。这个案例让我深刻认识到掌握MC协议开发的重要性。

2. 协议基础与通信原理

2.1 MC协议帧结构解析

MC协议采用典型的请求-响应模型，通信帧由三部分组成：

1. 子头部（5字节）：包含协议类型标识（0x50表示MC协议）、网络编号（通常为0）、PLC编号（0xFF表示广播）、请求目标模块IO编号（0x03FF表示CPU模块）、请求目标模块站号（通常0）
2. 报文头部（7字节）：包含监控定时器值（默认1000ms）、指令代码（如0x0401读位元件）、请求数据长度
3. 报文数据：具体操作参数，如元件类型、起始地址、读取点数等

以读取D100-D109这10个数据寄存器为例，完整的请求帧如下（十六进制表示）：

code复制50 00 FF FF 03 00 0C 00 00 01 04 01 00 00 A8 01 0A 00

其中关键字段解析：

• 0x0401：读字元件指令
• 0xA8：D寄存器类型码
• 0x0100：起始地址D100（小端表示）
• 0x0A00：读取10个字

2.2 元件地址映射规则

三菱PLC采用独特的地址编码系统，需要特别注意：

• 位元件：X(输入)Y(输出)M(辅助)的地址计算为 元件类型码 + 地址/8
  • 例如X20对应地址0x0080（0x00<<8 | (20/8)）
• 字元件：D(数据寄存器)直接使用寄存器编号
  • D100对应地址0x0100
• 特殊模块：需要通过IO编号和站号指定

重要提示：FX3U的元件地址范围与Q/L系列不同，例如D寄存器在FX3U上最大只能到D7999，超出范围会导致通信错误。

3. C#实现方案设计

3.1 网络通信层封装

采用异步Socket实现基础通信，关键类设计如下：

csharp复制public class McProtocolClient : IDisposable
{
    private Socket _socket;
    private readonly IPEndPoint _endPoint;
    private const int ReceiveTimeout = 1000;
    
    public McProtocolClient(string ip, int port = 5002)
    {
        _endPoint = new IPEndPoint(IPAddress.Parse(ip), port);
        _socket = new Socket(AddressFamily.InterNetwork, 
                           SocketType.Stream, 
                           ProtocolType.Tcp);
        _socket.ReceiveTimeout = ReceiveTimeout;
    }
    
    public async Task ConnectAsync()
    {
        await _socket.ConnectAsync(_endPoint);
    }
    
    private async Task<byte[]> SendAndReceive(byte[] request)
    {
        await _socket.SendAsync(new ArraySegment<byte>(request), 
                              SocketFlags.None);
        
        var buffer = new byte[256];
        var received = await _socket.ReceiveAsync(
            new ArraySegment<byte>(buffer), 
            SocketFlags.None);
        
        return buffer.Take(received).ToArray();
    }
    
    // 其他协议方法...
}

3.2 协议指令构造器

设计指令构造类处理地址转换和帧组装：

csharp复制public static class McCommandBuilder
{
    public static byte[] BuildReadCommand(
        DeviceType device, 
        int address, 
        int points)
    {
        var stream = new MemoryStream();
        using (var writer = new BinaryWriter(stream))
        {
            // 子头部
            writer.Write(new byte[] { 0x50, 0x00, 0xFF, 0xFF, 0x03, 0x00 });
            
            // 报文头部
            writer.Write((short)0x000C); // 请求数据长度
            writer.Write((short)0x0000); // 监控定时器
            writer.Write((short)0x0401); // 读指令
            
            // 报文数据
            writer.Write((byte)GetDeviceCode(device));
            writer.Write((short)address); // 小端序
            writer.Write((short)points);  // 小端序
            
            return stream.ToArray();
        }
    }
    
    private static byte GetDeviceCode(DeviceType device)
    {
        return device switch
        {
            DeviceType.X => 0x9C,
            DeviceType.Y => 0x9D,
            DeviceType.M => 0x90,
            DeviceType.D => 0xA8,
            _ => throw new ArgumentException("Unsupported device type")
        };
    }
}

4. 核心功能实现

4.1 数据读取实现

扩展McProtocolClient类添加读操作：

csharp复制public async Task<short[]> ReadWordsAsync(
    DeviceType device, 
    int address, 
    int points)
{
    var command = McCommandBuilder.BuildReadCommand(
        device, address, points);
    
    var response = await SendAndReceive(command);
    
    // 解析响应帧
    if (response.Length < 11 || response[9] != 0)
        throw new McProtocolException("Invalid response");
    
    var result = new short[points];
    for (int i = 0; i < points; i++)
    {
        int offset = 11 + i * 2;
        result[i] = BitConverter.ToInt16(response, offset);
    }
    
    return result;
}

4.2 数据写入实现

字元件写入方法示例：

csharp复制public async Task WriteWordsAsync(
    DeviceType device, 
    int address, 
    short[] values)
{
    var stream = new MemoryStream();
    using (var writer = new BinaryWriter(stream))
    {
        // 子头部和报文头部
        writer.Write(new byte[] { 0x50, 0x00, 0xFF, 0xFF, 0x03, 0x00 });
        writer.Write((short)(9 + values.Length * 2)); // 数据长度
        writer.Write((short)0x0000); // 监控定时器
        writer.Write((short)0x1401); // 写字指令
        
        // 报文数据
        writer.Write((byte)GetDeviceCode(device));
        writer.Write((short)address);
        writer.Write((short)values.Length);
        
        foreach (var value in values)
            writer.Write(value);
    }
    
    var response = await SendAndReceive(stream.ToArray());
    if (response.Length < 11 || response[9] != 0)
        throw new McProtocolException("Write operation failed");
}

5. 实战优化技巧

5.1 通信性能提升

1. 批量读取优化：

   • FX3U单次最多可读取960个字（1920字节）
   • 合理设置读取点数，避免多次小数据请求

   csharp复制// 推荐方式 - 单次读取多个寄存器
   var batchData = await client.ReadWordsAsync(DeviceType.D, 100, 50);
   
   // 不推荐 - 多次单独读取
   for (int i = 0; i < 50; i++)
   {
       var singleData = await client.ReadWordsAsync(DeviceType.D, 100 + i, 1);
   }
   

2. 连接池管理：

   • 保持长连接避免重复握手
   • 实现简单的连接复用机制

   csharp复制public class McConnectionPool
   {
       private readonly ConcurrentDictionary<string, Lazy<McProtocolClient>> _pool;
       
       public async Task<McProtocolClient> GetClientAsync(string ip)
       {
           var lazyClient = _pool.GetOrAdd(ip, 
               new Lazy<McProtocolClient>(() => new McProtocolClient(ip)));
           
           var client = lazyClient.Value;
           if (!client.IsConnected)
               await client.ConnectAsync();
               
           return client;
       }
   }
   

5.2 异常处理策略

1. 超时重试机制：

   csharp复制public async Task<T> RetryAsync<T>(
       Func<Task<T>> operation, 
       int maxRetries = 3)
   {
       int retryCount = 0;
       while (true)
       {
           try
           {
               return await operation();
           }
           catch (SocketException ex) when (retryCount < maxRetries)
           {
               retryCount++;
               await Task.Delay(100 * retryCount);
               _socket = new Socket(AddressFamily.InterNetwork,
                                  SocketType.Stream,
                                  ProtocolType.Tcp);
               await ConnectAsync();
           }
       }
   }
   

2. 心跳检测实现：

   csharp复制public async Task StartHeartbeatAsync(
       TimeSpan interval, 
       CancellationToken ct)
   {
       while (!ct.IsCancellationRequested)
       {
           try
           {
               await ReadWordsAsync(DeviceType.D, 0, 1);
               await Task.Delay(interval, ct);
           }
           catch
           {
               // 触发重连逻辑
               await ReconnectAsync();
           }
       }
   }
   

6. 典型问题排查指南

6.1 常见错误代码解析

6.2 调试技巧

1. Wireshark抓包分析：

   • 过滤条件：tcp.port == 5002
   • 典型问题识别：
     • 只有请求无响应：物理层问题（网线/交换机）
     • 响应错误码：协议层问题（地址/指令错误）

2. PLC侧诊断：

   • 通过GX Works2查看通信统计：
     • 路径：[诊断] → [PLC诊断] → [以太网端口状态]
   • 检查D8176（通信错误代码寄存器）

3. C#调试技巧：

   csharp复制// 在SendAndReceive方法中添加日志
   Console.WriteLine($"Sent: {BitConverter.ToString(request)}");
   Console.WriteLine($"Received: {BitConverter.ToString(response)}");
   

7. 扩展应用场景

7.1 与OPC UA集成方案

通过将MC协议客户端封装为OPC UA服务器，实现标准化接入：

csharp复制public class McOpcUaServer : IDisposable
{
    private readonly McProtocolClient _mcClient;
    private readonly ApplicationInstance _application;
    
    public McOpcUaServer(string plcIp)
    {
        _mcClient = new McProtocolClient(plcIp);
        
        _application = new ApplicationInstance {
            ApplicationName = "FX3U OPC UA Server",
            ApplicationType = ApplicationType.Server
        };
        
        // 配置服务器证书和端点
        var serverConfig = new ApplicationConfiguration {
            // ... 省略配置细节
        };
    }
    
    public async Task StartAsync()
    {
        await _mcClient.ConnectAsync();
        
        // 创建地址空间
        var namespaceManager = new NamespaceManager();
        var factory = new Opc.Ua.Server.StandardServer();
        
        // 映射PLC数据到OPC节点
        var variables = new List<BaseDataVariableState>();
        for (int i = 0; i < 100; i++)
        {
            var variable = new BaseDataVariableState {
                NodeId = new NodeId($"D{i}", 2),
                DisplayName = $"D{i}",
                DataType = DataTypeIds.Int16,
                ValueRank = ValueRanks.Scalar,
                AccessLevel = AccessLevels.CurrentRead | AccessLevels.CurrentWrite
            };
            variables.Add(variable);
        }
        
        // 启动数据同步任务
        _ = Task.Run(async () => {
            while (true)
            {
                var values = await _mcClient.ReadWordsAsync(DeviceType.D, 0, 100);
                for (int i = 0; i < values.Length; i++)
                {
                    variables[i].Value = values[i];
                }
                await Task.Delay(200);
            }
        });
    }
}

7.2 云端数据采集架构

基于MC协议构建的工业物联网架构示例：

code复制[FX3U PLC] ←MC协议→ [边缘网关(C#)] ←MQTT→ [云平台]
                    ↳ 本地缓存
                    ↳ 协议转换
                    ↳ 断线续传

边缘网关核心功能实现：

csharp复制public class EdgeGateway
{
    private readonly McProtocolClient _plcClient;
    private readonly IMqttClient _mqttClient;
    private readonly TimeSeriesDbClient _dbClient;
    
    public async Task RunAsync()
    {
        // 初始化连接
        await _plcClient.ConnectAsync();
        await _mqttClient.ConnectAsync();
        
        // 创建数据采集管道
        var transformBlock = new TransformBlock<short[], MqttMessage>(
            data => new MqttMessage {
                Topic = "plc/d100",
                Payload = JsonConvert.SerializeObject(data)
            });
        
        var broadcastBlock = new BroadcastBlock<MqttMessage>(msg => msg);
        
        // 数据流处理
        var processingPipeline = new ActionBlock<MqttMessage>(async msg => {
            await Task.WhenAll(
                _mqttClient.PublishAsync(msg),
                _dbClient.InsertAsync("plc_data", msg.Payload)
            );
        });
        
        // 构建管道链路
        transformBlock.LinkTo(broadcastBlock);
        broadcastBlock.LinkTo(processingPipeline);
        
        // 启动采集循环
        while (true)
        {
            var data = await _plcClient.ReadWordsAsync(DeviceType.D, 100, 10);
            await transformBlock.SendAsync(data);
            await Task.Delay(500);
        }
    }
}

在实际项目中，这种架构可以将PLC数据同时发送到云端和本地时序数据库，确保在网络波动时数据不丢失。我曾在一个水处理项目中采用类似方案，实现了98.7%的数据完整率。