1

src/YSAI.DAQ/YSAI.RabbitMQ/RabbitMQOperate.cs

@@ -294,12 +294,13 @@ namespace YSAI.RabbitMQ
             dynamic DynamicObj = new ExpandoObject();
             DynamicObj.Content = Encoding.UTF8.GetString(e.Body.ToArray());
             DynamicObj.Topic = e.RoutingKey;
-            OnEventHandler?.Invoke(this, new EventResult(true, DynamicObj.ToJson(), DynamicObj, Core.@enum.ResultType.Dynamic));
+            //Console.WriteLine((DynamicObj as object).ToJson());
             if (!AutoAck)
             {
                 //当自动确认为false，得手动确认消息
-                Channels[e.RoutingKey].BasicAck(e.DeliveryTag, false);
+                Channels[e.Exchange].BasicAck(e.DeliveryTag, false);
             }
+            OnEventHandler?.Invoke(this, new EventResult(true, $"消费成功，{(AutoAck ? "已自动确认" : "已手动确认")}", DynamicObj, Core.@enum.ResultType.Dynamic));
         }
         public Task<OperateResult> OnAsync()
         {

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

@@ -16,13 +16,36 @@ using YSAI.S7.client;
 using YSAI.Unility;
 
 
-MqttWebSocketServiceOperate mqttWebSocketServiceOperate = MqttWebSocketServiceOperate.Instance(new MqttWebSocketServiceData.Basics() 
+RabbitMQOperate rabbitMQOperate = RabbitMQOperate.Instance(new RabbitMQData.Basics()
 {
-    HttpPort=11886,
-    Port=1188,
-    
+    ExChangeName = "VariableExchangeRead",
+    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("VariableTopic");
+Console.WriteLine(operateResult.ToJson());
+
+while (true)
+{
+
+}
+void RabbitMQOperate_OnEvent(object? sender, EventResult e)
+{
+    Console.WriteLine(e.ToJson()) ;
+}
+
+
 
 //MqttClientOperate mqttClientOperate = MqttClientOperate.Instance(new MqttClientData.Basics()
 //{