QQ讨论群：953553560

using RabbitMQ.Client; using RabbitMQ.Client.Events; using System; using System.Collections.Generic; using System.Text; using System.Threading;  namespace RabbitMQClient {     class Program     {         private static readonly ConnectionFactory rabbitMqFactory = new ConnectionFactory()         {             HostName = "39.**.**.**",             Port = 5672,             UserName = "root",             Password = "root",             VirtualHost = "/"         };         static void Main(string[] args)         {             var exchangeAll = "changeAll";             var queueman = "queueman";             var quemankey = "man.#";              using (IConnection conn = rabbitMqFactory.CreateConnection())             using (IModel channel = conn.CreateModel())             {                 channel.ExchangeDeclare(exchangeAll, type: "topic", durable: true, autoDelete: false);                 channel.QueueDeclare(queueman, durable: true, exclusive: false, autoDelete: false);                 channel.QueueBind(queueman, exchangeAll, quemankey);                  channel.BasicQos(prefetchSize: 0, prefetchCount: 50, global: false);                 EventingBasicConsumer consumer = new EventingBasicConsumer(channel);                 consumer.Received += (model, ea) =>                 {                     Byte[] body = ea.Body;                     String message = Encoding.UTF8.GetString(body);                     Console.WriteLine( message);                     channel.BasicAck(deliveryTag: ea.DeliveryTag, multiple: false);                 };                  channel.BasicConsume(queue: queueman, autoAck: false, consumer: consumer);                 Console.ReadLine();             }         }     } }