1. 项目概述
在工业自动化领域，PLC（可编程逻辑控制器）作为核心控制设备，其通信能力直接影响系统集成效率。三菱FX3U系列PLC凭借其稳定性和性价比，在中小型自动化项目中广泛应用。而以太网MC协议作为三菱PLC的标准通信协议，为开发者提供了高效的远程控制接口。
本文将详细解析如何基于C#构建一个完整的FX3U以太网MC协议客户端。不同于简单的代码示例，我们将从协议原理、通信架构到实际封装进行全面剖析，最终形成可直接用于生产环境的解决方案。这个方案包含三个关键产出：
- 带完整注释的C#工程源码
- 可复用的开源DLL组件
- 一键部署的安装包
2. 核心设计思路
2.1 协议层设计
MC协议（MELSEC Communication Protocol）是三菱PLC的专用通信协议，其以太网版本采用TCP/IP传输。协议帧结构包含：
- 子头部（8字节）：标识协议类型和请求属性
- 访问路径（可变长度）：指定PLC型号和网络路径
- 请求数据（可变长度）：包含具体操作指令
典型读指令示例（ASCII格式）：
code复制500000FF03FF00001800000401000000D*0100
其中关键字段解析：
500000FF：子头部固定值03FF：网络/站号参数0100：读取D寄存器的指令码
2.2 通信架构设计
采用分层架构实现通信模块：
code复制[应用层]
│
▼
[协议封装层] ← 处理MC协议格式转换
│
▼
[传输层] ← TCP套接字管理
│
▼
[物理层] ← 以太网物理连接
这种设计使得协议实现与底层传输解耦，便于后续扩展其他通信方式（如串口）。
3. 关键实现细节
3.1 连接管理实现
增强版的连接管理类包含以下改进：
csharp复制public class Fx3UClient : IDisposable
{
private TcpClient _client;
private NetworkStream _stream;
private int _timeout = 3000; // 默认3秒超时
public bool Connect(string ip, int port, int retryCount = 3)
{
for (int i = 0; i < retryCount; i++)
{
try
{
_client = new TcpClient();
_client.ReceiveTimeout = _timeout;
_client.SendTimeout = _timeout;
var connectTask = _client.ConnectAsync(ip, port);
if (connectTask.Wait(_timeout))
{
_stream = _client.GetStream();
return true;
}
throw new TimeoutException();
}
catch (Exception ex)
{
if (i == retryCount - 1)
throw new Fx3UException($"连接失败: {ex.Message}", ex);
Thread.Sleep(500);
}
}
return false;
}
public void Dispose()
{
_stream?.Dispose();
_client?.Dispose();
}
}
关键改进点：
- 增加超时控制和重试机制
- 实现IDisposable接口确保资源释放
- 使用异步连接避免UI线程阻塞
3.2 协议指令封装
针对常用PLC操作进行高级封装：
csharp复制public class Fx3UProtocol
{
private readonly Fx3UClient _client;
public Fx3UProtocol(Fx3UClient client)
{
_client = client;
}
public short[] ReadDRegisters(int startAddr, int count)
{
string cmd = BuildReadCommand("D", startAddr, count);
byte[] response = SendCommand(cmd);
return ParseResponse(response, count);
}
private string BuildReadCommand(string regType, int addr, int count)
{
return $"500000FF03FF00001800000401000000{regType}{addr:X4}{count:X4}";
}
private byte[] SendCommand(string command)
{
byte[] cmdBytes = Encoding.ASCII.GetBytes(command);
_stream.Write(cmdBytes, 0, cmdBytes.Length);
byte[] header = new byte[11];
_stream.Read(header, 0, header.Length);
int dataLen = BitConverter.ToInt32(header, 7);
byte[] data = new byte[dataLen];
_stream.Read(data, 0, dataLen);
return data;
}
}
4. 高级功能实现
4.1 批量读写优化
针对大数据量传输的特殊处理：
csharp复制public class BulkDataTransfer
{
private const int MAX_BLOCK_SIZE = 960; // FX3U单次最大传输量
public void BulkRead(Fx3UProtocol protocol, int startAddr, int totalCount)
{
List<short> results = new List<short>();
int remaining = totalCount;
while (remaining > 0)
{
int blockSize = Math.Min(remaining, MAX_BLOCK_SIZE);
var block = protocol.ReadDRegisters(startAddr, blockSize);
results.AddRange(block);
startAddr += blockSize;
remaining -= blockSize;
}
}
}
4.2 异常处理机制
定义PLC专用异常类：
csharp复制public class Fx3UException : Exception
{
public ErrorCode ErrorCode { get; }
public Fx3UException(string message, ErrorCode code)
: base(message)
{
ErrorCode = code;
}
public enum ErrorCode
{
ConnectionFailed = 1001,
Timeout = 1002,
ProtocolError = 1003,
ChecksumError = 1004
}
}
5. 组件封装与部署
5.1 DLL封装要点
使用Visual Studio创建类库项目时，注意以下配置：
xml复制<PropertyGroup>
<TargetFramework>net6.0</TargetFramework>
<Nullable>enable</Nullable>
<GeneratePackageOnBuild>true</GeneratePackageOnBuild>
<PackageId>Fx3U.MCProtocol</PackageId>
<Version>1.0.0</Version>
</PropertyGroup>
5.2 安装包制作
使用Inno Setup制作安装程序时，关键脚本配置：
ini复制[Files]
Source: "Fx3U.MCProtocol.dll"; DestDir: "{app}"; Flags: ignoreversion
Source: "DemoApp.exe"; DestDir: "{app}"; Flags: ignoreversion
[Icons]
Name: "{group}\Demo Application"; Filename: "{app}\DemoApp.exe"
Name: "{commondesktop}\Demo Application"; Filename: "{app}\DemoApp.exe"
[Run]
Filename: "{app}\DemoApp.exe"; Description: "启动应用程序"; Flags: postinstall nowait
6. 实战注意事项
6.1 性能调优技巧
- 连接池管理：
csharp复制public class ConnectionPool
{
private ConcurrentBag<Fx3UClient> _pool = new();
public Fx3UClient GetClient(string ip, int port)
{
if (_pool.TryTake(out var client))
return client;
return new Fx3UClient().Connect(ip, port);
}
public void ReturnClient(Fx3UClient client)
{
if (client.IsConnected)
_pool.Add(client);
}
}
- 数据缓存策略：
- 对频繁读取的寄存器值实施本地缓存
- 设置合理的缓存过期时间（通常100-500ms）
- 使用ReaderWriterLockSlim保证线程安全
6.2 常见问题排查
- 连接失败诊断步骤：
- 使用ping测试网络连通性
- 通过telnet测试端口开放情况
- 检查PLC侧通信参数设置：
- IP地址与端口是否匹配
- MC协议功能是否启用
- 站号设置是否正确
- 数据异常处理流程：
mermaid复制graph TD
A[数据异常] --> B{校验和检查}
B -->|正确| C[解析数据]
B -->|错误| D[重发请求]
C --> E{值范围合理}
E -->|是| F[处理数据]
E -->|否| G[记录异常日志]
7. 扩展应用场景
7.1 与SCADA系统集成
通过OPC UA桥接实现数据对接：
- 创建OPC UA服务器项目
- 添加对FX3U组件的引用
- 实现周期性数据采集：
csharp复制public class OpcUaBridge
{
private Timer _timer;
private Fx3UProtocol _protocol;
public void Start(TimeSpan interval)
{
_timer = new Timer(UpdateData, null,
TimeSpan.Zero, interval);
}
private void UpdateData(object state)
{
var values = _protocol.ReadDRegisters(0, 100);
// 更新OPC UA节点值
}
}
7.2 云端数据采集方案
构建IoT边缘采集网关：
- 使用MQTT协议上传数据
- 实现断网缓存功能
- 添加数据压缩算法：
csharp复制public class MqttPublisher
{
public void PublishData(short[] values)
{
byte[] raw = MemoryMarshal.AsBytes(values.AsSpan()).ToArray();
byte[] compressed = BrotliCompressor.Compress(raw);
var message = new MqttApplicationMessageBuilder()
.WithTopic("plc/data")
.WithPayload(compressed)
.Build();
_client.PublishAsync(message);
}
}
在实际项目中，我们发现FX3U的以太网通信模块处理大量小数据包时性能较好，但大数据块传输时需要特别注意分包处理。经过测试，当单次读写超过500个寄存器时，建议拆分为多个100-200寄存器的小块进行操作，这样可获得最佳通信效率。