前言
創(chuàng)新互聯(lián)專注于舒蘭企業(yè)網(wǎng)站建設(shè),自適應(yīng)網(wǎng)站建設(shè),商城網(wǎng)站建設(shè)。舒蘭網(wǎng)站建設(shè)公司,為舒蘭等地區(qū)提供建站服務(wù)。全流程按需求定制設(shè)計(jì)，專業(yè)設(shè)計(jì)，全程項(xiàng)目跟蹤，創(chuàng)新互聯(lián)專業(yè)和態(tài)度為您提供的服務(wù)我在剛接觸使用中間件的時(shí)候，發(fā)現(xiàn)，中間件的使用并不是最難的，反而是中間件的下載，安裝，配置才是最難的。
所以，這篇文章我們從頭開始學(xué)習(xí)RabbitMq，真正的從頭開始。
關(guān)于消息隊(duì)列
其實(shí)消息隊(duì)列沒有那么神秘，我們這樣想一下，用戶訪問網(wǎng)站，最終是要將數(shù)據(jù)以HTTP的協(xié)議的方式，通過網(wǎng)絡(luò)傳輸?shù)街鳈C(jī)的某個端口上的。
那么，接收數(shù)據(jù)的方式是什么呢？自然是端口監(jiān)聽啦。
那消息隊(duì)列是什么就很好解釋了？
它就是端口監(jiān)聽，接到數(shù)據(jù)后，將數(shù)據(jù)排列起來。
那這件事，我們不用中間件能做嗎？
當(dāng)然能做啦，寫個TCP/UDP/Socket的軟件就可以做啦。
舉個簡單的例子，如下圖：
既然自己可以做消息隊(duì)列，那為什么要用RabbitMQ?
因?yàn)?，RabbitMQ成熟的開源中間件，可靠性有保證，bug少，性能也非常好。
而C#代碼默認(rèn)是使用托管內(nèi)存的，所以，想寫出媲美RabbitMQ性能的消息隊(duì)列，就必須離開我們常用的托管內(nèi)存，使用非托管內(nèi)存，但這個代價(jià)就太大了；而且最終能否達(dá)到RabbitMQ的性能水平還是個未知數(shù)。
還有就是RabbitMQ除了基礎(chǔ)的消息隊(duì)列管理，還有很多很強(qiáng)大的額外功能，而自己開發(fā)消息隊(duì)列，很難如此盡善盡美。
我們還會發(fā)現(xiàn)，在消息隊(duì)列里有很多概念，什么消息總線啊，什么工作隊(duì)列啊等等。
要怎么理解這些概念呢？
很簡單，不要去理解。這些概念其實(shí)是人家代碼架構(gòu)的模式，不要去理解他們，【記】就完了，人家的中間件就是按照這個模式工作的。
比如，我寫了一個接收消息的總控制器，然后我為他命名為總線，那這個控制器就是總線，沒有理由，這就是定義。
準(zhǔn)備工作
首先，我們訪問官網(wǎng)【https://www.rabbitmq.com/】，點(diǎn)擊Get Started。
然后，網(wǎng)站會自動跳轉(zhuǎn)到當(dāng)前首頁Get Started的錨點(diǎn)位置，如下圖：
Get Started錨點(diǎn)：
然后我們點(diǎn)擊DownLoad+Installation，進(jìn)入到下載界面。
在下載頁面中，我們找到安裝指南，然后在點(diǎn)擊官網(wǎng)推薦的Windows系統(tǒng)的安裝包，如下圖：
現(xiàn)在，我們進(jìn)入了Windows安裝指南界面了。
首先，我們看一下預(yù)覽信息，如下圖：
在預(yù)覽里，我們得知，安裝RabbitMQ有兩種方法，一種是使用Chocolatey安裝，一種是使用官方安裝包安裝。
Chocolatey是什么呢?隨手百度一下，原來他是一個軟件包管理工具，也就是說，Chocolatey是類似于Nuget的一種工具。
由于Chocolatey的使用，我不是很熟悉，所以，這里選擇使用官方安裝包安裝。
點(diǎn)擊【Using the official installer】，我們進(jìn)入了【Using the official installer】對應(yīng)的錨點(diǎn)，如下圖。
在【Using the official installer】段落里找到有推薦標(biāo)志的安裝包，然后下載。
下載完成后，我們可以得到這樣一個安裝包，如下圖：
除了下載安裝包，我們還會發(fā)現(xiàn)，在【Using the official installer】段落里，有提醒我們，RabbitMQ是有依賴的，依賴一個Erlang語言的框架（類似于C#語言的NetFramework）。
我們可以發(fā)現(xiàn)，在依賴的段落里，官網(wǎng)非?？拥慕o出了三個鏈接網(wǎng)址，如下：
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
因?yàn)?，我們是無法通過文字描述來判斷，哪一個是真的依賴框架的下載地址，所以只好每個都點(diǎn)擊進(jìn)去看看。。。
打開網(wǎng)址后發(fā)現(xiàn)，在后兩個網(wǎng)址中都可以找到框架下載地址，但第二個地址明顯更友好一點(diǎn)，所以我們在第二個網(wǎng)址內(nèi)下載Erlang的框架。
下載完成得到如下圖文件：
PS：這里下載的是OTP的22.1的版本，我的理解是Erlang等于C#語言，而OTP等于NetFramework。
安裝Erlang\OTP
首先，我們運(yùn)行otp_win64_22.1.exe，安裝依賴框架Erlang\OTP。
安裝完成后，設(shè)置環(huán)境變量如下：
然后運(yùn)行CMD，輸入erl，測試安裝是否成功，如下圖：
安裝成功。
安裝rabbitmq-server
安裝完依賴后，我們接著安裝rabbitmq-server-3.8.0.exe。
【rabbitmq-server-3.8.0.exe】？從這個文件名上，我們發(fā)現(xiàn)了一個問題，那就是，我們即將安裝的RabbitMQ，是一個服務(wù)端啊。
什么？服務(wù)端？難道還有客戶端？？？
其實(shí)這也很好理解，想一下最開始我舉的那個例子，消息隊(duì)列是需要一個監(jiān)聽端口的服務(wù)端的，然后客戶端向這個服務(wù)端發(fā)送請求。
這樣是不是就很好的理解RabbitMQ了呢：）
安裝完RabbitMQ服務(wù)端后，我們還是啟動CMD，用命令行來查看下安裝狀態(tài)。
首先輸入下面的命令，將路徑定位到RabbitMQ的路徑下：
【CD /D C:\Program Files\RabbitMQ Server\rabbitmq_server-3.8.0\sbin】
然后輸入rabbitmqctl status查看狀態(tài)。
啟動管理工具的命令行：rabbitmq-plugins enable rabbitmq_management。
啟動成功后，在瀏覽器輸入地址http://127.0.0.1:15672/，進(jìn)入管理頁面，賬戶密碼都是guest。
RabbitMQ還有很多常用命令，大家可以自行百度。
到此，RabbitMQ服務(wù)端的環(huán)境配置好了，正常情況，這些配置應(yīng)該在服務(wù)器進(jìn)行，但我為了測試方便，就把服務(wù)端也安裝在本機(jī)了，因此我下面調(diào)用RabbitMQ時(shí)，連接的主機(jī)IP都是localhost。
RabbitMQ應(yīng)用
首先創(chuàng)建兩個控制臺應(yīng)用程序，KibaRabbitMQSend和KibaRabbitMQReceived。
然后引入RabbitMQ的開源類庫。
在C#里使用RabbitMQ開源類庫非常簡單，可以去官網(wǎng)下載一個.NET版本的RabbitMQ客戶端類庫，也可以直接在Nuget上搜索RabbitMQ，然后安裝，如下圖：
KibaRabbitMQSend
安裝完RabbitMQ開源類庫后，我們編寫代碼，實(shí)現(xiàn)向RabbitMQ服務(wù)器發(fā)送消息，代碼如下：
重慶分公司
重慶分公司
static void Main(string[] args)
{
var factory = new ConnectionFactory();
factory.HostName = "localhost";//主機(jī)名，Rabbit會拿這個IP生成一個endpoint，這個很熟悉吧，就是socket綁定的那個終結(jié)點(diǎn)。
factory.UserName = "guest";//默認(rèn)用戶名,用戶可以在服務(wù)端自定義創(chuàng)建，有相關(guān)命令行
factory.Password = "guest";//默認(rèn)密碼
using (var connection = factory.CreateConnection())//連接服務(wù)器，即正在創(chuàng)建終結(jié)點(diǎn)。
{
//創(chuàng)建一個通道，這個就是Rabbit自己定義的規(guī)則了，如果自己寫消息隊(duì)列，這個就可以開腦洞設(shè)計(jì)了
//這里Rabbit的玩法就是一個通道channel下包含多個隊(duì)列Queue
using (var channel = connection.CreateModel())
{
channel.QueueDeclare("kibaQueue", false, false, false, null);//創(chuàng)建一個名稱為kibaqueue的消息隊(duì)列
var properties = channel.CreateBasicProperties();
properties.DeliveryMode = 1;
string message = "I am Kiba518"; //傳遞的消息內(nèi)容
channel.BasicPublish("", "kibaQueue", properties, Encoding.UTF8.GetBytes(message)); //生產(chǎn)消息
Console.WriteLine($"Send:{message}");
}
}
}另外有需要云服務(wù)器可以了解下創(chuàng)新互聯(lián)scvps.cn，海內(nèi)外云服務(wù)器15元起步，三天無理由+7*72小時(shí)售后在線，公司持有idc許可證，提供“云服務(wù)器、裸金屬服務(wù)器、高防服務(wù)器、香港服務(wù)器、美國服務(wù)器、虛擬主機(jī)、免備案服務(wù)器”等云主機(jī)租用服務(wù)以及企業(yè)上云的綜合解決方案，具有“安全穩(wěn)定、簡單易用、服務(wù)可用性高、性價(jià)比高”等特點(diǎn)與優(yōu)勢，專為企業(yè)上云打造定制，能夠滿足用戶豐富、多元化的應(yīng)用場景需求。
