开启生成队列

Common/RabbitMQClient.cs

@@ -28,12 +28,19 @@ namespace Common
         { 
             var factory = new ConnectionFactory()
             {
-                HostName = HostName,
+                // HostName = HostName,
                 UserName = UserName,
                 Password = Password,
                 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 单对单接收

Program.cs

@@ -129,7 +129,7 @@ app.Urls.Add("http://*:8005");
 
 ModelVoAdapt.Map(); //模型字段类型映射配置
 
-// RabbitMQClient.Instance.Conn("MakeQueue");
+RabbitMQClient.Instance.Conn("MakeQueue");
 // MakeHelper.Instance.Start("MakeCallBackQueue");
 
 // CopyData.CopyOldData();