Snet.NetMQ 26.216.1

<h1 align="center"> <img width="100" height="100" src="https://api.snet.cn/pic/nuget.png" alt="Snet Logo"/><br/> Snet </h1>

<p align="center"> <b>统一工业通信框架 · 35+ 协议 · 5 种中间件 · 一套 API</b> </p>

<p align="center"> <img src="https://img.shields.io/badge/.NET-8.0%20%7C%2010.0-purple.svg"/> <img src="https://img.shields.io/badge/NuGet-55%2B%20packages-brightgreen.svg"/> <img src="https://img.shields.io/badge/license-MIT-green"/> <img src="https://img.shields.io/github/directory-file-count/shunnet/SKILLS?type=dir&label=AI%20Skills&color=orange"/> </p>

<p align="center"> <a href="https://snet.cn"><b>🌐 官网</b></a> · <a href="https://docs.snet.cn"><b>📖 文档</b></a> · <a href="https://www.nuget.org/profiles/shun"><b>📦 NuGet</b></a> · <a href="https://github.com/shunnet/Debug"><b>🛠️ Debug 工具</b></a> · <a href="https://github.com/shunnet/Daq"><b>🔌 Daq 工具</b></a> · <a href="https://github.com/shunnet/SKILLS"><b>🤖 AI Skills</b></a> </p>

✨ 亮点速览

🚀 快速开始

IDaq — 数据采集（打开 / 读取 / 写入 / 订阅 / 组包 / 解包 / 关闭 / 释放）

dotnet add package Snet.Modbus

using Snet.Modbus;
using Snet.Model.data;
using Snet.Model.@enum;
using System.Collections.Concurrent;
using System.Linq;

var op = await ModbusOperate.InstanceAsync(new ModbusData.Basics { IpAddress = "192.168.1.100", Port = 502, Station = 1 });

// 打开
await op.OnAsync();

// 读取
var read = await op.ReadAsync(new Address(new AddressDetails("温度", "40001", DataType.Float)));
if (read.Status)
    Console.WriteLine(read.GetSource<ConcurrentDictionary<string, AddressValue>>().First().Value.ResultValue);

// 写入
await op.WriteAsync(new ConcurrentDictionary<string, object> { ["40001"] = 1234f });

// 订阅 — 先绑定事件再订阅
var subAddr = new Address(new AddressDetails("温度", "40001", DataType.Float));
op.OnDataEventAsync += async (s, e) => Console.WriteLine($"收到: {e.ResultData}");
await op.SubscribeAsync(subAddr);

// 取消订阅
await op.UnSubscribeAsync(subAddr);

// 组包 → 读取 → 解包（IDaq 内置 IPacker）
var address = new Address(new List<AddressDetails>
{
    new("温度", "40001", DataType.Float),
    new("压力", "40003", DataType.Float)
});
var packed = await op.PackerAsync(address, "ModbusTcpNet");    // 组包
var packedAddr = packed.GetSource<Address>();
var batch = (await op.ReadAsync(packedAddr)).GetSource<ConcurrentDictionary<string, AddressValue>>();
var values = (await op.UnPackerAsync(batch)).GetSource<List<ConcurrentDictionary<string, AddressValue>>>();  // 解包

// 关闭 + 释放
await op.OffAsync();
await op.DisposeAsync();

将 Modbus 替换为任意协议名（Siemens/Mitsubishi/Omron/OPC...）— API 完全一致。

IMq — 消息中间件（打开 / 生产 / 消费 / 取消消费 / 关闭 / 释放）

dotnet add package Snet.Mqtt

using Snet.Mqtt.client;

var mq = await MqttClientOperate.InstanceAsync(new MqttClientData.Basics { IpAddress = "127.0.0.1", Port = 6688 });

// 打开
await mq.OnAsync();

// 消费 — 先绑定事件再订阅主题
mq.OnDataEventAsync += async (s, e) => Console.WriteLine($"收到: {e.ResultData}");
await mq.ConsumeAsync("snet/temperature");

// 生产 — 字符串 / 原始字节
await mq.ProduceAsync("snet/temperature", "hello mqtt", System.Text.Encoding.UTF8);
await mq.ProduceAsync("snet/temperature", System.Text.Encoding.UTF8.GetBytes("payload"));

// 取消消费
await mq.UnConsumeAsync("snet/temperature");

// 关闭 + 释放
await mq.OffAsync();
await mq.DisposeAsync();

将 Mqtt 替换为任意中间件名（Kafka/RabbitMQ/NetMQ/Netty）— API 完全一致。

🔧 内置能力

数据与处理

扩展与工具

框架机制

🤖 AI 辅助开发

<p align="center"> <a href="https://github.com/shunnet/SKILLS"><b>📦 Snet AI Skills — 自然语言生成完整项目代码</b></a> </p>

每个技能对应 SKILLS 仓库 的一个目录，新增技能 = 新建目录，顶部徽章自动 +1，无需手动改。

🌍 链接

<p align="center"> <b>MIT License</b> · 开源 · 免费商用 · <a href="https://snet.cn">snet.cn</a> </p>