Omron 协议驱动

包: Snet.Omron | 类: OmronOperate | 类型: 8

提供通过 Fins（以太网）、CIP（EtherNet/IP）和 HostLink（串行）协议连接欧姆龙 PLC 的能力。

安装

dotnet add package Snet.Omron

快速开始

using Snet.Omron;

var op = await OmronOperate.InstanceAsync(new OmronData.Basics
{
    IpAddress = "192.168.1.100",
    Port = 9600,
    ProtocolType = ProtocolType.OmronFinsNet
});

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	Fins UDP/TCP 端口
ConnectTimeOut	int	1000	连接超时（毫秒）
ReceiveTimeOut	int	1000	接收超时（毫秒）
ProtocolType	enum	OmronCipNet	协议类型 — 默认 CIP（标签）寻址无法读取 D100 这类 FINS 地址；FINS 寄存器访问请使用 OmronFinsNet / OmronFinsUdp

支持的协议类型

类型	描述
OmronFinsNet	以太网 TCP 上的 Fins（CS/CJ/CP/NJ 系列）
OmronFinsUdp	以太网 UDP 上的 Fins
OmronCipNet	CIP（EtherNet/IP），适用于 NJ/NX 系列
OmronConnectedCipNet	CIP 连接消息
OmronHostLink	串行 HostLink 协议（C 系列，RS-232/485）
OmronHostLinkOverTcp	通过 TCP 桥接的 HostLink
OmronHostLinkCMode	HostLink C 模式串行
OmronHostLinkCModeOverTcp	通过 TCP 桥接的 HostLink C 模式

地址格式

FINS 寻址 — 别名不区分大小写(D→DM, C→CIO, W→WR, H→HR, A→AR, E→EM)。

区域	地址格式	示例
数据存储器	DM{n} / D{n}	DM100, D0
CIO 区	CIO{n}[.{位}] / C{n}	CIO100, CIO100.03
工作继电器	WR{n}[.{位}] / W{n}	WR100, WR0.15
保持继电器	HR{n}[.{位}] / H{n}	HR100, HR5.01
辅助继电器	AR{n}[.{位}] / A{n}	AR100, AR0.10
定时器 / 计数器	TIM{n}[.{位}] / CNT{n}[.{位}]	TIM100, CNT0.01
扩展数据存储器	EM{库号}.{字} (库号十六进制)	EM0.100, EM1.100
索引 / 数据寄存器	IR{n} / DR{n}	IR10, DR20
条件标志	CF{n} (仅位访问)	CF0

支持的数据类型

所有读取按 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	⚠️ 部分	仅 CIP 连接（OmronConnectedCipNet / OmronCipNet）支持

地址自动组包与解包

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

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

OmronCipNet / OmronConnectedCipNet（标签访问）不支持组包——Packer 原样返回地址集合。引擎细节：地址自动组包。

订阅

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