基本信息

---

下载

   友情提示：（无需注册或充值，赞助后即可获取资源下载链接）

---

     嘿，亲！知识可是无价之宝呢，但咱这精心整理的资料也耗费了不少心血呀。小小地破费一下，绝对物超所值哦！如有下载和支付问题，请联系我们QQ(微信同号)：813200300

本次赞助数额为： 2 元　

支付宝支付

微信支付

   源码介绍

---

using System;
using System.Text;
using RabbitMQ.Client;
using RabbitMQ.Client.Events;

namespace MQTest.RMQ.Consumer
{
    class Program
    {
        static void Main(string[] args)
        {
            Console.WriteLine("消费者!");

            //192.168.101.70
            //172.20.100.101
            //172.20.100.100
            //118.192.66.88
            var factory = new ConnectionFactory() { HostName = "10.3.14.81", Port = 8808 };
            factory.UserName = "123";
            factory.Password = "123456";
            using (var connection = factory.CreateConnection())
            using (var channel = connection.CreateModel())
            {
                channel.QueueDeclare(queue: "test",
                                     durable: false,
                                     exclusive: false,
                                     autoDelete: false,
                                     arguments: null);

                var consumer = new EventingBasicConsumer(channel);
                consumer.Received  = (model, ea) =>
                {
                    var body = ea.Body.ToArray();
                    var message = Encoding.UTF8.GetString(body);
                    Console.WriteLine(" [x] Received {0}", message);
                };
                channel.BasicConsume(queue: "test",
                                     autoAck: true,
                                     consumer: consumer);

                Console.WriteLine("结束!");
                Console.ReadKey();
            }





        }
    }
}