|
|
@@ -1,42 +1,38 @@
|
|
|
|
|
|
|
|
|
-Console.WriteLine();
|
|
|
-//using System.Runtime.InteropServices;
|
|
|
-//using YSAI.Core.data;
|
|
|
-//using YSAI.RabbitMQ;
|
|
|
-//using YSAI.Unility;
|
|
|
-
|
|
|
-
|
|
|
-//RabbitMQOperate rabbitMQOperate = RabbitMQOperate.Instance(new RabbitMQData.Basics()
|
|
|
-//{
|
|
|
-// ExChangeName = "exchang200",
|
|
|
-// HostName = "192.168.2.200",
|
|
|
-// UserName = "ys",
|
|
|
-// Password = "ys123456",
|
|
|
-// Port = 5672,
|
|
|
-// SN = Guid.NewGuid().ToString()
|
|
|
-//});
|
|
|
-
|
|
|
-//OperateResult operateResult = rabbitMQOperate.On();
|
|
|
-//Console.WriteLine(operateResult.ToJson());
|
|
|
-
|
|
|
-
|
|
|
-//rabbitMQOperate.OnEvent += RabbitMQOperate_OnEvent;
|
|
|
-//operateResult = rabbitMQOperate.Consume("test");
|
|
|
-//Console.WriteLine(operateResult.ToJson());
|
|
|
-
|
|
|
-//while (true)
|
|
|
-//{
|
|
|
-// operateResult = rabbitMQOperate.Produce("test", $"{new Random().NextDouble()}");
|
|
|
-//}
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-//void RabbitMQOperate_OnEvent(object? sender, EventResult e)
|
|
|
-//{
|
|
|
-// //Console.WriteLine(e.ToJson());
|
|
|
-//}
|
|
|
+using System.Runtime.InteropServices;
|
|
|
+using YSAI.Core.data;
|
|
|
+using YSAI.RabbitMQ;
|
|
|
+using YSAI.Unility;
|
|
|
+
|
|
|
+
|
|
|
+RabbitMQOperate rabbitMQOperate = RabbitMQOperate.Instance(new RabbitMQData.Basics()
|
|
|
+{
|
|
|
+ ExChangeName = "exchang200",
|
|
|
+ HostName = "192.168.2.200",
|
|
|
+ UserName = "ys",
|
|
|
+ Password = "ys123456",
|
|
|
+ Port = 5672,
|
|
|
+ SN = Guid.NewGuid().ToString()
|
|
|
+});
|
|
|
+
|
|
|
+OperateResult operateResult = rabbitMQOperate.On();
|
|
|
+Console.WriteLine(operateResult.ToJson());
|
|
|
+
|
|
|
+
|
|
|
+rabbitMQOperate.OnEvent += RabbitMQOperate_OnEvent;
|
|
|
+operateResult = rabbitMQOperate.Consume("test");
|
|
|
+Console.WriteLine(operateResult.ToJson());
|
|
|
+
|
|
|
+while (true)
|
|
|
+{
|
|
|
+ operateResult = rabbitMQOperate.Produce("test", $"{new Random().NextDouble()}");
|
|
|
+}
|
|
|
+
|
|
|
+void RabbitMQOperate_OnEvent(object? sender, EventResult e)
|
|
|
+{
|
|
|
+ //Console.WriteLine(e.ToJson());
|
|
|
+}
|
|
|
|
|
|
|
|
|
//using YSAI.Core.data;
|