Mitsubishi 协议驱动

包: Snet.Mitsubishi | 类: MitsubishiOperate | 类型: 16

提供通过 MC 协议（1E/3E/4E 帧）、FX 编程口和 A1E（AnA/AnU CPU）协议连接三菱 PLC 的能力。

安装

dotnet add package Snet.Mitsubishi

快速开始

using Snet.Mitsubishi;

var op = await MitsubishiOperate.InstanceAsync(new MitsubishiData.Basics
{
    IpAddress = "192.168.1.100",
    Port = 6000
});

var address = new Address(new List<AddressDetails>
{
    new("读数", "D100", DataType.Int16),
    new("读数2", "D102", DataType.Int16)
});
var result = await op.ReadAsync(address);
if (result.Status)
{
    var data = result.GetSource<ConcurrentDictionary<string, AddressValue>>();
    foreach (var kv in data)
        Console.WriteLine($"{kv.Key} = {kv.Value.ResultValue}");
}
else
{
    Console.WriteLine($"读取失败: {result.Message}");
}

// 订阅之前 绑定数据事件
op.OnDataEventAsync += async (sender, e) =>
{
    if (e.Status)
    {
        var data = e.GetSource<ConcurrentDictionary<string, AddressValue>>();
        foreach (var kv in data)
            Console.WriteLine($"{kv.Key} = {kv.Value.ResultValue}");
    }
    else
    {
        Console.WriteLine($"{e.Message}");
    }
};

var subAddr = new Address(new List<AddressDetails>
{
    new("读数", "D100", DataType.Int16)
});
await op.SubscribeAsync(subAddr);

// 后续：取消订阅
// await op.UnSubscribeAsync(subAddr);

await op.DisposeAsync();

配置

参数	类型	默认值	描述
IpAddress	string	127.0.0.1	PLC IP 地址
Port	int	6688	通信端口
ConnectTimeOut	int	1000	连接超时（毫秒）
ReceiveTimeOut	int	1000	接收超时（毫秒）
ProtocolType	enum	MelsecMcNet	协议类型
Format	int	1	A3C 支持格式 1-4；A4C 支持格式 1-5

支持的协议类型

类型	描述
MelsecCipNet	CIP（EtherNet/IP），通过 QJ71EIP71 模块（Q 系列）
MelsecA1ENet	A1E 二进制帧通过以太网（A/QnA 系列）
MelsecA1EAsciiNet	A1E ASCII 帧通过以太网
MelsecMcNet	MC 3E 二进制帧通过 TCP（iQ-R/iQ-F/Q/L 系列）
MelsecMcUdp	MC 3E 二进制帧通过 UDP
MelsecMcAsciiNet	MC 3E ASCII 帧通过 TCP
MelsecMcAsciiUdp	MC 3E ASCII 帧通过 UDP
MelsecMcRNet	MC 4E 二进制帧支持路由（iQ-R 系列）
MelsecFxSerial	FX 编程口协议（FX 系列，RS-232/485）
MelsecFxSerialOverTcp	通过 TCP 桥接的 FX 串行协议
MelsecFxLinks	FX Links 协议（FX 系列，RS-485）
MelsecFxLinksOverTcp	通过 TCP 桥接的 FX Links 协议
MelsecA3CNet	A3C 帧通过串口（PipeSerialPort，A 系列）
MelsecA3CNetOverTcp	通过 TCP 桥接的 A3C 帧
MelsecA4CNet	A4C 帧通过串口，支持格式 1-5 与和校验控制
MelsecA4CNetOverTcp	通过 TCP 桥接的 A4C 帧，支持格式 1-5 与和校验控制

地址格式

MC (Melsec) 协议设备 — FX Links 见下。

区域	地址格式	示例
数据寄存器	D{n}	D100, D200
链接寄存器	W{n} (十六进制)	W0, W1FF
输入 / 输出	X{n} / Y{n} (十六进制)	X0, X10
内部继电器	M{n}	M0, M100
锁存继电器	L{n}	L0
特殊继电器	SM{n} / SD{n}	SM400, SD400
定时器 / 计数器	TN{n} / CN{n}	TN0, CN0
文件寄存器	R{n} / ZR{n}	R0, ZR0
FX Links (FX 系列)	X/Y 八进制; M/S/TS/TN/CS/CN 位; D/R 字	X10 (= 8), M100, D100

支持的数据类型

所有读取按 AddressDetails.DataType 分发 — 别名(Short = Int16、Float = Single、Int = Int32 等)共用同一分支。

数据类型	支持	说明
Bool	✅	位读取 — 线圈 / 字内位
Int16 / Short, UInt16 / Ushort	✅	16 位整数
Int32 / Int, UInt32 / Uint	✅	32 位整数
Int64 / Long, UInt64 / Ulong	✅	64 位整数
Float / Single, Double	✅	32 / 64 位浮点
String / Char	✅	带 length + 编码读取
ByteArray + 全部 10 种 *Array	✅	带 length 的数组读取
Byte	⚠️ 部分	仅 MelsecCipNet 支持（FX Links 与其他 MC 连接不支持）

地址自动组包与解包

每个数采驱动都实现 IPacker，因此 MitsubishiOperate 可直接将分散地址合并为最小批量读取，并直接解包结果——无需装配处理器（见 IPacker 接口）：

// 组包：将分散地址合并为最少的批量读取
var packed = await op.PackerAsync(address, "MelsecMcNet");
if (!packed.Status) return;                                  // 组包失败
var packedAddr = packed.GetSource<Address>();

// 一次往返读取组包后的批次
var result = await op.ReadAsync(packedAddr);
if (!result.Status) return;                                  // 读取失败
var data = result.GetSource<ConcurrentDictionary<string, AddressValue>>();

// 解包：将每个批次的原始字节解析回各地址的值
var unpacked = await op.UnPackerAsync(data);
if (!unpacked.Status) return;                                // 解包失败
var values = unpacked.GetSource<List<ConcurrentDictionary<string, AddressValue>>>();
foreach (var dict in values)
    foreach (var v in dict)
        Console.WriteLine($"{v.Key} = {v.Value.ResultValue}");

MelsecA4CNet 与 MelsecA4CNetOverTcp 复用 A3C 的三菱地址模型，支持自动组包。MelsecCipNet（标签访问）不支持组包——Packer 原样返回地址集合。引擎细节：地址自动组包。

位批采用位流布局（26.235.x 起）：驱动字读位区从批首位号起返回连续位流（16 位/字、LSB-first），批内偏移=位号差（M100/M108 → 1 字节）。X/Y/DX/DY 前导 0 数字按八进制解析（X010 = 8）。点号地址（M100.5）不可组包。

订阅

先绑定数据事件，再通过 SubscribeAsync 添加地址；数据通过 OnDataEventAsync 到达：

op.OnDataEventAsync += async (sender, e) =>
{
    if (e.Status)
    {
        var data = e.GetSource<ConcurrentDictionary<string, AddressValue>>();
        foreach (var kv in data)
            Console.WriteLine($"{kv.Key} = {kv.Value.ResultValue}");
    }
    else
    {
        Console.WriteLine($"订阅错误: {e.Message}");
    }
};

var subAddr = new Address(new List<AddressDetails>
{
    new("读数", "D100", DataType.Int16)
});
await op.SubscribeAsync(subAddr);

// 后续：停止监视
// await op.UnSubscribeAsync(subAddr);

支持的操作

操作	方法
连接	OnAsync()
断开	OffAsync()
读取	ReadAsync(address)
写入	WriteAsync(values)
订阅	SubscribeAsync(address)
组包 / 解包	PackerAsync(address, protocolTypeKey) / UnPackerAsync(data)

参见

• DaqAbstract 基类
• IDaq 接口