Snet.Log 25.271.5

<img src="https://api.shunnet.top/pic/shun.png" height="32"> Snet - 工业协议与数据采集框架

🚀 统一 · 高效 · 灵活 · 可扩展
面向工业数据采集、传输、转发、消息中间件的全栈式解决方案

✨ 框架特色

1. ✅ 所有协议公共函数 支持同步 / 异步
2. ✅ 协议 读写参数统一，入参出参统一
3. ✅ 支持多点转发 / 多点解析
4. ✅ 快速对接与配置，可即插即用
5. ✅ 支持虚拟点位（模拟测试更便捷）
6. ✅ 采集协议全面支持 订阅模式
7. ✅ 采集与转发协议接口统一
8. ✅ 事件结果统一，并支持 异步事件
9. ✅ 所有采集协议均支持 WebAPI 控制与数据获取
10. ✅ 快捷二次开发，仅需继承接口与抽象类即可

🧩 核心组件

• [ Snet.Log ] 日志系统

  • Verbose 详细信息
  • Debug 调试
  • Info 信息
  • Warning 警告
  • Error 错误
  • Fatal 致命错误

• [ Snet.Unility ] 公共方法集合

  • 字节、枚举、文件、字符串、验证、比对、转换、反射、Json、Xml、Ftp、System ...

• [ Snet.Model ]

  • 特性、数据结构、枚举、接口

• [ Snet.Core ]

  • 抽象、扩展、处理、反射、队列、中间件、脚本、订阅、虚拟地址、TCP、UDP、HTTP、WS、串口、WebApi

• [ Snet.Driver ]

  • 底层驱动通信库

📡 采集协议

支持 20+ 种工业通信协议，覆盖 PLC / 工控 / 电力 / DB / 标准通信 等：

三菱 / 西门子 / Modbus / 汇川 / 欧姆龙 / LSis / 基恩士 / 松下 / 罗克韦尔 / 倍福  
通用电器 / 安川 / 山武 / 永宏 / 丰炜 / 富士 / 信捷 / 麦格米特 / 横河 / 丰田 / 台达 / 维控  
电力通讯规约 / OPC (UA、DA、DAHttp) / DB (SqlServer、MySql、Oracle、SQLite)  
TEP (Tcp扩展插件) / Sim (模拟库) / 英威腾 / 西蒙

接口定义：

/// <summary>
/// 数采接口
/// </summary>
public interface IDaq : IOn, IOff, IRead, IWrite, ISubscribe, 
						IGetStatus, IEvent, IGetParam, ICreateInstance, 
						ILog, IWA, IGetObject, ILanguage, IDisposable { }

📬 消息中间件协议

支持常见的高性能消息中间件：

• Kafka [AdminClient、Producer、Consumer]
• Mqtt [Client (Publish/Subscribe)、Service、WSService]
• RabbitMQ [Publish、Subscribe]
• Netty [Client (Publish/Subscribe)、Service]
• NetMQ [Publish、Subscribe]

接口定义：

/// <summary>
/// 消息中间件接口
/// </summary>
public interface IMq : IOn, IOff, IProducer, IConsumer, IGetStatus, 
					   IEvent, IGetParam, ICreateInstance, ILog, ILanguage, 
					   IDisposable { }

🖥️ 协议服务端 (数据模拟)

• Mqtt 服务端
• Mqtt WebSocket 服务端
• OpcUa 服务端
• Socket 服务端
• WebSocket 服务端

⚡ 实例创建方式

支持 无参、有参、单例、接口化实例 等多种方式，快速上手：

// 以 OPC UA 为例
using Snet.Opc.ua.client;

OpcUaClientOperate? operate = null;
IDaq? daq = null;

// 无参实例
operate = new OpcUaClientOperate();

// 调用 CreateInstance 创建
operate = new OpcUaClientOperate()
              .CreateInstance(new OpcUaClientData.Basics())
              .GetRData<OpcUaClientOperate>();

// 有参实例
operate = new OpcUaClientOperate(new OpcUaClientData.Basics());

// 单例模式
operate = OpcUaClientOperate.Instance(new OpcUaClientData.Basics());

// 接口实例
daq = new OpcUaClientOperate(new OpcUaClientData.Basics());

📥 采集应用示例

通过 NuGet 安装协议包，快速实现采集：

using Snet.Opc.ua.client;

using (OpcUaClientOperate operate = new OpcUaClientOperate(new OpcUaClientData.Basics
{
    ServerUrl = "opc.tcp://127.0.0.1:6688",
    UserName = "user",
    Password = "password",
	...
}))
{
    // 打开连接
    operate.On();

    // 读取数据
    var result = operate.Read(address);

    // 订阅数据
    operate.OnDataEvent += (s, e) => LogHelper.Info(e.ToJson(true));
    operate.Subscribe(address);

    // 写入数据
    operate.Write(new ConcurrentDictionary<string, object> { ["Tag1"] = 123 });

    // 关闭
    operate.Off();
}

🔄 转发应用示例

using Snet.Mqtt.client;

using (MqttClientOperate operate = new MqttClientOperate(new MqttClientData.Basics
{
    IpAddress = "127.0.0.1",
    Port = 6688,
    UserName = "user",
    Password = "password",
	...
}))
{
    // 打开
    operate.On();

    // 生产
    operate.Produce("topic", "content");

    // 消费
    operate.OnDataEvent += (s, e) =>
    {
        string str = e.GetRData<string>();
    };
    operate.Consume("topic");

    // 关闭
    operate.Off();
}

⚙️ 常用操作类名

SerialOperate       // 串口通信
HttpClientOperate   // HTTP 客户端
HttpServiceOperate  // HTTP 服务端
TcpClientOperate    // TCP 客户端
TcpServiceOperate   // TCP 服务端
UdpOperate          // UDP 通信
WsClientOperate     // WebSocket 客户端
WsServiceOperate    // WebSocket 服务端
ProcessCacheOperate // 内存缓存
ShareCacheOperate   // 共享缓存
MqOperate           // 消息队列
ReflectionOperate   // 反射操作

📦 快速开始

1. 打开 NuGet 搜索并安装对应协议包
2. 引入命名空间 using Snet.XXX
3. 按照上方示例编写采集/转发代码

🏗️ 架构总结

Snet 框架通过 统一接口设计 与 模块化协议支持，实现了：

• 数据采集
• 协议转发
• 消息中间件交互
• 模拟服务端测试
• 高效日志与缓存

从 设备 → 协议 → 中间件 → 应用层 全链路打通，支持快速构建工业物联网系统。

📜 许可证

本项目基于 MIT 开源。
请阅读 LICENSE 获取完整条款。
⚠️ 软件按 “原样” 提供，作者不对使用后果承担责任。

🌍 演示

👉 点击查看演示地址