更新

src/YSAI.Test.All/Program.cs

@@ -4,6 +4,7 @@ using YSAI.Core.script;
 using YSAI.Log;
 using YSAI.Model.data;
 using YSAI.Model.@enum;
+using YSAI.Mqtt.service;
 using YSAI.Opc.ua.client;
 using YSAI.Unility;
 
@@ -28,21 +29,21 @@ List<string> ReadCsv(string path, bool hasTitle)
 
 //启动两个服务端
 
-//Console.WriteLine(MqttServiceOperate.Instance(new MqttServiceData.Basics
-//{
-//    MaxNumber = 1000,
-//    Password = "ysai",
-//    UserName = "ysai",
-//    Port = 8881
-//}).On().ToJson().JsonFormatting());
+Console.WriteLine(MqttServiceOperate.Instance(new MqttServiceData.Basics
+{
+    MaxNumber = 1000,
+    Password = "ysai",
+    UserName = "ysai",
+    Port = 8881
+}).On().ToJson().JsonFormatting());
 
-//Console.WriteLine(MqttServiceOperate.Instance(new MqttServiceData.Basics
-//{
-//    MaxNumber = 1000,
-//    Password = "ysai",
-//    UserName = "ysai",
-//    Port = 8882
-//}).On().ToJson().JsonFormatting());
+Console.WriteLine(MqttServiceOperate.Instance(new MqttServiceData.Basics
+{
+    MaxNumber = 1000,
+    Password = "ysai",
+    UserName = "ysai",
+    Port = 8882
+}).On().ToJson().JsonFormatting());
 
 
 
@@ -168,9 +169,7 @@ OpcUaClientOperate opcUaClientOperate = OpcUaClientOperate.Instance(new OpcUaCli
 {
     ServerUrl = "opc.tcp://192.168.2.220:49320",
     CustomName = "YSAI 性能测试",
-    TaskNumber = 1,
-    TaskHandleInterval = 1000,
-    SubscribeSingleGroupMaxCount = 0,
+    SubscribeSingleGroupMaxCount = 1000,
 });
 Console.WriteLine(opcUaClientOperate.On().ToJson().JsonFormatting());
 opcUaClientOperate.OnEvent += OpcUaClientOperate_OnEvent;

src/YSAI.Test.All/YSAI.Test.All.csproj

@@ -9,6 +9,7 @@
   </PropertyGroup>
 
   <ItemGroup>
+    <ProjectReference Include="..\YSAI.Mqtt\YSAI.Mqtt.csproj" />
     <ProjectReference Include="..\YSAI.Opc\YSAI.Opc.csproj" />
   </ItemGroup>