1

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

@@ -20,6 +20,7 @@
 		<PackageReference Include="Microsoft.ClearScript" Version="7.4.3" />
 		<PackageReference Include="StackExchange.Redis" Version="2.6.122" />
 		<PackageReference Include="System.IO.Ports" Version="7.0.0" />
+		<PackageReference Include="System.Memory" Version="4.5.5" />
 		<PackageReference Include="YSAI.Log" Version="1.0.0.4" />
 		<PackageReference Include="YSAI.Unility" Version="1.0.0.4" />
 	</ItemGroup>

src/YSAI.DAQ/YSAI.Manage/param/YSAI.RabbitMQ.Param.json

@@ -1,5 +1,5 @@
 {
-    "SN": "2a943d02-ff08-427b-a2f2-c31125ad140d",
+    "SN": "f676e415-5e04-4d66-9cd2-9cf3d8a0217b",
     "ExChangeName": null,
     "HostName": null,
     "Port": 0,

src/YSAI.DAQ/YSAI.RabbitMQ/Properties/PublishProfiles/FolderProfile.pubxml

@@ -0,0 +1,13 @@
+<?xml version="1.0" encoding="utf-8"?>
+<!--
+https://go.microsoft.com/fwlink/?LinkID=208121.
+-->
+<Project>
+  <PropertyGroup>
+    <Configuration>Release</Configuration>
+    <Platform>Any CPU</Platform>
+    <PublishDir>bin\Release\net6.0\publish\</PublishDir>
+    <PublishProtocol>FileSystem</PublishProtocol>
+    <_TargetId>Folder</_TargetId>
+  </PropertyGroup>
+</Project>

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

@@ -7,37 +7,59 @@ using YSAI.DaqManage;
 using YSAI.Mqtt.client;
 using YSAI.Mqtt.service.websocket;
 using YSAI.Opc.ua.client;
+using YSAI.RabbitMQ;
 using YSAI.RelayManage;
 using YSAI.Unility;
 
 
-OpcUaClientData.Basics opcUaClientData1 = new OpcUaClientData.Basics() 
+RabbitMQData.Basics s= new RabbitMQData.Basics()
 {
-    Name="ys",
-    Password= "ys123456",
-    ServerUrl= "opc.tcp://192.168.2.200:49310/Opc.Ua.Service",
-    SN="OPCUA1",
-    UserName="ysai"
+    ExChangeName = "test",
+    HostName = "192.168.2.200",
+    Password = "ys123456",
+    UserName = "ys",
+    Port = 5672,
+    SN = "RMQ1"
 };
 
-OpcUaClientOperate opcUaClientOperate = OpcUaClientOperate.Instance(opcUaClientData1);
+FileTool.StringToFile("RMQ1.json", s.ToJson().JsonFormatting());
+RabbitMQOperate rabbitMQOperate =new RabbitMQOperate(s) ;
 
-OperateResult operateResult = opcUaClientOperate.On();
+
+
+OperateResult operateResult = await rabbitMQOperate.OnAsync();
+
+operateResult = rabbitMQOperate.Produce("a","666");
 
 Console.WriteLine();
 
-OpcUaClientData.Basics opcUaClientData2 = new OpcUaClientData.Basics()
-{
-    Name = "ysai",
-    Password = "ysai",
-    ServerUrl = "opc.tcp://192.168.2.200:49310/Opc.Ua.Service",
-    SN = "OPCUA2",
-    UserName = "ysai"
-};
+//OpcUaClientData.Basics opcUaClientData1 = new OpcUaClientData.Basics() 
+//{
+//    Name="ys",
+//    Password= "ys123456",
+//    ServerUrl= "opc.tcp://192.168.2.200:49310/Opc.Ua.Service",
+//    SN="OPCUA1",
+//    UserName="ysai"
+//};
+
+//OpcUaClientOperate opcUaClientOperate = OpcUaClientOperate.Instance(opcUaClientData1);
+
+//OperateResult operateResult = opcUaClientOperate.On();
+
+//Console.WriteLine();
+
+//OpcUaClientData.Basics opcUaClientData2 = new OpcUaClientData.Basics()
+//{
+//    Name = "ysai",
+//    Password = "ysai",
+//    ServerUrl = "opc.tcp://192.168.2.200:49310/Opc.Ua.Service",
+//    SN = "OPCUA2",
+//    UserName = "ysai"
+//};
 
-opcUaClientOperate = OpcUaClientOperate.Instance(opcUaClientData2);
+//opcUaClientOperate = OpcUaClientOperate.Instance(opcUaClientData2);
 
-operateResult = opcUaClientOperate.On();
+//operateResult = opcUaClientOperate.On();
 
 
 //FileTool.StringToFile("config/YSAI.Opc.ua.client.OpcUaClientReadController.OPCUA1.Daq.Config.json", opcUaClientData.ToJson().JsonFormatting());