[c#]RabbitMQ的簡單使用

摘要

Message Queue消息隊列，簡稱MQ，是一種應用程式對應用程式的通信方法，應用程式通過讀寫出入隊列的消息來通信，而無需專用連接配接來連結它們。消息傳遞指的是程式之間通過在消息中發送資料進行通信，而不是通過直接調用彼此通信。

MQ是消費-生産者模型的一個典型代表，一端往消息隊列中不斷寫入消息，而另一端則可以讀取或者訂閱隊列中的消息。

安裝

官網位址：http://www.rabbitmq.com/download.html。

下載下傳後，需要安裝RabbitMQ服務。如果沒有Erlang環境會彈出下面的提示：

下載下傳Erlang環境并安裝

位址：http://www.erlang.org/downloads

然後安裝RabbitMQ，安裝成功後會在服務中看到該服務。

一個例子

建立一個控制台應用程式，并使用Nuget引入RabbitMQ

 代碼如下：

當type等于1時，用戶端為生産者，2時為消費者

/// <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);
                        }
                    }
                }
            }
          
        }
    }      

測試

啟動生産者

啟動消費者

使用生産者入隊，1，2，3，4，5，6，7，8

消費者

 參考文章

http://www.cnblogs.com/qy1141/p/4054135.html?utm_source=tuicool&utm_medium=referral

• 部落格位址：http://www.cnblogs.com/wolf-sun/

  部落格版權:如果文中有不妥或者錯誤的地方還望高手的你指出，以免誤人子弟。如果覺得本文對你有所幫助不如【推薦】一下！如果你有更好的建議，不如留言一起讨論，共同進步！

  再次感謝您耐心的讀完本篇文章。