通过MQ接收SP原始数据，已正常

Common/RabbitMQClient.cs

@@ -26,14 +26,30 @@ namespace Common
         public static IConnection _connection;
         public void CreateConn()
         { 
+            // var factory = new ConnectionFactory()
+            // {
+            //     HostName = HostName,
+            //     UserName = UserName,
+            //     Password = Password,
+            //     VirtualHost = VirtualHostName
+            // };
+            // _connection = factory.CreateConnection();
             var factory = new ConnectionFactory()
             {
-                HostName = HostName,
                 UserName = UserName,
                 Password = Password,
-                VirtualHost = VirtualHostName
+                AutomaticRecoveryEnabled = true,  //如果connection挂掉是否重新连接
+                TopologyRecoveryEnabled = true,  //连接恢复后，连接的交换机，队列等是否一同恢复
+                VirtualHost = VirtualHostName,
             };
-            _connection = factory.CreateConnection();
+            List<AmqpTcpEndpoint> p = new List<AmqpTcpEndpoint>();
+            string[] HostNames = HostName.Split(',');
+            foreach (string subHostName in HostNames)
+            {
+                string[] subHostNameData = subHostName.Split(':');
+                p.Add(new AmqpTcpEndpoint(subHostNameData[0], int.Parse(subHostNameData[1])));
+            }
+            _connection = factory.CreateConnection(p);
         }
 
         #region 单对单接收

Task/SpDataHelper.cs

@@ -9,7 +9,6 @@ using Services;
 using Model;
 using LitJson;
 
-//营业额日汇总统计
 public class SpDataHelper
 {
     public readonly static SpDataHelper Instance = new SpDataHelper();

appsettings.Development.json

@@ -43,7 +43,7 @@
   "RabbitMqConfigs": {
     "UserName": "admin",
     "Password": "admin",
-    "HostName": "",
+    "HostName": "47.109.61.191:5672",
     "VirtualHostName": "/"
   },
   "InitDb": false, //是否初始化db

appsettings.json

@@ -40,6 +40,12 @@
     "RefreshTokenTime": 30, //分钟
     "TokenType": "Bearer"
   },
+  "RabbitMqConfigs": {
+    "UserName": "MjpyYWJiaXRtcS1zZXJ2ZXJsZXNzLWNuLW80OTNwdms0dTA1OkxUQUk1dEZVMzU2c01HdFNSa0dHbkRRUQ==",
+    "Password": "OEE5OTZDMzg5OUFBNEY5QUNCNTQ3MTFDMkNFQkNFRTA1NUNCNjk1QToxNzE0MzY4OTQwMjY3",
+    "HostName": "rabbitmq-serverless-cn-o493pvk4u05.cn-chengdu.amqp-0.vpc.mq.amqp.aliyuncs.com:5672",
+    "VirtualHostName": "kxs-rabbitmq-vhost-1"
+  },
   "InitDb": false, //是否初始化db
   "ApiKey": "*ga34|^7" //webapi解密的key
-}
+}