C#調用RabbitMQ實現消息隊列

前言

我在剛接觸使用中間件的時候，發現，中間件的使用並非最難的，反而是中間件的下載，安裝，配置纔是最難的。

因此，這篇文章咱們從頭開始學習RabbitMq，真正的從頭開始。

關於消息隊列

其實消息隊列沒有那麼神祕，咱們這樣想一下，用戶訪問網站，最終是要將數據以HTTP的協議的方式，經過網絡傳輸到主機的某個端口上的。

那麼，接收數據的方式是什麼呢？天然是端口監聽啦。

那消息隊列是什麼就很好解釋了？

它就是端口監聽，接到數據後，將數據排列起來。

那這件事，咱們不用中間件能作嗎？

固然能作啦，寫個TCP/UDP/Socket的軟件就能夠作啦。

舉個簡單的例子，以下圖：

既然本身能夠作消息隊列，那爲何要用RabbitMQ?

由於，RabbitMQ成熟的開源中間件，可靠性有保證，bug少，性能也很是好。

而C#代碼默認是使用託管內存的，因此，想寫出媲美RabbitMQ性能的消息隊列，就必須離開咱們經常使用的託管內存，使用非託管內存，但這個代價就太大了；並且最終可否達到RabbitMQ的性能水平仍是個未知數。

還有就是RabbitMQ除了基礎的消息隊列管理，還有不少很強大的額外功能，而本身開發消息隊列，很難如此盡善盡美。

----------------------------------------------------------------------------------------------------

咱們還會發現，在消息隊列裏有不少概念，什麼消息總線啊，什麼工做隊列啊等等。

要怎麼理解這些概念呢？

很簡單，不要去理解。這些概念實際上是人家代碼架構的模式，不要去理解他們，【記】就完了，人家的中間件就是按照這個模式工做的。

好比，我寫了一個接收消息的總控制器，而後我爲他命名爲總線，那這個控制器就是總線，沒有理由，這就是定義。

準備工做

首先，咱們訪問官網【https://www.rabbitmq.com/】，點擊Get Started。

而後，網站會自動跳轉到當前首頁Get Started的錨點位置，以下圖：

Get Started錨點：

而後咱們點擊DownLoad+Installation，進入到下載界面。

在下載頁面中，咱們找到安裝指南，而後在點擊官網推薦的Windows系統的安裝包，以下圖：

如今，咱們進入了Windows安裝指南界面了。

首先，咱們看一下預覽信息，以下圖：

在預覽裏，咱們得知，安裝RabbitMQ有兩種方法，一種是使用Chocolatey安裝，一種是使用官方安裝包安裝。

Chocolatey是什麼呢?隨手百度一下，原來他是一個軟件包管理工具，也就是說，Chocolatey是相似於Nuget的一種工具。

因爲Chocolatey的使用，我不是很熟悉，因此，這裏選擇使用官方安裝包安裝。

點擊【Using the official installer】，咱們進入了【Using the official installer】對應的錨點，以下圖。

 

在【Using the official installer】段落裏找到有推薦標誌的安裝包，而後下載。 

下載完成後，咱們能夠獲得這樣一個安裝包，以下圖：

除了下載安裝包，咱們還會發現，在【Using the official installer】段落裏，有提醒咱們，RabbitMQ是有依賴的，依賴一個Erlang語言的框架（相似於C#語言的NetFramework）。

咱們能夠發現，在依賴的段落裏，官網很是坑的給出了三個連接網址，以下：

supported version of Erlang：https://www.rabbitmq.com/which-erlang.html

Windows installer：https://www.erlang.org/downloads

Erlang Solutions：https://www.erlang-solutions.com/resources/download.html

由於，咱們是沒法經過文字描述來判斷，哪個是真的依賴框架的下載地址，因此只好每一個都點擊進去看看。。。

打開網址後發現，在後兩個網址中均可以找到框架下載地址，但第二個地址明顯更友好一點，因此咱們在第二個網址內下載Erlang的框架。

 下載完成獲得以下圖文件：

 PS：這裏下載的是OTP的22.1的版本，個人理解是Erlang等於C#語言，而OTP等於NetFramework。

安裝Erlang\OTP

首先，咱們運行otp_win64_22.1.exe，安裝依賴框架Erlang\OTP。

安裝完成後，設置環境變量以下：

而後運行CMD，輸入erl，測試安裝是否成功，以下圖：

安裝成功。

安裝rabbitmq-server

安裝完依賴後，咱們接着安裝rabbitmq-server-3.8.0.exe。

【rabbitmq-server-3.8.0.exe】？從這個文件名上，咱們發現了一個問題，那就是，咱們即將安裝的RabbitMQ，是一個服務端啊。

什麼？服務端？難道還有客戶端？？？

其實這也很好理解，想一下最開始我舉的那個例子，消息隊列是須要一個監聽端口的服務端的，而後客戶端向這個服務端發送請求。

這樣是否是就很好的理解RabbitMQ了呢：）

----------------------------------------------------------------------------------------------------

安裝完RabbitMQ服務端後，咱們仍是啓動CMD，用命令行來查看下安裝狀態。

首先輸入下面的命令，將路徑定位到RabbitMQ的路徑下：

【CD /D C:\Program Files\RabbitMQ Server\rabbitmq_server-3.8.0\sbin】

而後輸入rabbitmqctl status查看狀態。

啓動管理工具的命令行：rabbitmq-plugins enable rabbitmq_management。

啓動成功後，在瀏覽器輸入地址http://127.0.0.1:15672/，進入管理頁面，帳戶密碼都是guest。

RabbitMQ還有不少經常使用命令，你們能夠自行百度。

----------------------------------------------------------------------------------------------------

到此，RabbitMQ服務端的環境配置好了，正常狀況，這些配置應該在服務器進行，但我爲了測試方便，就把服務端也安裝在本機了，所以我下面調用RabbitMQ時，鏈接的主機IP都是localhost。

RabbitMQ應用

首先建立兩個控制檯應用程序，KibaRabbitMQSend和KibaRabbitMQReceived。

而後引入RabbitMQ的開源類庫。

在C#裏使用RabbitMQ開源類庫很是簡單，能夠去官網下載一個.NET版本的RabbitMQ客戶端類庫，也能夠直接在Nuget上搜索RabbitMQ，而後安裝，以下圖：

KibaRabbitMQSend

安裝完RabbitMQ開源類庫後，咱們編寫代碼，實現向RabbitMQ服務器發送消息，代碼以下：

static void Main(string[] args)
{
    var factory = new ConnectionFactory();
    factory.HostName = "localhost";//主機名，Rabbit會拿這個IP生成一個endpoint，這個很熟悉吧，就是socket綁定的那個終結點。
    factory.UserName = "guest";//默認用戶名,用戶能夠在服務端自定義建立，有相關命令行
    factory.Password = "guest";//默認密碼

    using (var connection = factory.CreateConnection())//鏈接服務器，即正在建立終結點。
    {
        //建立一個通道，這個就是Rabbit本身定義的規則了，若是本身寫消息隊列，這個就能夠開腦洞設計了
        //這裏Rabbit的玩法就是一個通道channel下包含多個隊列Queue
        using (var channel = connection.CreateModel())
        { 
             channel.QueueDeclare("kibaQueue", false, false, false, null);//建立一個名稱爲kibaqueue的消息隊列
             var properties = channel.CreateBasicProperties();
             properties.DeliveryMode = 1;
             string message = "I am Kiba518"; //傳遞的消息內容 
             channel.BasicPublish("", "kibaQueue", properties, Encoding.UTF8.GetBytes(message)); //生產消息
             Console.WriteLine($"Send:{message}"); 
        }
    }
}

運行代碼。

而後咱們使用命令行rabbitmqctl list_queues，去RabbitMQ的服務器查看當前消息隊列，以下圖：

能夠看到，咱們的消息已經發送成功了。

KibaRabbitMQReceived

如今咱們編寫接收消息代碼，以下：

static void Main(string[] args)
{
    var factory = new ConnectionFactory();
    factory.HostName = "localhost";
    factory.UserName = "guest";
    factory.Password = "guest";

    using (var connection = factory.CreateConnection())
    {
        using (var channel = connection.CreateModel())
        {
            channel.QueueDeclare("kibaQueue", false, false, false, null);

            /* 這裏定義了一個消費者，用於消費服務器接受的消息
             * C#開發須要注意下這裏，在一些非面向對象和麪向對象比較差的語言中，是很是重視這種設計模式的。
             * 好比RabbitMQ使用了生產者與消費者模式，而後不少相關的使用文章都在拿這個生產者和消費者來表述。
             * 可是，在C#裏，生產者與消費者對咱們而言，根本算不上一種設計模式，他就是一種最基礎的代碼編寫規則。
             * 因此，你們不要複雜的名詞嚇到，其實，並沒那麼複雜。
             * 這裏，其實就是定義一個EventingBasicConsumer類型的對象，而後該對象有個Received事件，
             * 該事件會在服務接收到數據時觸發。
             */
            var consumer = new EventingBasicConsumer(channel);//消費者 
            channel.BasicConsume("kibaQueue", true, consumer);//消費消息 
            consumer.Received += (model, ea) =>
            {
                var body = ea.Body;
                var message = Encoding.UTF8.GetString(body); 
            }; 
        }
    }
}

運行代碼。

而後咱們使用命令行rabbitmqctl list_queues，去RabbitMQ的服務器查看當前消息隊列，以下圖：

能夠看到，消息已經被使用了。

----------------------------------------------------------------------------------------------------

如今咱們在發送代碼出作一個for循環，看看消息接收速度是什麼樣的，代碼以下，for循環了100次，每次間隔3秒。

for (int i = 0; i < 100; i++)
{
    channel.QueueDeclare("kibaQueue", false, false, false, null);//建立一個名稱爲kibaQueue的消息隊列
    var properties = channel.CreateBasicProperties();
    properties.DeliveryMode = 1;
    string message = "I am Kiba518"; //傳遞的消息內容 
    channel.BasicPublish("", "kibaQueue", properties, Encoding.UTF8.GetBytes(message)); //生產消息
    Console.WriteLine($"Send:{message}");
    Thread.Sleep(3000);
}

效果圖以下：

能夠看到，發送消息和接收消息，幾乎是同步的，效果很是理想。

服務器端應用

在上文，咱們的RabbitMQ服務是安裝在個人本機上的；如今咱們把服務移植到服務器上，而後再來測試一下。

在服務器端安裝RabbitMQ和在本機安裝的步驟是同樣的，可是安裝完成後，咱們須要設置下防火牆的入站規則和出站規則，將5672的UDP端口開放一下。

爲何要開放端口是5672？由於RabbitMQ的默認的消息接收和發送端口就是5672，咱們可使用斷點查看一下。

如上圖，能夠看到，在咱們沒有設置端口的時候，Endpoint的端口的默認值是5672。

配置完端口後，咱們修改代碼中的HostName爲咱們的服務器地址，以下。

factory.HostName = "1.1.1.1";

從新運行代碼，會發如今運行到factory.CreateConnection()的時候，系統提示一個異常【RabbitMQ.Client.Exceptions.BrokerUnreachableException:「None of the specified endpoints were reachable」】，以下圖：

這是由於咱們使用的帳號是guest，guest帳號默認是不支持遠程鏈接的。

解決辦法很簡單，新建一個帳戶便可。

建立用戶

在服務器端打開瀏覽器，輸入http://127.0.0.1:15672/，進入管理頁面。

點擊菜單欄的Admin選項，進入用戶管理界面建立用戶kiba，密碼123456，以下圖：

建立完用戶後，獲得以下界面。

如上圖所示，剛剛建立的用戶尚未任何訪問權限。

如今咱們點擊用戶名，進入權限管理頁面設置權限。

如上圖所示，頁面默認爲咱們設置了一個可讀，可寫，可管理配置的權限；因此，咱們只要點擊Set premission就能夠了。

設置完權限，咱們回到用戶管理頁面。 

如上圖所示，權限設置成功。

如今咱們回到代碼，修改用戶名密碼以下。

factory.HostName = "1.1.1.1";
factory.UserName = "kiba";
factory.Password = "123456";

運行代碼，再也不拋異常，接受發送消息正常。

----------------------------------------------------------------------------------------------------

 設置用戶權限也能夠經過命令的方式設置，以下：

 rabbitmqctl set_permissions -p "/" kiba "." "." ".*"

----------------------------------------------------------------------------------------------------

到此C#調用RabbitMQ實現消息隊列就講完了。

代碼已經傳到Github上了，歡迎你們下載。

Github地址：https://github.com/kiba518/KibaRabbitMQ

----------------------------------------------------------------------------------------------------

注：此文章爲原創，任何形式的轉載都請聯繫做者得到受權並註明出處！
若您以爲這篇文章還不錯，請點擊下方的【推薦】，很是感謝！
本文已獨家受權給腳本之家（ID:jb51net）公衆號發佈

http://www.javashuo.com/article/p-yiyczbzz-bc.html