隊列工廠之RabbitMQ

本次和你們分享的是RabbitMQ隊列的用法，前一篇文章隊列工廠之(MSMQ)中在描述的時候已經搭建了簡單工廠，所以本章內容是在其之上擴充的子項再也不過多講解工廠的代碼了；RabbitMQ應該是如今互聯網公司消息隊列用的最多的一種之一吧，看看招聘基本都會有這個單詞的出現，她相比前一篇分享的MSMQ來講配置更多樣化，安裝步驟數二者都差很少吧，最大差異MSMQ是windows捆綁的服務幾乎只能在windows上使用，而Rabbit現目前運行支持的系統比較多；在寫隊列工廠第二篇文章的時候，其實代碼已經都完成了目前隊列工廠包括有以下隊列（msmq，redis，rabbitmq），你能夠去下載源碼和測試用例：QueueReposity-隊列工廠；但願你們可以喜歡，也但願各位多多"掃碼支持"和"推薦"謝謝！

 

 RabbitMQ安裝和控制檯

 封裝RabbitMQ隊列的讀和寫

 隊列工廠之RabbitMQ測試用例

 

下面一步一個腳印的來分享：

 RabbitMQ安裝和控制檯

要說RabbitMQ的安裝，首先咱們要下載對應服務器操做系統的RabbitMQ安裝文件，由於她有對應不一樣操做系統的安裝版本，這點須要注意；我本地電腦系統是win7(屬於windows)因此去官網下載安裝包：https://www.rabbitmq.com/，進入官網後選擇「Installation」，能看到不少安裝版本的下載源，這裏可選擇從Downloads on rabbitmq.com下載，點擊「windows」便可下載：

目前最新版本地址：

https://www.rabbitmq.com/releases/rabbitmq-server/v3.6.6/rabbitmq-server-3.6.6.exe；

一般我都是進入這個界面的Installation Guides節點後-》With installer (recommended)，這個時候進入的是windows系統所需的幫助文檔吧，一樣能夠選擇版本下載；進入該界面的主要目的是須要下載一個Erlang Windows的安裝文件（更深層緣由：RabbitMq運行依賴於Erlang語言），點擊Erlang Windows Binary File進入下載界面，而後選擇您操做系統對應的版本，若是您也是windows64位的能夠直接用這個地址下載：

http://erlang.org/download/otp_win64_19.2.exe

此刻兩個必須的東西已經下載完成，先安裝erlang語言的exe，再安裝rabbitmq-server-3.6.6.exe；有剛開始接觸RabbitMQ的朋友會問爲何須要Erlang的支持，由於她就是Erlang開發出來的，Erlang語言是一種通用的面向併發的編程語言，專門用來編寫分佈式的一種語言；當你安裝前面說的那個erlang安裝包後，您電腦開始菜單中就有Erlang開發編輯器，有時間您能夠用來練練手，就目前而言這種語言單詞通常出如今一流大公司的招聘中，中小型通常沒有，可能也由於不多中小型公司會涉及到併發的緣由吧；到這裏安裝就完成了，下面須要經過命令行執行一些指令，因爲RabbitMQ配置不少這裏我撿必定會用到的幾個來示範，其餘具體能夠參考官方文檔：

首先找到安裝rabbitmq的目錄並進入rabbitmq_server-3.6.6找到sbin文件夾-》按住Shift+鼠標右鍵sbin文件夾-》在此處打開命令窗體-》參考這個地址https://www.rabbitmq.com/management.html的命令：rabbitmq-plugins enable rabbitmq_management -》錄入到剛纔打開的cmd窗體中：

這個是開啓rabbitmq管理器的指令，這個時候你能夠在你瀏覽器中錄入http://localhost:15672/ 經過遊客帳號進入rabbitmq的監控後臺：

url：http://localhost:15672/

Username：guest

Password：guest

此刻若是你看到以下圖的界面，那恭喜你成功了，搭建RabbitMQ服務成功了:

由於Rabbit不光有隊列，還有其餘的路由，交換機等功能，因此能看到不少的統計或描述，這裏咱們只用到Queues的選項，點擊進入Queues界面能看到沒有任何的數據，可是有一個Add queue的按鈕，這個控制檯容許你手動添加一個隊列數據，固然這不是咱們今天的話題：

上面的guest已經夠咋們測試使用了，至於剩餘的什麼管理員帳號或密碼等操做的設置能夠去看這個：

rabbitmqctl操做的文檔：https://www.rabbitmq.com/man/rabbitmqctl.1.man.html#

plugins操做文檔：https://www.rabbitmq.com/plugins.html

 

 封裝RabbitMQ隊列的讀和寫

在C#中運用RabbitMQ官網列舉了幾種方式，這裏我選擇直接使用其提供的RabbitMQ.Client的nuget包，就目前這個nuget而言4.0.0及以上版本必需要NETFramework 4.5.1及以上版本或netcore版本才容許使用，筆者這裏用的是Framework4.5框架因此引用了此版本的nuget包：

Install-Package RabbitMQ.Client -Version 3.6.6

引用事後就是往前面講的隊列工廠填寫代碼，首先繼承統一配置文件讀取類 PublicClass.ConfClass<QRabbitMQ> ，而後實現 IQueue 接口，這裏封裝了RabbitMq經常使用的幾個操做方法，具體代碼：

/// <summary>
    /// RabbitMq
    /// </summary>
    public class QRabbitMQ : PublicClass.ConfClass<QRabbitMQ>, IQueue
    {
        private IConnection con = null;

        public void Create()
        {
            if (string.IsNullOrWhiteSpace(this.ApiUrl) || string.IsNullOrWhiteSpace(this.ApiKey)) { throw new Exception("建立RabbitMq隊列須要指定隊列：HostName和Port"); }

            try
            {
                var factory = new ConnectionFactory() { HostName = this.ApiUrl, Port = Convert.ToInt32(this.ApiKey) };
                con = con ?? factory.CreateConnection();
            }
            catch (Exception ex)
            {
                throw new Exception(ex.Message);
            }
        }

        public long Total(string name = "Redis_01")
        {
            if (con == null) { throw new Exception("請先建立隊列鏈接"); }
            using (var channel = con.CreateModel())
            {
                return channel.MessageCount(name);
            }
        }

        public Message Read(string name = "RabbitMQ_01")
        {
            if (con == null) { throw new Exception("請先建立隊列鏈接"); }
            if (string.IsNullOrWhiteSpace(name)) { throw new Exception("name不能爲空"); }

            var message = new Message();
            message.Label = name;
            message.Formatter = new XmlMessageFormatter(new Type[] { typeof(string) });
            using (var channel = con.CreateModel())
            {
                var baseResult = channel.BasicGet(name, true); //true：獲取後刪除隊列   false：不刪除  
                if (baseResult == null) { return message; }
                var body = baseResult.Body;
                message.Body = Encoding.UTF8.GetString(body); 
            }
            return message;
        }

        public bool Write(string content, string name = "RabbitMQ_Queue01")
        {
            if (con == null) { throw new Exception("請先建立隊列鏈接"); }
            if (string.IsNullOrWhiteSpace(content) || string.IsNullOrWhiteSpace(name)) { throw new Exception("content和name不能爲空"); }

            using (var channel = con.CreateModel())
            {
                channel.QueueDeclare(name, false, false, false, null);
                var body = Encoding.UTF8.GetBytes(content);

                channel.BasicPublish(string.Empty, name, null, body);
                return true;
            }
        }

        public void Dispose()
        {
            if (con != null)
            {
                con.Close();
                con.Dispose();
                con = null;
            }
        }
    }

代碼主要使用流程是：建立(Create)-》讀(Read)|寫(Write)-》釋放(Dispose)；有了具體的RabbitMq實現類，那麼在工廠中直接經過泛型映射來獲取該實現類的對象：

/// <summary>
    /// ==================
    /// author：神牛步行3
    /// des：該列工廠開源，包括隊列有MSMQ，RedisMQ，RabbitMQ
    /// blogs：http://www.cnblogs.com/wangrudong003/
    /// ==================
    /// 隊列工廠
    /// </summary>
    public class QueueReposity<T> where T : class,IQueue, new()
    {
        public static IQueue Current
        {
            get
            {
                return PublicClass.ConfClass<T>.Current;
            }
        }
    }

 隊列工廠之RabbitMQ測試用例

經過上面配置環境和封裝本身的方法，這裏寫了一個簡單的測試用例，分爲Server(加入消息隊列)和Client(獲取消息隊列)，首先來看Server端的代碼：

/// <summary>
    /// 隊列服務端測試用例
    /// </summary>
    class Program
    {
        static void Main(string[] args)
        {
            //Redis_Server();

            RabbitMQ_Server();

            //MSMQ_Server();
        }
        private static void RabbitMQ_Server()
        {
            //實例化QMsmq對象
            var mq = QueueReposity<QRabbitMQ>.Current;

            try
            {
                Console.WriteLine("Server端建立：RabbitMQ實例");
                mq.Create();

                var num = 0;
                do
                {
                    Console.WriteLine("輸入循環數量(數字,0表示結束)：");
                    var readStr = Console.ReadLine();
                    num = string.IsNullOrWhiteSpace(readStr) ? 0 : Convert.ToInt32(readStr);

                    Console.WriteLine("插入數據：");
                    for (int i = 0; i < num; i++)
                    {
                        var str = "個人編號是：" + i;
                        mq.Write(str);
                        Console.WriteLine(str);
                    }
                } while (num > 0);
            }
            catch (Exception ex)
            {
            }
            finally
            {
                Console.WriteLine("釋放。");
                mq.Dispose();
            }
            Console.ReadLine();
        }
    }

經過：建立(Create)-》讀(Read)|寫(Write)-》釋放(Dispose) 的流程來使用咱們的隊列工廠，感受挺簡單的，此時咱們運行下這個Server端，而後錄入參數：

這個時候就往RabbitMq隊列中加入了11條數據，咱們經過她的後臺去找剛纔添加的隊列：

可以看到咱們剛剛插入的隊列總數和名稱，若是你想看裏面具體內容，能夠點擊名字「mq_01」進入某一個隊列的界面，往下面拉滾動條找到「Get messages」選項，默認查看Messages是1咱們修改成10，再點擊get messages就可以看到以下圖咱們剛纔插入的具體內容了：

截圖有點長哦，不知道dudu會不會怪我哈哈，到這裏能看到隊列插入是成功的，而後咱們來經過client端消費隊列，具體代碼：

/// <summary>
    /// 隊列客戶端測試用例
    /// </summary>
    class Program
    {
        static void Main(string[] args)
        {
            //RedisMQ_Client();

            RabbitMQ_Client();

            //MSMQ_Client();
        }

        private static void RabbitMQ_Client()
        {
            //實例化QMsmq對象
            var mq = QueueReposity<QRabbitMQ>.Current;
            try
            {
                Console.WriteLine("Client端建立：RabbitMQ實例");
                mq.Create();

                while (true)
                {
                    try
                    {
                        var total = mq.Total();
                        if (total > 0) { Console.WriteLine("隊列條數：" + total); }

                        var result = mq.Read();
                        if (result.Body == null) { continue; }
                        Console.WriteLine(string.Format("接受隊列{0}：{1}", result.Label, result.Body));
                    }
                    catch (Exception ex)
                    { Console.WriteLine("異常信息：" + ex.Message); }
                }
            }
            catch (Exception ex)
            {
                throw ex;
            }
            finally
            {
                Console.WriteLine("釋放。");
                mq.Dispose();
            }
        }
    }

再來咋們運行exe看下效果：

此刻剛剛加入隊列中的數據就讀取出來了，這個時候咱們再看Rabbitmq控制檯，get messages已經獲取不出來具體的內容信息了，由於這個客戶端消費了數據，隊列中的數據自動清除了，至因而否想清除數據這個設置在代碼：

1 var baseResult = channel.BasicGet(name, true); //true：獲取後刪除隊列   false：不刪除

以上對封裝RabbitMQ的代碼分享和環境搭建講解，但願能給您帶來好的幫助，謝謝閱讀；