基本信息

---

下载

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

---

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

本次赞助数额为： 2 元　

支付宝支付

微信支付

   源码介绍

---

负载均衡

首先需要下载.net下的驱动类。rabbitmq.client.dll.安装后可以使用提供的文档。当然也可以直接从别的地方只下载rabbitmq.client.dll使用。
下载地址：http://www.rabbitmq.com/dotnet.html

static void Main(string[] args)
        {
            string exchange = "XJ.RabbitMQ.Exchange_Test";      //路由
            string exchangeType = "fanout";     //交换模式
            string routeKey = "XJ.RabbitMQ.RouteKey_Test";      //路由键
            string serverAddress = "amqp://127.0.0.1:5672/";

            ConnectionFactory cf = new ConnectionFactory();
            cf.Uri = serverAddress;
            cf.UserName = "admin";
            cf.Password = "admin";
            cf.VirtualHost = "/";
            cf.RequestedHeartbeat = 0;
            using (IConnection conn = cf.CreateConnection())
            {
                using (IModel channel = conn.CreateModel())
                {
                    //普通使用方式BasicGet  
                    //noAck = true，不需要回复，接收到消息后，queue上的消息就会清除  
                    //noAck = false，需要回复，接收到消息后，queue上的消息不会被清除，  
                    //直到调用channel.basicAck(deliveryTag, false);   
                    //queue上的消息才会被清除 而且，在当前连接断开以前，其它客户端将不能收到此queue上的消息  
                    while (true)
                    {
                        BasicGetResult result = channel.BasicGet("XJ.RabbitMQ.Queue_Test", false); //需要手动回复状态
                        if (result != null)
                        {
                            Console.WriteLine("接收到一条数据：" System.Text.Encoding.UTF8.GetString(result.Body));
                            Thread.Sleep(2000);
                            channel.BasicAck(result.DeliveryTag, false);    //回发数据
                        }
                        else
                        {
                            Console.WriteLine("无内容!!");
                            Thread.Sleep(500);
                        }
                    }
                }
            }
            Console.ReadKey();
        }