隊列工廠之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的代碼分享和環境搭建講解，希望能給您帶來好的幫助，謝謝閱讀；
另外有需要云服務器可以了解下創新互聯scvps.cn，海內外云服務器15元起步，三天無理由+7*72小時售后在線，公司持有idc許可證，提供“云服務器、裸金屬服務器、高防服務器、香港服務器、美國服務器、虛擬主機、免備案服務器”等云主機租用服務以及企業上云的綜合解決方案，具有“安全穩定、簡單易用、服務可用性高、性價比高”等特點與優勢，專為企業上云打造定制，能夠滿足用戶豐富、多元化的應用場景需求。
新聞名稱：隊列工廠之RabbitMQ-創新互聯
標題路徑：http://m.newbst.com/article2/hpjic.html
成都網站建設公司_創新互聯，為您提供營銷型網站建設、品牌網站制作、全網營銷推廣、網站導航、做網站、網站排名
聲明：本網站發布的內容（圖片、視頻和文字）以用戶投稿、用戶轉載內容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網站立場，如需處理請聯系客服。電話：028-86922220；郵箱：631063699@qq.com。內容未經允許不得轉載，或轉載時需注明來源： 創新互聯
- 網站建設可以為企業帶來哪些好處 2021-10-24
- 企業網站建設解決方案 2023-02-22
- 企業可根據網站建設的成本預算來選擇網站建設的類型 2022-05-19
- 網站建設好了以后怎么宣傳以及推廣 2014-07-12
- 上海網站建設公司、上海網站設計公司網站建設好嗎 2020-11-07
- 企業網站建設后把內容做到極致的幾種方法 2016-12-04
- 選擇網站建設系統的時候要注意什么 2021-05-02
- 教育類網站建設的幾個新趨勢 2021-09-12
- 企業營銷型網站建設應注意些什么問題 2022-05-13
- 淄川網站建設如何選擇一個好域名？ 2020-12-16
- 如何挑選高端網站建設公司？重點關注這三個方面 2022-06-17
- 網站建設中MySQL的表類型和存儲過程 2015-11-15