1

src/YSAI.DAQ/YSAI.Can/YSAI.Can.csproj

@@ -5,7 +5,7 @@
     <ImplicitUsings>enable</ImplicitUsings>
     <Nullable>enable</Nullable>
 	  <GeneratePackageOnBuild>True</GeneratePackageOnBuild>
-	  <Version>1.0.0.1</Version>
+	  <Version>1.0.0.2</Version>
 	  <Authors>Shun</Authors>
 	  <Company>YSAI</Company>
 	  <Product>SCADA</Product>
@@ -24,7 +24,7 @@
   </ItemGroup>
 
   <ItemGroup>
-    <PackageReference Include="YSAI.Core" Version="1.0.0.17" />
+    <PackageReference Include="YSAI.Core" Version="1.0.0.18" />
   </ItemGroup>
 
   <!--<ItemGroup>

src/YSAI.DAQ/YSAI.Core/YSAI.Core.csproj

@@ -5,7 +5,7 @@
     <ImplicitUsings>enable</ImplicitUsings>
     <Nullable>enable</Nullable>
     <GeneratePackageOnBuild>True</GeneratePackageOnBuild>
-    <Version>1.0.0.17</Version>
+    <Version>1.0.0.18</Version>
     <Authors>Shun</Authors>
     <Company>YSAI</Company>
     <Product>SCADA</Product>

src/YSAI.DAQ/YSAI.Core/interface/IConsumer.cs

@@ -10,7 +10,7 @@ namespace YSAI.Core.@interface
     /// <summary>
     /// 消费者接口
     /// </summary>
-    public interface IConsumer
+    public interface IConsumer : IEvent
     {
         /// <summary>
         /// 添加订阅

src/YSAI.DAQ/YSAI.DB/YSAI.DB.csproj

@@ -5,7 +5,7 @@
     <ImplicitUsings>enable</ImplicitUsings>
     <Nullable>enable</Nullable>
 	  <GeneratePackageOnBuild>True</GeneratePackageOnBuild>
-	  <Version>1.0.0.1</Version>
+	  <Version>1.0.0.2</Version>
 	  <Authors>Shun</Authors>
 	  <Company>YSAI</Company>
 	  <Product>SCADA</Product>
@@ -18,7 +18,7 @@
 		<PackageReference Include="System.Data.OracleClient" Version="1.0.8" />
 		<PackageReference Include="System.Data.SqlClient" Version="4.8.5" />
 		<PackageReference Include="System.Data.SQLite" Version="1.0.118" />
-		<PackageReference Include="YSAI.Core" Version="1.0.0.17" />
+		<PackageReference Include="YSAI.Core" Version="1.0.0.18" />
 	</ItemGroup>
 	<!--<ItemGroup>
 		<ProjectReference Include="..\YSAI.Core\YSAI.Core.csproj" />

src/YSAI.DAQ/YSAI.DaqManage/YSAI.DaqManage.csproj

@@ -7,7 +7,7 @@
   </PropertyGroup>
 	<ItemGroup>
 		<PackageReference Include="Microsoft.AspNetCore.Http.Features" Version="5.0.17" />
-		<PackageReference Include="YSAI.Core" Version="1.0.0.17" />
+		<PackageReference Include="YSAI.Core" Version="1.0.0.18" />
 	</ItemGroup>
 
 	<!--<ItemGroup>

src/YSAI.DAQ/YSAI.Kafka/YSAI.Kafka.csproj

@@ -5,7 +5,7 @@
     <ImplicitUsings>enable</ImplicitUsings>
     <Nullable>enable</Nullable>
 	  <GeneratePackageOnBuild>True</GeneratePackageOnBuild>
-	  <Version>1.0.0.1</Version>
+	  <Version>1.0.0.2</Version>
 	  <Authors>Shun</Authors>
 	  <Company>YSAI</Company>
 	  <Product>SCADA</Product>
@@ -14,7 +14,7 @@
 
   <ItemGroup>
     <PackageReference Include="Confluent.Kafka" Version="2.2.0" />
-    <PackageReference Include="YSAI.Core" Version="1.0.0.17" />
+    <PackageReference Include="YSAI.Core" Version="1.0.0.18" />
   </ItemGroup>
 	
 	<!--<ItemGroup>

src/YSAI.DAQ/YSAI.Lib/YSAI.Can.Pack/YSAI.Can.xml

@@ -0,0 +1,154 @@
+<?xml version="1.0"?>
+<doc>
+    <assembly>
+        <name>YSAI.Can</name>
+    </assembly>
+    <members>
+        <member name="T:YSAI.Can.CanData.Basics">
+            <summary>
+            基础数据
+            </summary>
+        </member>
+        <member name="P:YSAI.Can.CanData.Basics.SN">
+            <summary>
+            唯一标识符
+            </summary>
+        </member>
+        <member name="P:YSAI.Can.CanData.Basics.BaudRate">
+            <summary>
+            波特率
+            </summary>
+        </member>
+        <member name="P:YSAI.Can.CanData.Basics.CanChannel">
+            <summary>
+            打开的CAN通道
+            </summary>
+        </member>
+        <member name="M:YSAI.Can.CanData.Basics.Equals(System.Object)">
+            <summary>
+            重写基类中的Equals方法
+            </summary>
+            <param name="obj"></param>
+            <returns></returns>
+        </member>
+        <member name="T:YSAI.Can.CanData.ResultData">
+            <summary>
+            结果数据
+            </summary>
+        </member>
+        <member name="P:YSAI.Can.CanData.ResultData.CanID">
+            <summary>
+            CANID
+            </summary>
+        </member>
+        <member name="P:YSAI.Can.CanData.ResultData.ByteData">
+            <summary>
+            字节数据
+            </summary>
+        </member>
+        <member name="P:YSAI.Can.CanData.ResultData.StrByteData">
+            <summary>
+            字符串形式的字节数据
+            </summary>
+        </member>
+        <member name="P:YSAI.Can.CanData.ResultData.Length">
+            <summary>
+            长度
+            </summary>
+        </member>
+        <member name="P:YSAI.Can.CanData.ResultData.Flag">
+            <summary>
+            标志
+            </summary>
+        </member>
+        <member name="P:YSAI.Can.CanData.ResultData.Time">
+            <summary>
+            时间
+            </summary>
+        </member>
+        <member name="T:YSAI.Can.CanData.CanBaudRate">
+            <summary>
+            波特率
+            </summary>
+        </member>
+        <member name="T:YSAI.Can.CanOperator">
+            <summary>
+            can的读取比较特殊无须地址
+            </summary>
+        </member>
+        <member name="M:YSAI.Can.CanOperator.Instance(YSAI.Can.CanData.Basics)">
+            <summary>
+            单例模式
+            </summary>
+            <returns></returns>
+        </member>
+        <member name="M:YSAI.Can.CanOperator.#ctor(YSAI.Can.CanData.Basics)">
+            <summary>
+            构造函数
+            </summary>
+            <param name="param">参数</param>
+        </member>
+        <member name="P:YSAI.Can.CanOperator.basics">
+            <summary>
+            基础数据
+            </summary>
+        </member>
+        <member name="F:YSAI.Can.CanOperator.Status">
+            <summary>      
+            为方法返回的执行状态信息，可以用来判断方法是否成功执行
+            </summary>
+        </member>
+        <member name="F:YSAI.Can.CanOperator.Handle">
+            <summary>
+            句柄
+            </summary>
+        </member>
+        <member name="F:YSAI.Can.CanOperator.MonitorSwitch">
+            <summary>
+            监控开关 
+            </summary>
+        </member>
+        <member name="F:YSAI.Can.CanOperator.CanState">
+            <summary>
+            Can当前状态
+            </summary>
+        </member>
+        <member name="M:YSAI.Can.CanOperator.GetCanState">
+            <summary>
+            获取CAN当前状态
+            </summary>
+            <returns></returns>
+        </member>
+        <member name="M:YSAI.Can.CanOperator.Write(System.Collections.Concurrent.ConcurrentDictionary{System.Int32,System.Byte[]})">
+            <summary>
+            写入
+            </summary>
+            <param name="Values">写入的数据点，与数据类型</param>
+            <returns>统一泛型结果</returns>
+        </member>
+        <member name="M:YSAI.Can.CanOperator.WriteAsync(System.Collections.Concurrent.ConcurrentDictionary{System.Int32,System.Byte[]})">
+            <summary>
+            异步写入
+            </summary>
+            <param name="Values">写入的数据点，与数据类型</param>
+            <returns>统一泛型结果</returns>
+        </member>
+        <member name="F:YSAI.Can.CanOperator.VAM">
+            <summary>
+            虚拟地址
+            </summary>
+        </member>
+        <member name="F:YSAI.Can.CanOperator.subscribeOperate">
+            <summary>
+            实现订阅功能
+            </summary>
+        </member>
+        <member name="M:YSAI.Can.CanOperator.SubscribeOperate_OnEvent(System.Object,YSAI.Core.data.EventResult)">
+            <summary>
+            事件抛出
+            </summary>
+            <param name="sender">自定义订阅对象</param>
+            <param name="e">返回的参数</param>
+        </member>
+    </members>
+</doc>

src/YSAI.DAQ/YSAI.Lib/YSAI.DB.Pack/YSAI.DB.xml

@@ -0,0 +1,246 @@
+<?xml version="1.0"?>
+<doc>
+    <assembly>
+        <name>YSAI.DB</name>
+    </assembly>
+    <members>
+        <member name="T:YSAI.DB.DBData.Basics">
+            <summary>
+            基础数据
+            </summary>
+        </member>
+        <member name="P:YSAI.DB.DBData.Basics.SN">
+            <summary>
+            唯一标识符
+            </summary>
+        </member>
+        <member name="P:YSAI.DB.DBData.Basics.ConnectStr">
+            <summary>
+            数据库连接字符串
+            </summary>
+        </member>
+        <member name="P:YSAI.DB.DBData.Basics.DBType">
+            <summary>
+            数据库类型
+            </summary>
+        </member>
+        <member name="M:YSAI.DB.DBData.Basics.Equals(System.Object)">
+            <summary>
+            重写基类中的Equals方法
+            </summary>
+            <param name="obj"></param>
+            <returns></returns>
+        </member>
+        <member name="T:YSAI.DB.DBData.DBType">
+            <summary>
+            数据库类型
+            </summary>
+        </member>
+        <member name="T:YSAI.DB.DBData.ExtendParam">
+            <summary>
+            扩展参数
+            </summary>
+        </member>
+        <member name="T:YSAI.DB.DBData.ExtendParam.Read">
+            <summary>
+            读取
+            </summary>
+        </member>
+        <member name="P:YSAI.DB.DBData.ExtendParam.Read.Sql">
+            <summary>
+            sql语句
+            </summary>
+        </member>
+        <member name="P:YSAI.DB.DBData.ExtendParam.Read.ColumnName">
+            <summary>
+            需要的列名，针对数据库读取设置
+            </summary>
+        </member>
+        <member name="T:YSAI.DB.DBOperate">
+            <summary>
+            数据库操作
+            </summary>
+        </member>
+        <member name="M:YSAI.DB.DBOperate.Instance(YSAI.DB.DBData.Basics)">
+            <summary>
+            单例模式
+            </summary>
+            <returns></returns>
+        </member>
+        <member name="M:YSAI.DB.DBOperate.#ctor(YSAI.DB.DBData.Basics)">
+            <summary>
+            构造函数
+            </summary>
+            <param name="param">参数</param>
+        </member>
+        <member name="P:YSAI.DB.DBOperate.basics">
+            <summary>
+            连接字符串
+            </summary>
+        </member>
+        <member name="M:YSAI.DB.DBOperate.Execute``1(System.String,``0)">
+            <summary>
+             增删改
+            </summary>
+            <typeparam name="T">实体类型.</typeparam>
+            <param name="sql">传入sql执行语句.</param>
+            <param name="t">传入实体类型.</param>
+            <returns>int.</returns>
+        </member>
+        <member name="M:YSAI.DB.DBOperate.Execute``1(System.String,System.Collections.Generic.List{``0})">
+            <summary>
+            批量 增删改
+            </summary>
+            <typeparam name="T">实体类型.</typeparam>
+            <param name="sql">传入sql执行语句.</param>
+            <param name="t">传入泛型类.</param>
+            <returns>int.</returns>
+        </member>
+        <member name="M:YSAI.DB.DBOperate.Execute(System.String)">
+            <summary>
+            增删改 无实体
+            </summary>
+            <param name="sql">传入sql执行语句</param>
+            <returns>返回执行状态</returns>
+        </member>
+        <member name="M:YSAI.DB.DBOperate.Query``1(System.String)">
+            <summary>
+            查询.
+            </summary>
+            <typeparam name="T">实体类型.</typeparam>
+            <param name="sql">传入sql执行语句.</param>
+            <returns>泛型类.</returns>
+        </member>
+        <member name="M:YSAI.DB.DBOperate.Query``1(System.String,``0)">
+            <summary>
+            查询指定数据.
+            </summary>
+            <typeparam name="T">实体类型.</typeparam>
+            <param name="sql">传入sql执行语句.</param>
+            <param name="t">传入泛型类.</param>
+            <returns>类.</returns>
+        </member>
+        <member name="M:YSAI.DB.DBOperate.QueryList``1(System.String,``0)">
+            <summary>
+            查询多条数据
+            </summary>
+            <typeparam name="T"></typeparam>
+            <param name="sql">查询语句</param>
+            <param name="t">模型</param>
+            <returns></returns>
+        </member>
+        <member name="M:YSAI.DB.DBOperate.QueryDataTable``1(System.String,``0)">
+            <summary>
+            查询数据返回datatable
+            </summary>
+            <typeparam name="T">实体类型</typeparam>
+            <param name="sql">传入sql执行语句</param>
+            <param name="t">实体类型</param>
+            <returns></returns>
+        </member>
+        <member name="M:YSAI.DB.DBOperate.Query``1(System.String,System.Int32[])">
+            <summary>
+            查询的in操作.
+            </summary>
+            <typeparam name="T">实体类型.</typeparam>
+            <param name="sql">传入sql执行语句.</param>
+            <typeparam name="ids">参数</typeparam>
+            <returns>泛型类.</returns>
+        </member>
+        <member name="M:YSAI.DB.DBOperate.QueryMultiple``1(System.String,``0)">
+            <summary>
+            多语句操作
+            </summary>
+            <typeparam name="T">实体类型.</typeparam>
+            <param name="sql">传入sql执行语句.</param>
+            <param name="basics.ConnectStr.ConnectStr">链接字符串.</param>
+        </member>
+        <member name="M:YSAI.DB.DBOperate.Query(System.String)">
+            <summary>
+            查询指定数据.
+            </summary>
+            <typeparam name="T">实体类型.</typeparam>
+            <param name="sql">传入sql执行语句.</param>
+            <param name="t">传入泛型类.</param>
+            <returns>类.</returns>
+        </member>
+        <member name="F:YSAI.DB.DBOperate.VAM">
+            <summary>
+            虚拟地址
+            </summary>
+        </member>
+        <member name="M:YSAI.DB.DBOperate.Analysis(Newtonsoft.Json.Linq.JArray,System.Collections.Generic.List{System.String},YSAI.Core.data.AddressDetails)">
+            <summary>
+            解析数据
+            </summary>
+            <param name="Data"></param>
+            <param name="Columns"></param>
+            <returns></returns>
+        </member>
+        <member name="F:YSAI.DB.DBOperate.Sqls">
+            <summary>
+            sql数据集合
+            </summary>
+        </member>
+        <member name="M:YSAI.DB.DBOperate.AddSql(System.String)">
+            <summary>
+            添加sql
+            </summary>
+            <returns></returns>
+        </member>
+        <member name="M:YSAI.DB.DBOperate.StartSqlExecuteThread">
+            <summary>
+            打开sql按步执行线程
+            </summary>
+        </member>
+        <member name="F:YSAI.DB.DBOperate.SqlExecuteExceptionMaxCount">
+            <summary>
+            Sql执行最大的异常次数
+            </summary>
+        </member>
+        <member name="F:YSAI.DB.DBOperate.SqlExecuteException">
+            <summary>
+            执行sql异常记录
+            异常的sql，异常次数
+            </summary>
+        </member>
+        <member name="T:YSAI.DB.DBOperate.ExceptionSqlInfo">
+            <summary>
+            异常sql信息
+            </summary>
+        </member>
+        <member name="P:YSAI.DB.DBOperate.ExceptionSqlInfo.ExceptionCount">
+            <summary>
+            异常次数
+            </summary>
+        </member>
+        <member name="P:YSAI.DB.DBOperate.ExceptionSqlInfo.ExceptionCode">
+            <summary>
+            异常的状态码
+            </summary>
+        </member>
+        <member name="P:YSAI.DB.DBOperate.ExceptionSqlInfo.ExceptionMessage">
+            <summary>
+            异常信息
+            </summary>
+        </member>
+        <member name="M:YSAI.DB.DBOperate.SqlExecute(System.String)">
+            <summary>
+            执行增删改的sql语句
+            </summary>
+            <returns></returns>
+        </member>
+        <member name="F:YSAI.DB.DBOperate.subscribeOperate">
+            <summary>
+            实现订阅功能
+            </summary>
+        </member>
+        <member name="M:YSAI.DB.DBOperate.SubscribeOperate_OnEvent(System.Object,YSAI.Core.data.EventResult)">
+            <summary>
+            事件抛出
+            </summary>
+            <param name="sender">自定义订阅对象</param>
+            <param name="e">返回的参数</param>
+        </member>
+    </members>
+</doc>

src/YSAI.DAQ/YSAI.Lib/YSAI.Kafka.Pack/YSAI.Kafka.xml

@@ -0,0 +1,186 @@
+<?xml version="1.0"?>
+<doc>
+    <assembly>
+        <name>YSAI.Kafka</name>
+    </assembly>
+    <members>
+        <member name="T:YSAI.Kafka.KafkaData.Basics">
+            <summary>
+            基础数据
+            </summary>
+        </member>
+        <member name="P:YSAI.Kafka.KafkaData.Basics.SN">
+            <summary>
+            唯一标识符
+            </summary>
+        </member>
+        <member name="P:YSAI.Kafka.KafkaData.Basics.BootstrapServers">
+            <summary>
+            服务器地址
+            </summary>
+        </member>
+        <member name="P:YSAI.Kafka.KafkaData.Basics.WaitTime">
+            <summary>
+            最多等待时间（毫秒）
+            </summary>
+        </member>
+        <member name="P:YSAI.Kafka.KafkaData.Basics.SecurityProtocol">
+            <summary>
+            安全协议
+            </summary>
+        </member>
+        <member name="P:YSAI.Kafka.KafkaData.Basics.AutoOffsetReset">
+            <summary>
+            自动偏移复位
+            </summary>
+        </member>
+        <member name="M:YSAI.Kafka.KafkaData.Basics.Equals(System.Object)">
+            <summary>
+            重写基类中的Equals方法
+            </summary>
+            <param name="obj"></param>
+            <returns></returns>
+        </member>
+        <member name="T:YSAI.Kafka.KafkaData.ConsumeData`2">
+            <summary>
+            消费订阅得到的数据
+            </summary>
+        </member>
+        <member name="P:YSAI.Kafka.KafkaData.ConsumeData`2.Message">
+            <summary>
+            消息
+            </summary>
+        </member>
+        <member name="P:YSAI.Kafka.KafkaData.ConsumeData`2.State">
+            <summary>
+            状态
+            </summary>
+        </member>
+        <member name="P:YSAI.Kafka.KafkaData.ConsumeData`2.Topic">
+            <summary>
+            主题
+            </summary>
+        </member>
+        <member name="P:YSAI.Kafka.KafkaData.ConsumeData`2.Key">
+            <summary>
+            键
+            </summary>
+        </member>
+        <member name="P:YSAI.Kafka.KafkaData.ConsumeData`2.Value">
+            <summary>
+            值
+            </summary>
+        </member>
+        <member name="P:YSAI.Kafka.KafkaData.ConsumeData`2.Time">
+            <summary>
+            时间
+            </summary>
+        </member>
+        <member name="M:YSAI.Kafka.KafkaOperate.Instance(YSAI.Kafka.KafkaData.Basics)">
+            <summary>
+            单例模式
+            </summary>
+            <returns></returns>
+        </member>
+        <member name="P:YSAI.Kafka.KafkaOperate.basics">
+            <summary>
+            基础数据
+            </summary>
+        </member>
+        <member name="M:YSAI.Kafka.KafkaOperate.#ctor(YSAI.Kafka.KafkaData.Basics)">
+            <summary>
+            构造函数
+            </summary>
+        </member>
+        <member name="P:YSAI.Kafka.KafkaOperate.producerConfig">
+            <summary>
+            生产者配置
+            </summary>
+        </member>
+        <member name="P:YSAI.Kafka.KafkaOperate.consumerConfig">
+            <summary>
+            消费者配置
+            </summary>
+        </member>
+        <member name="P:YSAI.Kafka.KafkaOperate.adminClientConfig">
+            <summary>
+            客户端管理员配置
+            </summary>
+        </member>
+        <member name="F:YSAI.Kafka.KafkaOperate.TopicArray">
+            <summary>
+            主题集合
+            </summary>
+        </member>
+        <member name="F:YSAI.Kafka.KafkaOperate.Consumer">
+            <summary>
+            订阅的消费者
+            </summary>
+        </member>
+        <member name="P:YSAI.Kafka.KafkaOperate.IsOpen">
+            <summary>
+            是否打开
+            </summary>
+        </member>
+        <member name="F:YSAI.Kafka.KafkaOperate.PollingState">
+            <summary>
+            轮询状态
+            </summary>
+        </member>
+        <member name="M:YSAI.Kafka.KafkaOperate.Dispose">
+            <summary>
+            释放
+            </summary>
+        </member>
+        <member name="M:YSAI.Kafka.KafkaOperate.Polling">
+            <summary>
+            轮询消费
+            </summary>
+            <returns></returns>
+        </member>
+        <member name="M:YSAI.Kafka.KafkaOperate.CreateTopicsAsync(System.Collections.Generic.List{System.String})">
+            <summary>
+            创建主题，用于生产者消费者使用
+            </summary>
+            <returns>统一出参</returns>
+        </member>
+        <member name="M:YSAI.Kafka.KafkaOperate.CreateTopics(System.Collections.Generic.List{System.String})">
+            <summary>
+            创建主题，用于生产者消费者使用
+            </summary>
+            <returns>统一出参</returns>
+        </member>
+        <member name="M:YSAI.Kafka.KafkaOperate.Produce(System.String,System.String,System.String)">
+            <summary>
+            生产
+            </summary>
+            <param name="Topic">主题</param>
+            <param name="Key">键</param>
+            <param name="Content">值</param>
+            <returns>统一出参</returns>
+        </member>
+        <member name="M:YSAI.Kafka.KafkaOperate.ProduceAsync(System.String,System.String,System.String)">
+            <summary>
+            生产
+            </summary>
+            <param name="Topic">主题</param>
+            <param name="Key">键</param>
+            <param name="Content">值</param>
+            <returns>统一出参</returns>
+        </member>
+        <member name="M:YSAI.Kafka.KafkaOperate.ConsumeAsync(System.String)">
+            <summary>
+            订阅 - 消费
+            </summary>
+            <param name="Topic">主题</param>
+            <returns>统一出参</returns>
+        </member>
+        <member name="M:YSAI.Kafka.KafkaOperate.Consume(System.String)">
+            <summary>
+            订阅 - 消费
+            </summary>
+            <param name="Topic">主题</param>
+            <returns>统一出参</returns>
+        </member>
+    </members>
+</doc>

src/YSAI.DAQ/YSAI.Lib/YSAI.Mqtt.Pack/YSAI.Mqtt.xml

@@ -0,0 +1,495 @@
+<?xml version="1.0"?>
+<doc>
+    <assembly>
+        <name>YSAI.Mqtt</name>
+    </assembly>
+    <members>
+        <member name="T:YSAI.Mqtt.client.MqttClientData">
+            <summary>
+            mqtt 客户端数据
+            </summary>
+        </member>
+        <member name="T:YSAI.Mqtt.client.MqttClientData.Basics">
+            <summary>
+            基础数据
+            </summary>
+        </member>
+        <member name="P:YSAI.Mqtt.client.MqttClientData.Basics.SN">
+            <summary>
+            唯一标识符
+            </summary>
+        </member>
+        <member name="P:YSAI.Mqtt.client.MqttClientData.Basics.ServerIPAddress">
+            <summary>
+            IP地址
+            </summary>
+        </member>
+        <member name="P:YSAI.Mqtt.client.MqttClientData.Basics.ServerPort">
+            <summary>
+            端口
+            </summary>
+        </member>
+        <member name="P:YSAI.Mqtt.client.MqttClientData.Basics.ServerLoginID">
+            <summary>
+            登陆账号
+            </summary>
+        </member>
+        <member name="P:YSAI.Mqtt.client.MqttClientData.Basics.ServerLoginPassword">
+            <summary>
+            登陆密码
+            </summary>
+        </member>
+        <member name="P:YSAI.Mqtt.client.MqttClientData.Basics.ClientID">
+            <summary>
+            客户端ID
+            不输入默认生成随机
+            </summary>
+        </member>
+        <member name="P:YSAI.Mqtt.client.MqttClientData.Basics.QualityOfServiceLevel">
+            <summary>
+            QoS0 是最低级别，基本上等同于 Fire and Forget 模式，发送者发送完数据之后，不关心消息是否已经投递到了接收者那边。
+            QoS1 是中间级别，保证消息至少送达一次。MQTT 通过简单的 ACK 机制来保证 QoS1。
+            QoS2 是最高级别，保证到且仅到一次。这通过更加复杂的消息流程保证。
+            
+            注意：QoS 级别越高，流程越复杂，系统资源消耗越大
+            </summary>
+        </member>
+        <member name="M:YSAI.Mqtt.client.MqttClientData.Basics.Equals(System.Object)">
+            <summary>
+            重写基类中的Equals方法
+            </summary>
+            <param name="obj"></param>
+            <returns></returns>
+        </member>
+        <member name="T:YSAI.Mqtt.client.MqttClientOperate">
+            <summary>
+            Mqtt 客户端
+            </summary>
+        </member>
+        <member name="M:YSAI.Mqtt.client.MqttClientOperate.Instance(YSAI.Mqtt.client.MqttClientData.Basics)">
+            <summary>
+            单例模式
+            </summary>
+            <returns></returns>
+        </member>
+        <member name="M:YSAI.Mqtt.client.MqttClientOperate.#ctor(YSAI.Mqtt.client.MqttClientData.Basics)">
+            <summary>
+            构造函数
+            </summary>
+        </member>
+        <member name="F:YSAI.Mqtt.client.MqttClientOperate.mqttClientData">
+            <summary>
+            基础数据
+            </summary>
+        </member>
+        <member name="F:YSAI.Mqtt.client.MqttClientOperate.mqttClient">
+            <summary>
+            MQTT 客户端
+            </summary>
+        </member>
+        <member name="M:YSAI.Mqtt.client.MqttClientOperate.MqttClient_ApplicationMessageReceivedAsync(MQTTnet.Client.MqttApplicationMessageReceivedEventArgs)">
+            <summary>
+            消息事件
+            </summary>
+        </member>
+        <member name="M:YSAI.Mqtt.client.MqttClientOperate.PublishSubscribeAsync(System.String,System.String,System.Int32,System.Boolean)">
+            <summary>
+            发布订阅
+            </summary>
+            <param name="Topic">主题</param>
+            <param name="Content">内容</param>
+            <param name="QoSLevel">
+            消息等级
+            QoS 0 是最低级别，基本上等同于 Fire and Forget 模式，发送者发送完数据之后，不关心消息是否已经投递到了接收者那边。
+            QoS 1 是中间级别，保证消息至少送达一次。MQTT 通过简单的 ACK 机制来保证 QoS1。
+            QoS 2 是最高级别，保证到且仅到一次。这通过更加复杂的消息流程保证。
+            
+            注意：QoS 级别越高，流程越复杂，系统资源消耗越大
+            </param>
+            <param name="Retain">消息是否保留</param>
+            <returns>统一结果</returns>
+        </member>
+        <member name="M:YSAI.Mqtt.client.MqttClientOperate.PublishSubscribe(System.String,System.String,System.Int32,System.Boolean)">
+            <summary>
+            发布订阅
+            </summary>
+            <param name="Topic">主题</param>
+            <param name="Content">内容</param>
+            <param name="QoSLevel">
+            消息等级
+            QoS 0 是最低级别，基本上等同于 Fire and Forget 模式，发送者发送完数据之后，不关心消息是否已经投递到了接收者那边。
+            QoS 1 是中间级别，保证消息至少送达一次。MQTT 通过简单的 ACK 机制来保证 QoS1。
+            QoS 2 是最高级别，保证到且仅到一次。这通过更加复杂的消息流程保证。
+            
+            注意：QoS 级别越高，流程越复杂，系统资源消耗越大
+            </param>
+            <param name="Retain">消息是否保留</param>
+            <returns>统一结果</returns>
+        </member>
+        <member name="M:YSAI.Mqtt.client.MqttClientOperate.AddSubscribeAsync(System.String,System.Int32)">
+            <summary>
+            添加订阅
+            </summary>
+            <param name="Topic">主题</param>
+            <param name="QoSLevel">
+            消息等级
+            QoS 0 是最低级别，基本上等同于 Fire and Forget 模式，发送者发送完数据之后，不关心消息是否已经投递到了接收者那边。
+            QoS 1 是中间级别，保证消息至少送达一次。MQTT 通过简单的 ACK 机制来保证 QoS1。
+            QoS 2 是最高级别，保证到且仅到一次。这通过更加复杂的消息流程保证。
+            
+            注意：QoS 级别越高，流程越复杂，系统资源消耗越大
+            </param>
+            <returns>统一结果</returns>
+        </member>
+        <member name="M:YSAI.Mqtt.client.MqttClientOperate.AddSubscribe(System.String,System.Int32)">
+            <summary>
+            添加订阅
+            </summary>
+            <param name="Topic">主题</param>
+            <param name="QoSLevel">
+            消息等级
+            QoS 0 是最低级别，基本上等同于 Fire and Forget 模式，发送者发送完数据之后，不关心消息是否已经投递到了接收者那边。
+            QoS 1 是中间级别，保证消息至少送达一次。MQTT 通过简单的 ACK 机制来保证 QoS1。
+            QoS 2 是最高级别，保证到且仅到一次。这通过更加复杂的消息流程保证。
+            
+            注意：QoS 级别越高，流程越复杂，系统资源消耗越大
+            </param>
+            <returns>统一结果</returns>
+        </member>
+        <member name="M:YSAI.Mqtt.client.MqttClientOperate.RemoveSubscribeAsync(System.String)">
+            <summary>
+            移除订阅
+            </summary>
+            <param name="Topic">主题</param>
+            <returns>统一结果</returns>
+        </member>
+        <member name="M:YSAI.Mqtt.client.MqttClientOperate.RemoveSubscribe(System.String)">
+            <summary>
+            移除订阅
+            </summary>
+            <param name="Topic">主题</param>
+            <returns>统一结果</returns>
+        </member>
+        <member name="T:YSAI.Mqtt.service.MqttServiceData">
+            <summary>
+            mqtt 服务 数据
+            </summary>
+        </member>
+        <member name="T:YSAI.Mqtt.service.MqttServiceData.Basics">
+            <summary>
+            基础数据
+            </summary>
+        </member>
+        <member name="P:YSAI.Mqtt.service.MqttServiceData.Basics.Port">
+            <summary>
+            端口
+            </summary>
+        </member>
+        <member name="P:YSAI.Mqtt.service.MqttServiceData.Basics.LoginID">
+            <summary>
+            登陆账号
+            </summary>
+        </member>
+        <member name="P:YSAI.Mqtt.service.MqttServiceData.Basics.LoginPassword">
+            <summary>
+            登陆密码
+            </summary>
+        </member>
+        <member name="P:YSAI.Mqtt.service.MqttServiceData.Basics.MaxNumber">
+            <summary>
+            最大连接数
+            </summary>
+        </member>
+        <member name="M:YSAI.Mqtt.service.MqttServiceData.Basics.Equals(System.Object)">
+            <summary>
+            重写基类中的Equals方法
+            </summary>
+            <param name="obj"></param>
+            <returns></returns>
+        </member>
+        <member name="T:YSAI.Mqtt.service.MqttServiceData.Steps">
+            <summary>
+            哪一个步骤
+            </summary>
+        </member>
+        <member name="T:YSAI.Mqtt.service.MqttServiceData.States">
+            <summary>
+            状态
+            </summary>
+        </member>
+        <member name="F:YSAI.Mqtt.service.MqttServiceData.States.On">
+            <summary>
+            已启动
+            </summary>
+        </member>
+        <member name="F:YSAI.Mqtt.service.MqttServiceData.States.Off">
+            <summary>
+            已停止
+            </summary>
+        </member>
+        <member name="F:YSAI.Mqtt.service.MqttServiceData.States.Null">
+            <summary>
+            啥也没干
+            </summary>
+        </member>
+        <member name="T:YSAI.Mqtt.service.MqttServiceOperate">
+            <summary>
+            mqtt 服务端
+            </summary>
+        </member>
+        <member name="M:YSAI.Mqtt.service.MqttServiceOperate.Instance(YSAI.Mqtt.service.MqttServiceData.Basics)">
+            <summary>
+            单例模式
+            </summary>
+            <returns></returns>
+        </member>
+        <member name="M:YSAI.Mqtt.service.MqttServiceOperate.#ctor(YSAI.Mqtt.service.MqttServiceData.Basics)">
+            <summary>
+            构造函数
+            </summary>
+            <param name="mqttServiceData">参数</param>
+        </member>
+        <member name="F:YSAI.Mqtt.service.MqttServiceOperate.mqttServiceData">
+            <summary>
+            参数
+            </summary>
+        </member>
+        <member name="F:YSAI.Mqtt.service.MqttServiceOperate.mqttServer">
+            <summary>
+            MQTT 服务
+            </summary>
+        </member>
+        <member name="F:YSAI.Mqtt.service.MqttServiceOperate.states">
+            <summary>
+            状态
+            </summary>
+        </member>
+        <member name="M:YSAI.Mqtt.service.MqttServiceOperate.MqttServer_StoppedAsync(System.EventArgs)">
+            <summary>
+            服务停止后
+            </summary>
+        </member>
+        <member name="M:YSAI.Mqtt.service.MqttServiceOperate.MqttServer_StartedAsync(System.EventArgs)">
+            <summary>
+            服务启动后
+            </summary>
+        </member>
+        <member name="M:YSAI.Mqtt.service.MqttServiceOperate.MqttServer_ClientUnsubscribedTopicAsync(MQTTnet.Server.ClientUnsubscribedTopicEventArgs)">
+            <summary>
+            客户端取消订阅
+            </summary>
+        </member>
+        <member name="M:YSAI.Mqtt.service.MqttServiceOperate.MqttServer_ClientSubscribedTopicAsync(MQTTnet.Server.ClientSubscribedTopicEventArgs)">
+            <summary>
+            客户端订阅
+            </summary>
+        </member>
+        <member name="M:YSAI.Mqtt.service.MqttServiceOperate.MqttServer_ApplicationMessageNotConsumedAsync(MQTTnet.Server.ApplicationMessageNotConsumedEventArgs)">
+            <summary>
+            客户端消息接收
+            </summary>
+        </member>
+        <member name="M:YSAI.Mqtt.service.MqttServiceOperate.MqttServer_ClientDisconnectedAsync(MQTTnet.Server.ClientDisconnectedEventArgs)">
+            <summary>
+            客户端断开
+            </summary>
+        </member>
+        <member name="M:YSAI.Mqtt.service.MqttServiceOperate.MqttServer_ClientConnectedAsync(MQTTnet.Server.ClientConnectedEventArgs)">
+            <summary>
+            客户端连接
+            </summary>
+        </member>
+        <member name="M:YSAI.Mqtt.service.MqttServiceOperate.MqttServer_ValidatingConnectionAsync(MQTTnet.Server.ValidatingConnectionEventArgs)">
+            <summary>
+            身份验证
+            </summary>
+            <param name="arg"></param>
+            <returns></returns>
+            <exception cref="T:System.NotImplementedException"></exception>
+        </member>
+        <member name="M:YSAI.Mqtt.service.MqttServiceOperate.GetState">
+            <summary>
+            获取状态
+            </summary>
+            <returns></returns>
+        </member>
+        <member name="M:YSAI.Mqtt.service.MqttServiceOperate.Dispose">
+            <summary>
+            释放
+            </summary>
+        </member>
+        <member name="M:YSAI.Mqtt.service.MqttServiceOperate.On">
+            <summary>
+            打开
+            </summary>
+            <returns>统一泛型结果</returns>
+        </member>
+        <member name="M:YSAI.Mqtt.service.MqttServiceOperate.OnAsync">
+            <summary>
+            异步打开
+            </summary>
+            <returns>统一泛型结果</returns>
+        </member>
+        <member name="M:YSAI.Mqtt.service.MqttServiceOperate.Off">
+            <summary>
+            关闭
+            </summary>
+            <returns>统一泛型结果</returns>
+        </member>
+        <member name="M:YSAI.Mqtt.service.MqttServiceOperate.OffAsync">
+            <summary>
+            异步关闭
+            </summary>
+            <returns>统一泛型结果</returns>
+        </member>
+        <member name="T:YSAI.Mqtt.service.websocket.MqttWebSocketServiceData">
+            <summary>
+            websocketservice 数据
+            </summary>
+        </member>
+        <member name="T:YSAI.Mqtt.service.websocket.MqttWebSocketServiceData.IMqttWebSocketService">
+            <summary>
+            MQTTwebsocket 接口
+            </summary>
+        </member>
+        <member name="T:YSAI.Mqtt.service.websocket.MqttWebSocketServiceData.Basics">
+            <summary>
+            基础数据
+            </summary>
+        </member>
+        <member name="P:YSAI.Mqtt.service.websocket.MqttWebSocketServiceData.Basics.Port">
+            <summary>
+            MQTT服务端口
+            </summary>
+        </member>
+        <member name="P:YSAI.Mqtt.service.websocket.MqttWebSocketServiceData.Basics.HttpPort">
+            <summary>
+            HTTP 端口 Mqtt WEBSOCKET 使用
+            </summary>
+        </member>
+        <member name="P:YSAI.Mqtt.service.websocket.MqttWebSocketServiceData.Basics.LoginID">
+            <summary>
+            登陆账号
+            </summary>
+        </member>
+        <member name="P:YSAI.Mqtt.service.websocket.MqttWebSocketServiceData.Basics.LoginPassword">
+            <summary>
+            登陆密码
+            </summary>
+        </member>
+        <member name="P:YSAI.Mqtt.service.websocket.MqttWebSocketServiceData.Basics.Uri">
+            <summary>
+            地址
+            </summary>
+        </member>
+        <member name="M:YSAI.Mqtt.service.websocket.MqttWebSocketServiceData.Basics.Equals(System.Object)">
+            <summary>
+            重写基类中的Equals方法
+            </summary>
+            <param name="obj"></param>
+            <returns></returns>
+        </member>
+        <member name="T:YSAI.Mqtt.service.websocket.MqttWebSocketServiceData.Steps">
+            <summary>
+            哪一个步骤
+            </summary>
+        </member>
+        <member name="T:YSAI.Mqtt.service.websocket.MqttWebSocketServiceOperate">
+            <summary>
+            MQTT WEBSOCKET 服务
+            </summary>
+        </member>
+        <member name="M:YSAI.Mqtt.service.websocket.MqttWebSocketServiceOperate.Instance(YSAI.Mqtt.service.websocket.MqttWebSocketServiceData.Basics)">
+            <summary>
+            单例模式
+            </summary>
+            <returns></returns>
+        </member>
+        <member name="P:YSAI.Mqtt.service.websocket.MqttWebSocketServiceOperate.mqttServiceData">
+            <summary>
+            配置数据
+            </summary>
+        </member>
+        <member name="P:YSAI.Mqtt.service.websocket.MqttWebSocketServiceOperate.mqttServiceData_Static">
+            <summary>
+            配置数据（静态）
+            </summary>
+        </member>
+        <member name="M:YSAI.Mqtt.service.websocket.MqttWebSocketServiceOperate.#ctor(YSAI.Mqtt.service.websocket.MqttWebSocketServiceData.Basics)">
+            <summary>
+            构造函数
+            </summary>
+            <param name="param"></param>
+        </member>
+        <member name="M:YSAI.Mqtt.service.websocket.MqttWebSocketServiceOperate.GetWriteHead">
+            <summary>
+            获取控制台输出头
+            </summary>
+            <returns></returns>
+        </member>
+        <member name="E:YSAI.Mqtt.service.websocket.MqttWebSocketServiceOperate.OnEvent">
+            <summary>
+            信息传递
+            </summary>
+        </member>
+        <member name="F:YSAI.Mqtt.service.websocket.MqttWebSocketServiceOperate.OnEventHandler">
+            <summary>
+            信息传递
+            </summary>
+        </member>
+        <member name="T:YSAI.Mqtt.service.websocket.MqttWebSocketServiceOperate.MqttController">
+            <summary>
+            MQTT控制器
+            </summary>
+        </member>
+        <member name="M:YSAI.Mqtt.service.websocket.MqttWebSocketServiceOperate.MqttController.MqttServer_ClientUnsubscribedTopicAsync(MQTTnet.Server.ClientUnsubscribedTopicEventArgs)">
+            <summary>
+            客户端取消订阅
+            </summary>
+        </member>
+        <member name="M:YSAI.Mqtt.service.websocket.MqttWebSocketServiceOperate.MqttController.MqttServer_ClientSubscribedTopicAsync(MQTTnet.Server.ClientSubscribedTopicEventArgs)">
+            <summary>
+            客户端订阅
+            </summary>
+        </member>
+        <member name="M:YSAI.Mqtt.service.websocket.MqttWebSocketServiceOperate.MqttController.MqttServer_ApplicationMessageNotConsumedAsync(MQTTnet.Server.ApplicationMessageNotConsumedEventArgs)">
+            <summary>
+            客户端消息接收
+            </summary>
+        </member>
+        <member name="M:YSAI.Mqtt.service.websocket.MqttWebSocketServiceOperate.MqttController.MqttServer_ClientDisconnectedAsync(MQTTnet.Server.ClientDisconnectedEventArgs)">
+            <summary>
+            客户端断开
+            </summary>
+        </member>
+        <member name="M:YSAI.Mqtt.service.websocket.MqttWebSocketServiceOperate.MqttController.MqttServer_ClientConnectedAsync(MQTTnet.Server.ClientConnectedEventArgs)">
+            <summary>
+            客户端连接
+            </summary>
+        </member>
+        <member name="M:YSAI.Mqtt.service.websocket.MqttWebSocketServiceOperate.MqttController.MqttServer_ValidatingConnectionAsync(MQTTnet.Server.ValidatingConnectionEventArgs)">
+            <summary>
+            身份验证
+            </summary>
+            <param name="arg"></param>
+            <returns></returns>
+            <exception cref="T:System.NotImplementedException"></exception>
+        </member>
+        <member name="T:YSAI.Mqtt.service.websocket.MqttWebSocketServiceOperate.Startup">
+            <summary>
+            启动
+            </summary>
+        </member>
+        <member name="M:YSAI.Mqtt.service.websocket.MqttWebSocketServiceOperate.Startup.Configure(Microsoft.AspNetCore.Builder.IApplicationBuilder,Microsoft.AspNetCore.Hosting.IWebHostEnvironment,YSAI.Mqtt.service.websocket.MqttWebSocketServiceOperate.MqttController)">
+            <summary>
+            配置
+            </summary>
+        </member>
+        <member name="M:YSAI.Mqtt.service.websocket.MqttWebSocketServiceOperate.Startup.ConfigureServices(Microsoft.Extensions.DependencyInjection.IServiceCollection)">
+            <summary>
+            配置服务
+            </summary>
+            <param name="services"></param>
+        </member>
+    </members>
+</doc>

src/YSAI.DAQ/YSAI.Lib/YSAI.RabbitMQ.Pack/YSAI.RabbitMQ.xml

@@ -0,0 +1,181 @@
+<?xml version="1.0"?>
+<doc>
+    <assembly>
+        <name>YSAI.RabbitMQ</name>
+    </assembly>
+    <members>
+        <member name="T:YSAI.RabbitMQ.RabbitMQData">
+            <summary>
+            数据
+            </summary>
+        </member>
+        <member name="T:YSAI.RabbitMQ.RabbitMQData.Basics">
+            <summary>
+            基础数据
+            </summary>
+        </member>
+        <member name="P:YSAI.RabbitMQ.RabbitMQData.Basics.SN">
+            <summary>
+            唯一标识符
+            </summary>
+        </member>
+        <member name="P:YSAI.RabbitMQ.RabbitMQData.Basics.ExChangeName">
+            <summary>
+            交换机名称
+            </summary>
+        </member>
+        <member name="P:YSAI.RabbitMQ.RabbitMQData.Basics.HostName">
+            <summary>
+            要连接的地址
+            </summary>
+        </member>
+        <member name="P:YSAI.RabbitMQ.RabbitMQData.Basics.Port">
+            <summary>
+            端口
+            </summary>
+        </member>
+        <member name="P:YSAI.RabbitMQ.RabbitMQData.Basics.UserName">
+            <summary>
+            账号
+            </summary>
+        </member>
+        <member name="P:YSAI.RabbitMQ.RabbitMQData.Basics.Password">
+            <summary>
+            密码
+            </summary>
+        </member>
+        <member name="M:YSAI.RabbitMQ.RabbitMQData.Basics.Equals(System.Object)">
+            <summary>
+            重写Equals
+            </summary>
+            <param name="obj"></param>
+            <returns></returns>
+        </member>
+        <member name="T:YSAI.RabbitMQ.RabbitMQOperate">
+            <summary>
+            发布者操作
+            </summary>
+        </member>
+        <member name="M:YSAI.RabbitMQ.RabbitMQOperate.Instance(YSAI.RabbitMQ.RabbitMQData.Basics)">
+            <summary>
+            单例模式
+            </summary>
+            <returns></returns>
+        </member>
+        <member name="P:YSAI.RabbitMQ.RabbitMQOperate.basics">
+            <summary>
+            基础数据
+            </summary>
+        </member>
+        <member name="M:YSAI.RabbitMQ.RabbitMQOperate.#ctor(YSAI.RabbitMQ.RabbitMQData.Basics)">
+            <summary>
+            构造函数
+            </summary>
+        </member>
+        <member name="P:YSAI.RabbitMQ.RabbitMQOperate.connection">
+            <summary>
+            连接对象
+            </summary>
+        </member>
+        <member name="F:YSAI.RabbitMQ.RabbitMQOperate.Channels">
+            <summary>
+            通道集合
+            </summary>
+        </member>
+        <member name="F:YSAI.RabbitMQ.RabbitMQOperate.Queues">
+            <summary>
+            队列集合
+            </summary>
+        </member>
+        <member name="F:YSAI.RabbitMQ.RabbitMQOperate.QueueAndBasicProperties">
+            <summary>
+            队列与基础数据
+            </summary>
+        </member>
+        <member name="M:YSAI.RabbitMQ.RabbitMQOperate.Publish(System.String,System.String,System.String,System.String,System.String,System.Boolean,System.Boolean,System.Boolean)">
+            <summary>
+            发布 一个交换机可以发布多个消息
+            </summary>
+            <param name="Content">消息内容</param>
+            <param name="Topic">主题不为空，则队列、路由设置为主题</param>
+            <param name="Queue">队列名称</param>
+            <param name="RoutingKey">路由键</param>
+            <param name="Type">
+            通道类型
+            direct  //用于AMQP直接交换的交换类型。
+            fanout  //用于AMQP扇出交换的交换类型。
+            headers //用于AMQP报头交换的交换类型。
+            topic   //用于AMQP主题交换的交换类型。
+            </param>
+            <param name="Durable">持久化</param>
+            <param name="Exclusive">独有的</param>
+            <param name="AutoDelete">自动删除</param>
+            <returns>统一出参</returns>
+        </member>
+        <member name="M:YSAI.RabbitMQ.RabbitMQOperate.PublishAsync(System.String,System.String,System.String,System.String,System.String,System.Boolean,System.Boolean,System.Boolean)">
+            <summary>
+            发布 一个交换机可以发布多个消息
+            </summary>
+            <param name="Content">消息内容</param>
+            <param name="Topic">主题不为空，则队列、路由设置为主题</param>
+            <param name="Queue">队列名称</param>
+            <param name="RoutingKey">路由键</param>
+            <param name="Type">
+            通道类型
+            direct  //用于AMQP直接交换的交换类型。
+            fanout  //用于AMQP扇出交换的交换类型。
+            headers //用于AMQP报头交换的交换类型。
+            topic   //用于AMQP主题交换的交换类型。
+            </param>
+            <param name="Durable">持久化</param>
+            <param name="Exclusive">独有的</param>
+            <param name="AutoDelete">自动删除</param>
+            <returns>统一出参</returns>
+        </member>
+        <member name="M:YSAI.RabbitMQ.RabbitMQOperate.Consume(System.String,System.String,System.String,System.String,System.Boolean,System.Boolean,System.Boolean,System.Boolean)">
+            <summary>
+            消费 一个交换机可以消费多个消息
+            </summary>
+            <param name="Topic">主题不为空，则队列、路由设置为主题</param>
+            <param name="Queue">队列名称</param>
+            <param name="RoutingKey">路由键</param>
+            <param name="Type">
+            通道类型
+            direct  //用于AMQP直接交换的交换类型。
+            fanout  //用于AMQP扇出交换的交换类型。
+            headers //用于AMQP报头交换的交换类型。
+            topic   //用于AMQP主题交换的交换类型。
+            </param>
+            <param name="AutoAck">自动确认</param>
+            <param name="Durable">持久化</param>
+            <param name="Exclusive">独有的</param>
+            <param name="AutoDelete">自动删除</param>
+            <returns>统一出参</returns>
+        </member>
+        <member name="M:YSAI.RabbitMQ.RabbitMQOperate.ConsumeAsync(System.String,System.String,System.String,System.String,System.Boolean,System.Boolean,System.Boolean,System.Boolean)">
+            <summary>
+            消费 一个交换机可以消费多个消息
+            </summary>
+            <param name="Topic">主题不为空，则队列、路由设置为主题</param>
+            <param name="Queue">队列名称</param>
+            <param name="RoutingKey">路由键</param>
+            <param name="Type">
+            通道类型
+            direct  //用于AMQP直接交换的交换类型。
+            fanout  //用于AMQP扇出交换的交换类型。
+            headers //用于AMQP报头交换的交换类型。
+            topic   //用于AMQP主题交换的交换类型。
+            </param>
+            <param name="AutoAck">自动确认</param>
+            <param name="Durable">持久化</param>
+            <param name="Exclusive">独有的</param>
+            <param name="AutoDelete">自动删除</param>
+            <returns>统一出参</returns>
+        </member>
+        <member name="M:YSAI.RabbitMQ.RabbitMQOperate.Consumer_Received(System.Object,RabbitMQ.Client.Events.BasicDeliverEventArgs,System.Boolean)">
+            <summary>
+            [消费]接收发布者消息
+            </summary>
+        </member>
+    </members>
+</doc>

src/YSAI.DAQ/YSAI.Modbus/YSAI.Modbus.csproj

@@ -5,7 +5,7 @@
     <ImplicitUsings>enable</ImplicitUsings>
     <Nullable>enable</Nullable>
 	  <GeneratePackageOnBuild>True</GeneratePackageOnBuild>
-	  <Version>1.0.0.1</Version>
+	  <Version>1.0.0.2</Version>
 	  <Authors>Shun</Authors>
 	  <Company>YSAI</Company>
 	  <Product>SCADA</Product>
@@ -13,7 +13,7 @@
   </PropertyGroup>
 
 	<ItemGroup>
-    <PackageReference Include="YSAI.Core" Version="1.0.0.17" />
+    <PackageReference Include="YSAI.Core" Version="1.0.0.18" />
   </ItemGroup>
 
 	<!--<ItemGroup>

src/YSAI.DAQ/YSAI.Mqtt/YSAI.Mqtt.csproj

@@ -5,7 +5,7 @@
     <ImplicitUsings>enable</ImplicitUsings>
     <Nullable>enable</Nullable>
 	  <GeneratePackageOnBuild>True</GeneratePackageOnBuild>
-	  <Version>1.0.0.1</Version>
+	  <Version>1.0.0.2</Version>
 	  <Authors>Shun</Authors>
 	  <Company>YSAI</Company>
 	  <Product>SCADA</Product>
@@ -15,7 +15,7 @@
   <ItemGroup>
     <PackageReference Include="MQTTnet" Version="4.3.1.873" />
     <PackageReference Include="MQTTnet.AspNetCore" Version="4.3.1.873" />
-    <PackageReference Include="YSAI.Core" Version="1.0.0.17" />
+    <PackageReference Include="YSAI.Core" Version="1.0.0.18" />
   </ItemGroup>
 
 	<!--<ItemGroup>

src/YSAI.DAQ/YSAI.Opc/YSAI.Opc.csproj

@@ -5,7 +5,7 @@
     <ImplicitUsings>enable</ImplicitUsings>
     <Nullable>enable</Nullable>
 	  <GeneratePackageOnBuild>True</GeneratePackageOnBuild>
-	  <Version>1.0.0.1</Version>
+	  <Version>1.0.0.2</Version>
 	  <Authors>Shun</Authors>
 	  <Company>YSAI</Company>
 	  <Product>SCADA</Product>
@@ -27,7 +27,7 @@
   </ItemGroup>
   <ItemGroup>
     <PackageReference Include="OPCFoundation.NetStandard.Opc.Ua" Version="1.4.372.56" />
-	<PackageReference Include="YSAI.Core" Version="1.0.0.17" />
+	<PackageReference Include="YSAI.Core" Version="1.0.0.18" />
   </ItemGroup>
 
 

src/YSAI.DAQ/YSAI.RabbitMQ/YSAI.RabbitMQ.csproj

@@ -5,7 +5,7 @@
     <ImplicitUsings>enable</ImplicitUsings>
     <Nullable>enable</Nullable>
 	  <GeneratePackageOnBuild>True</GeneratePackageOnBuild>
-	  <Version>1.0.0.1</Version>
+	  <Version>1.0.0.2</Version>
 	  <Authors>Shun</Authors>
 	  <Company>YSAI</Company>
 	  <Product>SCADA</Product>
@@ -14,7 +14,7 @@
 
   <ItemGroup>
     <PackageReference Include="RabbitMQ.Client" Version="6.5.0" />
-    <PackageReference Include="YSAI.Core" Version="1.0.0.17" />
+    <PackageReference Include="YSAI.Core" Version="1.0.0.18" />
   </ItemGroup>
 	<!--<ItemGroup>
 		<ProjectReference Include="..\YSAI.Core\YSAI.Core.csproj" />

src/YSAI.DAQ/YSAI.RelayManage/YSAI.RelayManage.csproj

@@ -10,7 +10,7 @@
 		<PackageReference Include="RabbitMQ.Client" Version="6.5.0" />
 		<PackageReference Include="Confluent.Kafka" Version="2.2.0" />
 		<PackageReference Include="Microsoft.AspNetCore.Http.Features" Version="5.0.17" />
-		<PackageReference Include="YSAI.Core" Version="1.0.0.17" />
+		<PackageReference Include="YSAI.Core" Version="1.0.0.18" />
 	</ItemGroup>
 
 	<!--<ItemGroup>

src/YSAI.DAQ/YSAI.S7/YSAI.S7.csproj

@@ -5,7 +5,7 @@
     <ImplicitUsings>enable</ImplicitUsings>
     <Nullable>enable</Nullable>
 	  <GeneratePackageOnBuild>True</GeneratePackageOnBuild>
-	  <Version>1.0.0.1</Version>
+	  <Version>1.0.0.2</Version>
 	  <Authors>Shun</Authors>
 	  <Company>YSAI</Company>
 	  <Product>SCADA</Product>
@@ -13,7 +13,7 @@
   </PropertyGroup>
 
 	<ItemGroup>
-    <PackageReference Include="YSAI.Core" Version="1.0.0.17" />
+    <PackageReference Include="YSAI.Core" Version="1.0.0.18" />
   </ItemGroup>
 
 	<!--<ItemGroup>

src/YSAI.DAQ/YSAI.Test.Console/Program.cs

@@ -2,11 +2,13 @@
 using S7.Net;
 using System.Collections.Concurrent;
 using System.Collections.Generic;
+using System.Text;
 using YSAI.Core.data;
 using YSAI.Core.@enum;
 using YSAI.Core.reflection;
 using YSAI.Core.script;
 using YSAI.DaqManage;
+using YSAI.DB;
 using YSAI.Kafka;
 using YSAI.Log;
 using YSAI.Modbus.client;
@@ -19,84 +21,145 @@ using YSAI.S7.client;
 using YSAI.Unility;
 using ZstdSharp.Unsafe;
 
+string StartBit = "2D 2D 2D 2D 2D 2D 2D 2D 2D 2D 2D 2D 2D 2D 2D 2D 2D 2D 2D 2D 2D 2D 2D 2D 2D 2D 2D 2D 2D 2D 2D 2D 2D 2D 2D 2D 2D 2D 2D 2D 0A 41 62 62 65 6D 61 74 20";
 
-//点位地址
-Address address = new Address();
-address.SN = Guid.NewGuid().ToString();
-address.CreationTime = DateTime.Now.ToLocalTime();
-address.AddressArray = new List<AddressDetails>();
-address.AddressArray.Add(new AddressDetails()
-{
-    AddressName = "0,2",
-    AddressDataType = YSAI.Core.@enum.DataType.Double,
-    AddressType = AddressType.Reality,
-    AddressDescribe = "上一次的湿度"
-});
-address.AddressArray.Add(new AddressDetails()
-{
-    AddressName = "2,2",
-    AddressDataType = YSAI.Core.@enum.DataType.Double,
-    AddressType = AddressType.Reality,
-    AddressDescribe = "上一次的密度"
-});
-address.AddressArray.Add(new AddressDetails()
-{
-    AddressName = "4,2",
-    AddressDataType = YSAI.Core.@enum.DataType.Double,
-    AddressType = AddressType.Reality,
-    AddressDescribe = "上一次的温度"
-});
-address.AddressArray.Add(new AddressDetails()
-{
-    AddressName = "6,2",
-    AddressDataType = YSAI.Core.@enum.DataType.Double,
-    AddressType = AddressType.Reality,
-    AddressDescribe = "实时湿度"
-});
-address.AddressArray.Add(new AddressDetails()
-{
-    AddressName = "8,2",
-    AddressDataType = YSAI.Core.@enum.DataType.Double,
-    AddressType = AddressType.Reality,
-    AddressDescribe = "实时密度"
-});
-address.AddressArray.Add(new AddressDetails()
-{
-    AddressName = "10,2",
-    AddressDataType = YSAI.Core.@enum.DataType.Double,
-    AddressType = AddressType.Reality,
-    AddressDescribe = "实时温度"
-});
-ModbusClientOperate modbusClientOperate = ModbusClientOperate.Instance(new ModbusClientData.Basics
-{
-    ProtocolType = ModbusClientData.ProtocolType.Tcp,
-    Ip = "192.168.150.182",
-    Port = 502,
-    MRType = ModbusClientData.ModbusReadType.FloatInputRegisters,
-    MWType = ModbusClientData.ModbusWriteType.NULL
-});
-
-OperateResult operateResult = modbusClientOperate.On();
-Console.WriteLine(operateResult.ToJson());
-
-
-operateResult = modbusClientOperate.Read(address);
-Console.WriteLine(operateResult.ToJson());
+string EndBit = "20 0A 20 0A 20 0A 20 0A 53 69 67 6E 61 74 75 72 65 3A 2E 2E 2E 2E 2E 2E 2E 2E 2E 2E 2E 2E 2E 2E 2E 2E 2E 2E 2E 2E 2E 2E 2E 2E 2E 2E 2E 2E 2E 2E 2E 0A 20 0A 20 0A";
 
-//modbusClientOperate.OnEvent += ModbusClientOperate_OnEvent;
+string info= Encoding.Default.GetString(ByteTool.HexStringToBinary(EndBit));
 
-//operateResult = modbusClientOperate.Subscribe(address);
+Console.WriteLine(info);
+
+
+
+////数据库操作
+//DBOperate dBOperate = DBOperate.Instance(new DBData.Basics 
+//{
+//    SN = Guid.NewGuid().ToString(),
+//    ConnectStr = "server=192.168.150.95;port=3306;user=root;password=admin; database=mts2015;",
+//    DBType=DBData.DBType.MySql,
+//});
+//dBOperate.OnEvent += DBOperate_OnEvent;
+
+////扩展参数
+//DBData.ExtendParam.Read extend = new DBData.ExtendParam.Read()
+//{
+//    Sql = "select a,b,c,d from table",
+//    ColumnName=new List<string>
+//    {
+//        "a","b","c","d"
+//    }
+//};
+////地址参数
+//Address address = new Address() 
+//{
+//    SN= Guid.NewGuid().ToString(),
+//    AddressArray=new List<AddressDetails>
+//    {
+//        new AddressDetails
+//        {
+//            SN="数据库一号采集",
+//            AddressName="DBDAQ",
+//            AddressDescribe="数据库采集",
+//            AddressExtendParam = extend,
+//        }
+//    }
+//};
+
+////执行订阅
+//OperateResult operateResult = dBOperate.Subscribe(address);
+////判断返回结果
+
+
+////实现响应
+//void DBOperate_OnEvent(object? sender, EventResult e)
+//{
+//    //判断返回结果
+//}
+
+
+
+
+//LogHelper.Debug("666666666666666");
+
+//Console.WriteLine();
+
+////点位地址
+//Address address = new Address();
+//address.SN = Guid.NewGuid().ToString();
+//address.CreationTime = DateTime.Now.ToLocalTime();
+//address.AddressArray = new List<AddressDetails>();
+//address.AddressArray.Add(new AddressDetails()
+//{
+//    AddressName = "0,2",
+//    AddressDataType = YSAI.Core.@enum.DataType.Double,
+//    AddressType = AddressType.Reality,
+//    AddressDescribe = "上一次的湿度"
+//});
+//address.AddressArray.Add(new AddressDetails()
+//{
+//    AddressName = "2,2",
+//    AddressDataType = YSAI.Core.@enum.DataType.Double,
+//    AddressType = AddressType.Reality,
+//    AddressDescribe = "上一次的密度"
+//});
+//address.AddressArray.Add(new AddressDetails()
+//{
+//    AddressName = "4,2",
+//    AddressDataType = YSAI.Core.@enum.DataType.Double,
+//    AddressType = AddressType.Reality,
+//    AddressDescribe = "上一次的温度"
+//});
+//address.AddressArray.Add(new AddressDetails()
+//{
+//    AddressName = "6,2",
+//    AddressDataType = YSAI.Core.@enum.DataType.Double,
+//    AddressType = AddressType.Reality,
+//    AddressDescribe = "实时湿度"
+//});
+//address.AddressArray.Add(new AddressDetails()
+//{
+//    AddressName = "8,2",
+//    AddressDataType = YSAI.Core.@enum.DataType.Double,
+//    AddressType = AddressType.Reality,
+//    AddressDescribe = "实时密度"
+//});
+//address.AddressArray.Add(new AddressDetails()
+//{
+//    AddressName = "10,2",
+//    AddressDataType = YSAI.Core.@enum.DataType.Double,
+//    AddressType = AddressType.Reality,
+//    AddressDescribe = "实时温度"
+//});
+//ModbusClientOperate modbusClientOperate = ModbusClientOperate.Instance(new ModbusClientData.Basics
+//{
+//    ProtocolType = ModbusClientData.ProtocolType.Tcp,
+//    Ip = "192.168.150.182",
+//    Port = 502,
+//    MRType = ModbusClientData.ModbusReadType.FloatInputRegisters,
+//    MWType = ModbusClientData.ModbusWriteType.NULL
+//});
+
+//OperateResult operateResult = modbusClientOperate.On();
+//Console.WriteLine(operateResult.ToJson());
+
+
+//operateResult = modbusClientOperate.Read(address);
 //Console.WriteLine(operateResult.ToJson());
 
-while (true)
-{
+////modbusClientOperate.OnEvent += ModbusClientOperate_OnEvent;
 
-}
+////operateResult = modbusClientOperate.Subscribe(address);
+////Console.WriteLine(operateResult.ToJson());
 
-void ModbusClientOperate_OnEvent(object? sender, EventResult e)
-{
-    Console.WriteLine(e.ToJson().JsonFormatting());
-}
+//while (true)
+//{
+
+//}
+
+//void ModbusClientOperate_OnEvent(object? sender, EventResult e)
+//{
+//    Console.WriteLine(e.ToJson().JsonFormatting());
+//}
 
 
 ////点位地址

src/YSAI.DAQ/YSAI.Test/YSAI.Test.csproj

@@ -17,7 +17,7 @@
       <PrivateAssets>all</PrivateAssets>
       <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
     </PackageReference>
-	<PackageReference Include="YSAI.Core" Version="1.0.0.17" />
+	<PackageReference Include="YSAI.Core" Version="1.0.0.18" />
   </ItemGroup>
 
   <ItemGroup>