隊列工廠之RabbitMQ

来源:http://www.cnblogs.com/wangrudong003/archive/2017/03/14/6550059.html
-Advertisement-
Play Games

本次和大家分享的是RabbitMQ隊列的用法，前一篇文章隊列工廠之(MSMQ)中在描述的時候已經搭建了簡單工廠，因此本章內容是在其之上擴充的子項不再過多講解工廠的代碼了；RabbitMQ應該是現在互聯網公司消息隊列用的最多的一種之一吧，看看招聘基本都會有這個單詞的出現，她相比前一篇分享的MSMQ來說 ...


本次和大家分享的是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常用的幾個操作方法，具體代碼：

 1  /// <summary>
 2     /// RabbitMq
 3     /// </summary>
 4     public class QRabbitMQ : PublicClass.ConfClass<QRabbitMQ>, IQueue
 5     {
 6         private IConnection con = null;
 7 
 8         public void Create()
 9         {
10             if (string.IsNullOrWhiteSpace(this.ApiUrl) || string.IsNullOrWhiteSpace(this.ApiKey)) { throw new Exception("創建RabbitMq隊列需要指定隊列：HostName和Port"); }
11 
12             try
13             {
14                 var factory = new ConnectionFactory() { HostName = this.ApiUrl, Port = Convert.ToInt32(this.ApiKey) };
15                 con = con ?? factory.CreateConnection();
16             }
17             catch (Exception ex)
18             {
19                 throw new Exception(ex.Message);
20             }
21         }
22 
23         public long Total(string name = "Redis_01")
24         {
25             if (con == null) { throw new Exception("請先創建隊列連接"); }
26             using (var channel = con.CreateModel())
27             {
28                 return channel.MessageCount(name);
29             }
30         }
31 
32         public Message Read(string name = "RabbitMQ_01")
33         {
34             if (con == null) { throw new Exception("請先創建隊列連接"); }
35             if (string.IsNullOrWhiteSpace(name)) { throw new Exception("name不能為空"); }
36 
37             var message = new Message();
38             message.Label = name;
39             message.Formatter = new XmlMessageFormatter(new Type[] { typeof(string) });
40             using (var channel = con.CreateModel())
41             {
42                 var baseResult = channel.BasicGet(name, true); //true：獲取後刪除隊列   false：不刪除  
43                 if (baseResult == null) { return message; }
44                 var body = baseResult.Body;
45                 message.Body = Encoding.UTF8.GetString(body); 
46             }
47             return message;
48         }
49 
50         public bool Write(string content, string name = "RabbitMQ_Queue01")
51         {
52             if (con == null) { throw new Exception("請先創建隊列連接"); }
53             if (string.IsNullOrWhiteSpace(content) || string.IsNullOrWhiteSpace(name)) { throw new Exception("content和name不能為空"); }
54 
55             using (var channel = con.CreateModel())
56             {
57                 channel.QueueDeclare(name, false, false, false, null);
58                 var body = Encoding.UTF8.GetBytes(content);
59 
60                 channel.BasicPublish(string.Empty, name, null, body);
61                 return true;
62             }
63         }
64 
65         public void Dispose()
66         {
67             if (con != null)
68             {
69                 con.Close();
70                 con.Dispose();
71                 con = null;
72             }
73         }
74     }

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

 1 /// <summary>
 2     /// ==================
 3     /// author：神牛步行3
 4     /// des：該列工廠開源，包括隊列有MSMQ，RedisMQ，RabbitMQ
 5     /// blogs：http://www.cnblogs.com/wangrudong003/
 6     /// ==================
 7     /// 隊列工廠
 8     /// </summary>
 9     public class QueueReposity<T> where T : class,IQueue, new()
10     {
11         public static IQueue Current
12         {
13             get
14             {
15                 return PublicClass.ConfClass<T>.Current;
16             }
17         }
18     }

 

» 隊列工廠之RabbitMQ測試用例

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

 1  /// <summary>
 2     /// 隊列服務端測試用例
 3     /// </summary>
 4     class Program
 5     {
 6         static void Main(string[] args)
 7         {
 8             //Redis_Server();
 9 
10             RabbitMQ_Server();
11 
12             //MSMQ_Server();
13         }
14         private static void RabbitMQ_Server()
15         {
16             //實例化QMsmq對象
17             var mq = QueueReposity<QRabbitMQ>.Current;
18 
19             try
20             {
21                 Console.WriteLine("Server端創建：RabbitMQ實例");
22                 mq.Create();
23 
24                 var num = 0;
25                 do
26                 {
27                     Console.WriteLine("輸入迴圈數量(數字,0表示結束)：");
28                     var readStr = Console.ReadLine();
29                     num = string.IsNullOrWhiteSpace(readStr) ? 0 : Convert.ToInt32(readStr);
30 
31                     Console.WriteLine("插入數據：");
32                     for (int i = 0; i < num; i++)
33                     {
34                         var str = "我的編號是：" + i;
35                         mq.Write(str);
36                         Console.WriteLine(str);
37                     }
38                 } while (num > 0);
39             }
40             catch (Exception ex)
41             {
42             }
43             finally
44             {
45                 Console.WriteLine("釋放。");
46                 mq.Dispose();
47             }
48             Console.ReadLine();
49         }
50     }

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

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

能夠看到我們剛剛插入的隊列總數和名稱，如果你想看裡面具體內容，可以點擊名字“mq_01”進入某一個隊列的界面，往下麵拉滾動條找到“Get messages”選項，預設查看Messages是1我們修改為10，再點擊get messages就能夠看到如下圖我們剛纔插入的具體內容了：

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

 1  /// <summary>
 2     /// 隊列客戶端測試用例
 3     /// </summary>
 4     class Program
 5     {
 6         static void Main(string[] args)
 7         {
 8             //RedisMQ_Client();
 9 
10             RabbitMQ_Client();
11 
12             //MSMQ_Client();
13         }
14 
15         private static void RabbitMQ_Client()
16         {
17             //實例化QMsmq對象
18             var mq = QueueReposity<QRabbitMQ>.Current;
19             try
20             {
21                 Console.WriteLine("Client端創建：RabbitMQ實例");
22                 mq.Create();
23 
24                 while (true)
25                 {
26                     try
27                     {
28                         var total = mq.Total();
29                         if (total > 0) { Console.WriteLine("隊列條數：" + total); }
30 
31                         var result = mq.Read();
32                         if (result.Body == null) { continue; }
33                         Console.WriteLine(string.Format("接受隊列{0}：{1}", result.Label, result.Body));
34                     }
35                     catch (Exception ex)
36                     { Console.WriteLine("異常信息：" + ex.Message); }
37                 }
38             }
39             catch (Exception ex)
40             {
41                 throw ex;
42             }
43             finally
44             {
45                 Console.WriteLine("釋放。");
46                 mq.Dispose();
47             }
48         }
49     }

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

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

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

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


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 容斥原理及SQL in關鍵字在EF中的應用
    突然意識到文字的重要性，於是開始寫了第一個篇博客，博客目的緊緊為記錄，以便溫故。 同時也希望拋磚能達到引玉的作用，歡迎各位來發表自己的感想與想法，以此達到相互學習促進！ 背景： 在做百度地圖電子圍欄的時候，一條圍欄內包含人員的設置是直接通過更新圍欄表（Fence）內FenceUser欄位（數據格式: ...
  • 從客戶端出現小於等於公式符號引發檢測到有潛在危險的Request.Form 值
    可以在處理Post方法的Action添加一個特性：[ValidateInput(false)]，這樣處理就更加有針對性，提高頁面的安全性。 [HttpPost][ValidateInput(false)]public ActionResult CatalogEdit(Catalog model){r ...
  • Gridview AutoGenerateColumns屬性
    第一篇隨筆，以後會陸續的把剛開始工作時的知識點都記錄下來，畢竟現在用WebForm的不多了~ AutoGenerateColumns MSDN 說明 ： 獲取或設置一個值，該值指示是否為數據源中的每個欄位自動創建綁定的欄位。 預設值為true 當AutoGenerateColumns=true時，那 ...
  • 那一夜，我在等經理給我評分
    using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; using System.Drawing; using System.Linq; using System.... ...
  • .NET Core 運行時標識符 (RID) 目錄
    RID 是什麼？ RID 是運行時標識符的縮寫。 RID 用於標識其中將運行應用程式或資產（即程式集）的目標操作系統。 其外觀類似如下：“ubuntu.14.04-x64”、“win7-x64”、“osx.10.11-x64”。 對於具有本機依賴項的包，它將指定在其中可以還原包的平臺。 Window ...
  • Qt下實現簡單的UDP通信
    本人呢還是小實習生一枚，剛一腳踏進社會大母親的懷抱，不想找工作的時候碰到的全是培訓機構。。。 不過還是幸運的進了一家。。。咳咳，國企？！好吧，其實是國企下麵的一個分出來的小公司（正在起步中，算是創業公司）。有人收留是好，可惜，與小白我的專業不是非常的合拍！沒辦法，還得邊學邊做。 天哪嚕，鬼知道我第一 ...
  • ZKEACMS for .Net Core 深度解析
    ZKEACMS.Core 是基於 .Net Core MVC 開發的開源CMS。ZKEACMS可以讓用戶自由規劃頁面佈局，使用可視化編輯設計“所見即所得”，直接在頁面上進行拖放添加內容。ZKEACMS使用插件式設計，模塊分離，通過橫向擴展來豐富CMS的功能。 ...
  • C#多線程基礎
    最近花了近兩周時間讀完了C#本質論,這本書非常喜歡,但是到後面關於多線程和同步這塊,讀起來就感覺有些困難了,所以做了筆記,一方面防止忘記,另一方法如果有不正確的地方,十分歡喜各位前輩不吝賜教 什麼是單線程 通過一個控制台程式來認識單線程 在Console.WriteLine處添加一個斷點,查看主線程 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類