英威腾 - Snet Docs
文档/协议/invt

INVT 协议驱动

包: Snet.Invt | 类: InvtOperate | 类型: 2

提供通过 Modbus 协议栈（TCP/RTU）连接英威腾 PLC、变频器和伺服驱动器的能力。

安装

dotnet add package Snet.Invt

快速开始

using Snet.Invt;

var op = await InvtOperate.InstanceAsync(new InvtData.Basics
{
    IpAddress = "192.168.1.100",
    Port = 502
});

var address = new Address(new List<AddressDetails>
{
    new("读数", "D100", DataType.Int16),
    new("读数2", "R0", 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 设备 IP 地址
Port int 6688 通信端口
ConnectTimeOut int 1000 连接超时（毫秒）
ReceiveTimeOut int 1000 接收超时（毫秒）
DataFormat enum CDAB 数据转换字节序
Station int 1 设备站号
SerialPortInfo string COM3-9600-8-N-1 串口设置（Modbus RTU）

支持的类型

INVT 协议，适用于伺服驱动器和 PLC，支持标准 Modbus 兼容寄存器寻址。

  • ModbusTcpNet — Modbus TCP Net 通信
  • ModbusRtu — Modbus RTU 通信

地址格式

区域 地址格式 示例
位 M{编号} (偏移0) / S{编号} (+32768) / X{编号} (八进制, +40960) / Y{编号} (八进制, +45056) / T{编号} (+49152) / C{编号} (+49664) M0, S1, X0, Y0
字 D{编号} (偏移0) / R{编号} (+32768) / Z{编号} 索引 (×2 + 58368) D100, R0, Z10
直接 Modbus 地址 纯数字或 H 十六进制后缀（仅语法） 2000H, 2002H, 1000
注意

连接时注入英威腾 TS600 映射(Invt_Ts)，因此所有地址都通过映射解析——直接 Modbus 地址（2000H、1000）不可达；支持 s={站号}; 前缀。

支持的数据类型

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

None、Date、DateTime、Time 在 ReadAsync 中没有分支 — 不支持。

地址自动组包与解包

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

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

INVT 基于 Modbus 协议栈运行——ModbusTcpNet 和 ModbusRtu 均已注册到自动组包注册表。引擎详情：地址自动组包。

订阅

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

参见