Allen-Bradley 协议驱动
包: Snet.AllenBradley | 类: AllenBradleyOperate | 类型: 6
提供通过 CIP(EtherNet/IP)和 PCCC(DF1/串行)协议连接 Allen-Bradley PLC(ControlLogix、CompactLogix、MicroLogix 和 SLC 系列)的能力。
安装
dotnet add package Snet.AllenBradley
快速开始
using Snet.AllenBradley;
var op = await AllenBradleyOperate.InstanceAsync(new AllenBradleyData.Basics
{
IpAddress = "192.168.1.100",
Port = 44818
});
var address = new Address(new List<AddressDetails>
{
new("读数", "TagName", DataType.Float),
new("读数2", "TagName2", DataType.Float)
});
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("读数", "TagName", DataType.Float)
});
await op.SubscribeAsync(subAddr);
// 后续:取消订阅
// await op.UnSubscribeAsync(subAddr);
await op.DisposeAsync();
配置
| 参数 | 类型 | 默认值 | 描述 |
|---|---|---|---|
IpAddress |
string | 127.0.0.1 | PLC IP 地址 |
Port |
int | 6688 | EtherNet/IP 端口 |
ConnectTimeOut |
int | 1000 | 连接超时(毫秒) |
ReceiveTimeOut |
int | 1000 | 接收超时(毫秒) |
ProtocolType |
enum | AllenBradleyNet | 协议类型 |
Slot |
int | 0 | CPU 槽位(背板访问) |
SerialPortInfo |
string | COM3-9600-8-N-1 | 串口设置(DF1) |
RtsEnable |
bool | false | RTS 握手(DF1) |
DtrEnable |
bool | false | DTR 握手(DF1) |
Station |
int | 1 | 站号(DF1) |
DstNode |
int | 2 | 目标节点地址(DF1) |
SrcNode |
int | 1 | 源节点地址(DF1) |
支持的协议类型
| 类型 | 描述 |
|---|---|
AllenBradleyNet |
CIP(EtherNet/IP),适用于 ControlLogix/CompactLogix |
AllenBradleyConnectedCipNet |
CIP 连接消息,支持更大数据 |
AllenBradleyMicroCip |
CIP,适用于 MicroLogix 1400 以太网 |
AllenBradleyPcccNet |
通过以太网的 PCCC(PLC-5/SLC 5/05) |
AllenBradleySLCNet |
通过以太网的 SLC 协议(SLC 5/03, 5/04) |
AllenBradleyDF1Serial |
DF1 半双工串行(PLC-5/SLC/MicroLogix) |
地址格式
PCCC 按文件号寻址(SLC/PLC-5);Logix 平台改用 CIP 标签寻址。
| 区域 | 地址格式 | 示例 |
|---|---|---|
| 位文件 | B{文件号}:{元素号} |
B3:0, B3:100 |
| 整型文件 | N{文件号}:{元素号} |
N7:10, N10:0 |
| 状态文件(默认 2) | S{文件号}:{元素号} 或 S:{元素号} |
S2:0, S:0 |
| 输出文件(默认 0) | O{文件号}:{元素号} 或 O:{元素号} |
O0:1, O:1 |
| 输入文件(默认 1) | I{文件号}:{元素号} 或 I:{元素号} |
I1:1, I:1 |
| 字符串文件(默认 1) | ST{文件号}:{元素号} |
ST5:0, ST1:10 |
| 定时器/计数器/控制 | T/C/R{文件号}:{元素号} |
T4:0, C5:0, R3:0 |
| 浮点 / 长整型 / ASCII | F/L/A{文件号}:{元素号} |
F8:0, L9:0, A9:0 |
注意
位寻址 B3:0/5(带 /)不可组包(单值位读);元素字节宽:B/N/S/I/O=2、T/C/R=6、F=4、L=8、ST=84。CIP(Logix)用标签名(TagName、Array[0]、UDT.Member),不适用 PCCC 文件语法。
支持的数据类型
所有读取按 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 |
⚠️ 部分 | 除 AllenBradleySLCNet / AllenBradleyDF1Serial(PCCC 串口)外支持 |
注意
None、Date、DateTime、Time 在 ReadAsync 中没有分支 — 不支持。
地址自动组包与解包
每个数采驱动都实现 IPacker。PCCC 文件地址(B3:0、N7:10 等)已注册在自动组包注册表中(AllenBradleyPacker,SupportsAutoPack = true)并可合并为最小批量读取——A(ASCII)文件类型与 / 位地址(如 B3:0/5)不可组包;CIP 标签地址(Logix)原样透传。引擎细节:地址自动组包。
订阅
先绑定数据事件,再通过 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("读数", "TagName", DataType.Float)
});
await op.SubscribeAsync(subAddr);
// 后续:停止监视
// await op.UnSubscribeAsync(subAddr);
支持的操作
| 操作 | 方法 |
|---|---|
| 连接 | OnAsync() |
| 断开 | OffAsync() |
| 读取 | ReadAsync(address) |
| 写入 | WriteAsync(values) |
| 订阅 | SubscribeAsync(address) |
| 组包 / 解包 | PackerAsync(address, protocolTypeKey) / UnPackerAsync(data) |
