YuDian 协议驱动
包: Snet.YuDian | 类: YuDianOperate | 类型数量: 1
通过宇电 AIBus 私有串口协议(PipeSerialPort)提供与宇电温控器及仪表的连接。
安装
dotnet add package Snet.YuDian
快速入门
using Snet.YuDian;
// YuDianData.Basics 没有 IP/端口配置 —— 它是串口 AIBus 驱动
var op = await YuDianOperate.InstanceAsync(new YuDianData.Basics
{
Station = 1,
SerialPortInfo = "COM3-9600-8-N-1"
});
var address = new Address(new List<AddressDetails>
{
new("读数", "0", DataType.Float),
new("读数2", "1", 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("读数", "0", DataType.Float)
});
await op.SubscribeAsync(subAddr);
// 后续:取消订阅
// await op.UnSubscribeAsync(subAddr);
await op.DisposeAsync();
配置参数
| 参数 | 类型 | 默认值 | 说明 |
|---|---|---|---|
Station |
int | 1 | 站号信息 |
SerialPortInfo |
string | COM3-9600-8-N-1 | 串口信息(端口-波特率-数据位-校验-停止位) |
RtsEnable |
bool | false | RTS 握手 |
DtrEnable |
bool | false | DTR 握手 |
SleepTime |
int | 0 | 帧间休眠(毫秒) |
ReceiveTimeOut |
int | 1000 | 接收超时(毫秒) |
ProtocolType |
enum | YuDianAIBus | 协议类型 |
支持类型
| 类型 | 说明 |
|---|---|
YuDianAIBus |
宇电 AI 系列仪表,通过 AIBus 串口协议通信 |
适用于 AI 系列仪表的宇电 AIBus 协议,通过串口支持 PV/SV/MV 及参数寄存器访问。
地址格式
| 区域 | 地址格式 | 示例 |
|---|---|---|
| 参数(唯一区域) | 纯十进制 0-255 字节地址;可选 s={站号}; 前缀(默认 Basics.Station) |
0, 1, 63, s=2;0 |
注意
AIBus 读命令码 82、写命令码 67;每个寄存器 2 字节 (int16)。惯例:0 = PV 测量值、1 = SV 设定值等。
支持的数据类型
所有读取按 AddressDetails.DataType 分发 — 别名(Short = Int16、Float = Single、Int = Int32 等)共用同一分支。
| 数据类型 | 支持 | 说明 |
|---|---|---|
Bool |
❌ | ReadBoolAsync 落到基类并失败 |
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 但无底层读取 — 实际消息为格式化资源串(含协议名与类型名),并非字面文本 "不支持该类型读取" |
注意
None、Date、DateTime、Time 在 ReadAsync 中没有分支 — 不支持。
地址自动组包与解包
每个数采驱动都实现 IPacker。YuDianOperate 使用标签/符号寻址,未注册在自动组包注册表中,因此 Packer 原样返回地址集合(透传)——见 IPacker 接口。支持字节偏移寻址的协议(如西门子 S7、Modbus、三菱 MC)可组包:地址自动组包。
订阅
先绑定数据事件,再通过 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("读数", "0", DataType.Float)
});
await op.SubscribeAsync(subAddr);
// 后续:停止监视
// await op.UnSubscribeAsync(subAddr);
支持操作
| 操作 | 方法 |
|---|---|
| 连接 | OnAsync() |
| 断开 | OffAsync() |
| 读取 | ReadAsync(address) |
| 写入 | WriteAsync(values) |
| 订阅 | SubscribeAsync(address) |
| 组包 / 解包 | PackerAsync(address, protocolTypeKey) / UnPackerAsync(data) |
