C#中RabbitMQ應(yīng)用的示例分析

這篇文章將為大家詳細(xì)講解有關(guān)C#中RabbitMQ應(yīng)用的示例分析，小編覺得挺實(shí)用的，因此分享給大家做個(gè)參考，希望大家閱讀完這篇文章后可以有所收獲。

發(fā)送端：

            ConnectionFactory factory = new ConnectionFactory { HostName = "hostname", UserName = "root", Password = "root001", VirtualHost = "hostserver" }; 
                       using (IConnection conn = factory.CreateConnection())
            {                using (IModel im = conn.CreateModel())
                {
                    im.ExchangeDeclare("rabbitmq_route", ExchangeType.Direct);
                    im.QueueDeclare("rabbitmq_query", false, false, false, null);
                    im.QueueBind("rabbitmq_query", "rabbitmq_route", ExchangeType.Direct, null);                    
                    for (int i = 0; i < 1000; i++)
                    {                        byte[] message = Encoding.UTF8.GetBytes("Hello Lv");
                        im.BasicPublish("rabbitmq_route", ExchangeType.Direct, null, message);
                        Console.WriteLine("send:" + i);
                    }
                }
            }

接收端：

            ConnectionFactory factory = new ConnectionFactory { HostName = "hostname", UserName = "root", Password = "root001", VirtualHost = "hostserver" }; 
                       using (IConnection conn = factory.CreateConnection())
            {                using (IModel im = conn.CreateModel())
                {                    while (true)
                    {
                        BasicGetResult res = im.BasicGet("rabbitmq_query", true);                        
                        if (res != null)
                        {
                            Console.WriteLine("receiver:"+UTF8Encoding.UTF8.GetString(res.Body));
                        }
                    }
                }
            }

發(fā)送端一次性發(fā)送一千條，發(fā)送過程很快，接收時(shí)相對(duì)要慢一些。

上述DEMO只限一個(gè)接收著，那相同的發(fā)送量，多個(gè)接收者會(huì)出現(xiàn)什么情況，添加一個(gè)新的接收端，直接復(fù)制DEMO中接收端即可。

附上運(yùn)行結(jié)果：

可以看到，在兩個(gè)接收端同時(shí)運(yùn)行時(shí)，RabbitMQ 會(huì)按順序的分發(fā)每個(gè)消息。當(dāng)每個(gè)收到確認(rèn)后，會(huì)將該消息刪除，然后將下一個(gè)分發(fā)到下一個(gè)接收者，主要是因?yàn)镽abbitMQ的循環(huán)分發(fā)機(jī)制。

上面簡單說了一下，在多個(gè)接收者時(shí)，因?yàn)檠h(huán)分發(fā)的原因，消息幾乎是兩個(gè)接收端對(duì)分的。

那么如何將相同的消息分發(fā)到多個(gè)接收端。

對(duì)發(fā)送端代碼進(jìn)行修改:

            ConnectionFactory factory = new ConnectionFactory { HostName = "hostname", UserName = "root", Password = "root001", VirtualHost = "host" }; 
                       using (IConnection conn = factory.CreateConnection())
            {                using (IModel im = conn.CreateModel())
                {
                    im.ExchangeDeclare("rabbitmq_route_Fanout", ExchangeType.Fanout);// 路由                    
                    int i = 0;                    
                    while (true)
                    {
                        Thread.Sleep(1000);
                        ++i;                        
                        byte[] message = Encoding.UTF8.GetBytes(i.ToString());
                        im.BasicPublish("rabbitmq_route_Fanout", "", null, message);
                        Console.WriteLine("send:" + i.ToString());
                    }
                }
            }

與上種方式比較，會(huì)發(fā)現(xiàn)在代碼注釋后面少兩段代碼，在設(shè)置了Fanout方式后，不需要再指定隊(duì)列名稱。停一秒是為了方便看結(jié)果，以免刷新太快。

再來看看接收端代碼：

            ConnectionFactory factory = new ConnectionFactory { HostName = "hostname", UserName = "root", Password = "root001", VirtualHost = "host" };  
                      using (IConnection conn = factory.CreateConnection())
            {                using (IModel im = conn.CreateModel())
                {
                    im.ExchangeDeclare("rabbitmq_route_Fanout", ExchangeType.Fanout);                    
                    var queueOk = im.QueueDeclare();//1
                    im.QueueBind(queueOk.QueueName, "rabbitmq_route_Fanout", "");//2                    
                    var consumer = new QueueingBasicConsumer(im);//3
                    im.BasicConsume(queueOk.QueueName, true, consumer);//4                    
                    while (true)
                    {var _result = (BasicDeliverEventArgs)consumer.Queue.Dequeue();//5                        
                    var body = _result.Body;                        
                    var message = Encoding.UTF8.GetString(body);
                        Console.WriteLine("received:{0}", message);
                    }
                }

當(dāng)一個(gè)新的接收端連接時(shí)（消費(fèi)者），需要一個(gè)申報(bào)一個(gè)新的隊(duì)列，注釋1處代碼，RabbitMQ在申報(bào)隊(duì)列時(shí)，如果不指定名稱會(huì)自動(dòng)生成一個(gè)，這還是不錯(cuò)的。

兩個(gè)接收端時(shí)運(yùn)行結(jié)果，符合預(yù)期。

關(guān)于“C#中RabbitMQ應(yīng)用的示例分析”這篇文章就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，使各位可以學(xué)到更多知識(shí)，如果覺得文章不錯(cuò)，請(qǐng)把它分享出去讓更多的人看到。