/// <summary>/// RabbitMQ/// </summary>class Program{static void Main(string[] args){string type = Console.ReadLine();//生产者if (type=="1"){ConnectionFactory factory = new ConnectionFactory();factory.HostName = "127.0.0.1";//默认端口factory.Port = 5672;using (IConnection conn = factory.CreateConnection()){using (IModel channel = conn.CreateModel()){//在MQ上定义一个持久化队列，如果名称相同不会重复创建channel.QueueDeclare("MyRabbitMQ", true, false, false, null);while (true){string message = string.Format("Message_{0}", Console.ReadLine());byte[] buffer = Encoding.UTF8.GetBytes(message);IBasicProperties properties = channel.CreateBasicProperties();properties.DeliveryMode = 2;channel.BasicPublish("", "MyRabbitMQ", properties, buffer);Console.WriteLine("消息发送成功：" + message);}}}}else{//消费者ConnectionFactory factory = new ConnectionFactory();factory.HostName = "127.0.0.1";//默认端口factory.Port = 5672;using (IConnection conn = factory.CreateConnection()){using (IModel channel = conn.CreateModel()){//在MQ上定义一个持久化队列，如果名称相同不会重复创建channel.QueueDeclare("MyRabbitMQ", true, false, false, null);//输入1，那如果接收一个消息，但是没有应答，则客户端不会收到下一个消息channel.BasicQos(0, 1, false);Console.WriteLine("Listening...");//在队列上定义一个消费者QueueingBasicConsumer consumer = new QueueingBasicConsumer(channel);//消费队列，并设置应答模式为程序主动应答channel.BasicConsume("MyRabbitMQ", false, consumer);while (true){//阻塞函数，获取队列中的消息BasicDeliverEventArgs ea = (BasicDeliverEventArgs)consumer.Queue.Dequeue();byte[] bytes = ea.Body;string str = Encoding.UTF8.GetString(bytes);Console.WriteLine("队列消息:" + str.ToString());//回复确认channel.BasicAck(ea.DeliveryTag, false);}}}}}}