Yokogawa 协议驱动

包: Snet.Yokogawa | 类: YokogawaOperate | 类型数量: 1

通过横河专用以太网协议提供与横河 PLC 及控制器（FA-M3/STARDOM 系列）的连接。

安装

dotnet add package Snet.Yokogawa

快速入门

using Snet.Yokogawa;

var op = await YokogawaOperate.InstanceAsync(new YokogawaData.Basics
{
    IpAddress = "192.168.1.100",
    Port = 12289
});

var address = new Address(new List<AddressDetails>
{
    new("读数", "D1", DataType.Int16),
    new("读数2", "D3", 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("读数", "D1", 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	接收超时（毫秒）

支持类型

类型	说明
YokogawaLinkTcp	横河 Link 协议，基于以太网 TCP

适用于 FA-M3 和 STARDOM 系列的横河 Link 协议，支持 D/I/O/M/E/T/C 寄存器。

地址格式

区域	地址格式	示例
位区 X/Y/I/E/M/T/C/L	{类型}{十进制位号} (字内位 0-15)	X100, Y10, M5, E30
字区 D/B/F/R/V/Z/W/TN/CN	{类型}{十进制字号}	D100, B50, F10, TN10
特殊模块	Special:[cpu={n};]unit={u};slot={s};{pos}	Special:cpu=1;unit=0;slot=1;100, Special:unit=0;slot=1;100

支持的数据类型

所有读取按 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	❌	ReadAsync 中有 case 但无底层读取 — "不支持该类型读取"

地址自动组包与解包

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

// 组包：将分散地址合并为最少的批量读取
var packed = await op.PackerAsync(address, "YokogawaLinkTcp");
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}");

横河 Link 单次读取最多组包 500 字节。引擎细节：地址自动组包。

位批自 26.235.x 起采用位流布局（批内偏移 = 与批首的位号差）。位区 Word 与字区 Bool 经 IsPackable 降级（驱动字读位区按位号寻址，位读仅限位区）。

订阅

先绑定数据事件，再通过 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("读数", "D1", 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 接口