Net分散式系統之四:RabbitMQ消息隊列應用

来源:http://www.cnblogs.com/Andon_liu/archive/2016/04/17/5401961.html
-Advertisement-
Play Games

消息通信組件Net分散式系統的核心中間件之一,應用與系統高併發,各個組件之間解耦的依賴的場景。本框架採用消息隊列中間件主要應用於兩方面:一是解決部分高併發的業務處理;二是通過消息隊列傳輸系統日誌。目前業界使用較多的消息隊列組件有RabbitMQ、ActiveMQ、MSMQ、kafka、zeroMQ等 ...


   消息通信組件Net分散式系統的核心中間件之一,應用與系統高併發,各個組件之間解耦的依賴的場景。本框架採用消息隊列中間件主要應用於兩方面:一是解決部分高併發的業務處理;二是通過消息隊列傳輸系統日誌。目前業界使用較多的消息隊列組件有RabbitMQ、ActiveMQ、MSMQ、kafka、zeroMQ等,本文對系統架構之MQ Component詮釋,並採用RabbitMQ作為消息隊列中間件。

 

圖1- 消息隊列組件示意圖


 

 

一、RabbitMQ介紹

  RabbitMQ是一款基於AMQP(消息隊列協議),由Erlang開發的開源消息隊列組件。是一款優秀的消息隊列組件,他由兩部分組成:服務端和客戶端,客戶端支持多種語言的驅動,如:.Net、JAVA、Erlang等。RabbitMQ與其他消息隊列組件性能比較,在此不作介紹,網上有大把的資料。


 

二、RabbitMQ原理簡介

 

圖2- RabbitMQ結構示意圖

  RabbitMQ中間件分為服務端(RabbitMQ Server)和客戶端(RabbitMQ Client),服務端可以理解為是一個消息的代理消費者,客戶端又分為消息生產者(Producer)和消息消費者(Consumer)。

  1、消息生產者(Producer):主要生產消息並將消息基於TCP協議,通過建立Connection和Channel,將消息傳輸給RabbitMQ Server,對於Producer而言基本就完成了工作。

  2、服務端(RabbitMQ Server):主要負責處理消息路由、分發、入隊列、緩存和出列。主要由三部分組成:Exchange、RoutingKey、Queue。

    (1)Exchange:用於接收消息生產者發送的消息,有三種類型的exchange:direct, fanout,topic,不同類型實現了不同的路由演算法;

    A. direct exchange:將與routing key 比配的消息,直接推入相對應的隊列,創建隊列時,預設就創建同名的routing key。

    B. fanout exchange:是一種廣播模式,忽略routingkey的規則。

    C. topic exchange:應用主題,根據key進行模式匹配路由,例如:若為abc*則推入到所有abc*相對應的queue;若為abc.#則推入到abc.xx.one ,abc.yy.two對應的queue。

    (2)RoutingKey:是RabbitMQ實現路由分發到各個隊列的規則,並結合Binging提供於Exchange使用將消息推送入隊列;

    (3)Queue:是消息隊列,可以根據需要定義多個隊列,設置隊列的屬性,比如:消息移除、消息緩存、回調機制等設置,實現與Consumer通信;

  3、消息消費者(Consumer):主要負責消費Queue的消息,同樣基於TCP協議,通過建立Connection和Channel與Queue傳輸消息,一個消息可以給多個Consumer消費;

  4、關鍵名詞說明:Connection、Channel、Binging等;

    (1)Connection:是建立客戶端與服務端的連接。

    (2)Channel:是基於Connection之上建立通信通道,因為每次Connection建立TCP協議通信開銷及性能消耗較大,所以一次建立Connection後,使用多個Channel通道通信減少開銷和提高性能。

    (3)Binging:是一個捆綁定義,將exchange和queue捆綁,定義routingkey相關策略。


 

三、RabbitMQ安裝部署

   以上對RabbitMQ簡介,接下來我們通過實際搭建消息隊列服務實踐。RabbitMQ服務端能運行於Window、Linux和Mac平臺,客戶端也支持多種技術的實現。本次我們將在Linux之CentOS7平臺搭建。

  1、安裝Erlang運行環境

    由於RabbitMQ使用Erlang技術開發,所以需要先安裝Erlang運行環境後,才能安裝消息隊列服務。

    (1)配置系統能正常訪問公網,設置預設網關

route add default gw 192.168.1.1

    (2)安裝erlang

su -c 'rpm -Uvh http://download.fedoraproject.org/pub/epel/7/x86_64/e/epel-release-7-5.noarch.rpm'
sudo yum install erlang

    (3)檢查erlang是否安裝成功

erl

    (4)安裝成功

    

 

  2、安裝RabbitMQ服務端

    (1)下載安裝包

wget http://www.rabbitmq.com/releases/rabbitmq-server/v3.6.0/rabbitmq-server-3.6.0-1.noarch.rpm

    (2)安裝和配置RabbitMQ服務端,3.6.0版本:

rpm --import https://www.rabbitmq.com/rabbitmq-signing-key-public.asc
yum install rabbitmq-server-3.6.0-1.noarch.rpm

    (3)啟用web管理插件

rabbitmq-plugins enable rabbitmq_management

    (4)啟動RabbitMQ

chkconfig rabbitmq-server on
/sbin/service rabbitmq-server start

    (5)防火牆開通埠

# firewall-cmd --permanent --zone=public --add-port=5672/tcp
# firewall-cmd --permanent --zone=public --add-port=15672/tcp
# firewall-cmd --reload

    (6)rabbitmq預設會創建guest賬號,只能用於localhost登錄頁面管理員,本機訪問地址:http://localhost:15672/

rabbitmqctl add_user test test
rabbitmqctl set_user_tags test administrator
rabbitmqctl set_permissions -p / test ".*" ".*" ".*"

      RabbitMQ 管理員頁面。

 

 


 

四、RabbitMQ應用

   本章節描述,web應用生產的日誌,通過rabbitmq傳輸,然後日誌服務接收消息隊列的消息。

    

圖3- 功能結構示意圖

  本系統採用官方的Client,通過nuget引用。

  

 

   1、Web應用生產業務日誌

[HttpPost]
        public ActionResult Create()
        {
            this.HttpContext.Session["mysession"] = DateTime.Now.ToString("yyyy-MM-dd hh:mm:ss");
            var txt = Request.Form["txtSite"].ToString();
            RabbitMQHelper helper = new RabbitMQHelper();
            helper.SendMsg(txt + ",操作日誌,時間:" + DateTime.Now.ToString("yyyy-MM-dd hh:mm:ss"));

            return RedirectToAction("Index");
        }

  頁面效果圖。

 

  2、日誌服務接收日誌消息

     基於window form開發一個日誌處理服務,並將接收的消息列印出來。

private void btnReceive_Click(object sender, EventArgs e)
        {
            isConnected = true;
            using (var channel = connection.CreateModel())
            {
                channel.QueueDeclare("MyLog", false, false, false, null);

                var consumer = new QueueingBasicConsumer(channel);
                channel.BasicConsume("MyLog", true, consumer);

                while (isConnected)
                {
                    var ea = (BasicDeliverEventArgs)consumer.Queue.Dequeue();

                    var body = ea.Body;
                    var message = Encoding.UTF8.GetString(body);
                    txtMsg.Text += message + "\r\n";

                }
            }
        }

  

 

   3、RabbitMQ頁面監控情況

   RabbitMQ自帶頁面監控工具,通過此工具可以監控MQ的情況:

         

 

五、總結

  此文大概介紹RabbitMQ搭建和應用於本系統,RabbitMQ還是較為簡單,還提供界面監控工具方便運維人員監控。 

 

作者:andon
出處:http://www.cnblogs.com/Andon_liu
關於作者:專註於微軟平臺項目架構、管理。熟悉設計模式、領域驅動、架構設計、敏捷開發和項目管理。現主要從事ASP.NET MVC、WCF/Web API、SOA、MSSQL、redis方面的項目開發、架構、管理工作。 如有問題或建議,請一起學習討論!
本文版權歸作者和博客園共有,歡迎轉載,但未經作者同意必須保留此段聲明,且在文章頁面明顯位置給出原文連接。
如有問題,可以郵件:[email protected] 聯繫我,謝謝。

 


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

-Advertisement-
Play Games
更多相關文章
  • 一、繼承 1、作用:繼承是復用程式代碼的有力手段。 2、理解繼承:當有多個類之間存在相同的屬性時,我們可以在這些類中抽取一個父類,當子類繼承父類時,子類就能使用父類所有的方法和屬性。(子類就無需定義與父類相同的屬性) 二、繼承的基本語法 1、在java語言中,用關鍵字Extends來表示一個類繼承另 ...
  • 思路: Python的實現 要點: ...
  • 一、選擇伺服器放在哪個區域 對於Google而言,不同的區域,搜索結果的就不同.一些英文關鍵詞, 你在中國用Google搜索,發現你網站的排名非產靠前,但是如果你在國外用Google, 你可能翻十頁都找不到你的網站. 我們做Google排名的排名效果不是讓我們自己看的, 而是讓我們的潛在客戶看的. ...
  • 外觀模式(Facade) 定義 外觀模式(Facade),為子系統中的一組介面提供一個一致的界面,此模式定義了一個高層介面,這個介面使得這一子系統更加容易使用。 類圖 描述 Facade:外觀類,外觀類知道哪些子系統類負責處理請求,將用戶的請求代理給恰當的子系統對象。 Classes:子系統類,實現 ...
  • 數組概念 數組是存儲同一種數據類型多個元素的集合。也可以看成是一個容器。數組既可以存儲基本數據類型,也可以存儲引用數據類型。 數組的初始化 動態初始化:初始化時只指定數組長度,由系統為數組分配初始值。格式:數據類型[] 數組名 = new 數據類型[數組長度]; 數組長度其實就是數組中元素的個數。舉 ...
  • 一、什麼是nginx 是一個C語言開發的HTTP反向代理伺服器,性能非常高 一個俄羅斯的哥們開發的,官方提供的測試性能能夠達到5W的併發,我的天吶~,實際測試差不多是2W,而淘寶的牛人可以優化到200W 運行效率非常好,占用的資源也非常低,運行穩定 二、Nginx的應用場景 有哪些 1、http服務 ...
  • ![大話設計模式 抽象工廠模式 結構圖][1] 概述 抽象工廠模式(Abstract Factory)是所有形態的工廠模式中最為抽象和最具一般性的一種形態。抽象工廠模式是指當有多個抽象角色時,使用的一種工廠模式。抽象工廠模式可以向客戶端提供一個介面,使客戶端在不必指定產品的具體的情況下,創建多個產品 ...
  • 一、首先先建立一個Web Project 二、然後在程式根目錄建立文件夾“DataBase”和“Doc”,分別存放資料庫文件和保存SQL語句,建完如下所示: 三、建立資料庫“dbHibernate”,保存到文件夾“DataBase”下 四、書寫SQL語句,創建“student”表 -- 資料庫名稱 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 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 ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...