Rabbitmq集群高可用部署詳細

来源:http://www.cnblogs.com/knowledgesea/archive/2017/03/11/6535766.html
-Advertisement-
Play Games

序言 清風萬里的季節,周末本該和親人朋友一起消遣這爛漫的花花草草,或是懶洋洋的曬個太陽聽聽風聲鳥鳴。無奈工作使然,理想使然,我回到啦公司,敲起啦鍵盤,擼起啦代碼,程式狗的世界一片黯然,一片黯然,願天下所有努力的程式狗都夢想成真吧!! 回到正題,為什麼搭建rabbitmq集群?rabbitmq集群有那 ...


序言

清風萬里的季節,周末本該和親人朋友一起消遣這爛漫的花花草草,或是懶洋洋的曬個太陽聽聽風聲鳥鳴。無奈工作使然,理想使然,我回到啦公司,敲起啦鍵盤,擼起啦代碼,程式狗的世界一片黯然,一片黯然,願天下所有努力的程式狗都夢想成真吧!!

回到正題,為什麼搭建rabbitmq集群?rabbitmq集群有那些模式?如何搭建Rabbitmq集群?rabbitmq鏡像高可用策略有那些?

1、首先這款產品本身的優點眾多,大家最看好的便是他的非同步化提高系統抗峰值能力,然後便是系統及功能結構解耦,那麼照此兩點來說,他的在整個系統中的作用還是至關重要的,那麼如此重要,當然要考慮他的高可用性,那麼便有啦第一個問題的解答。

2、rabbitmq有3種模式,但集群模式是2種。詳細如下:

  • 單一模式:即單機情況不做集群,就單獨運行一個rabbitmq而已。
  • 普通模式:預設模式,以兩個節點(rabbit01、rabbit02)為例來進行說明。對於Queue來說,消息實體只存在於其中一個節點rabbit01(或者rabbit02),rabbit01和rabbit02兩個節點僅有相同的元數據,即隊列的結構。當消息進入rabbit01節點的Queue後,consumer從rabbit02節點消費時,RabbitMQ會臨時在rabbit01、rabbit02間進行消息傳輸,把A中的消息實體取出並經過B發送給consumer。所以consumer應儘量連接每一個節點,從中取消息。即對於同一個邏輯隊列,要在多個節點建立物理Queue。否則無論consumer連rabbit01或rabbit02,出口總在rabbit01,會產生瓶頸。當rabbit01節點故障後,rabbit02節點無法取到rabbit01節點中還未消費的消息實體。如果做了消息持久化,那麼得等rabbit01節點恢復,然後才可被消費;如果沒有持久化的話,就會產生消息丟失的現象。
  • 鏡像模式:把需要的隊列做成鏡像隊列,存在與多個節點屬於RabbitMQ的HA方案該模式解決了普通模式中的問題,其實質和普通模式不同之處在於,消息實體會主動在鏡像節點間同步,而不是在客戶端取數據時臨時拉取。該模式帶來的副作用也很明顯,除了降低系統性能外,如果鏡像隊列數量過多,加之大量的消息進入,集群內部的網路帶寬將會被這種同步通訊大大消耗掉。所以在對可靠性要求較高的場合中適用。

準備集群環境安裝RabbitMQ

我的環境如下:

1、兩台Centos7的機器,hostname分別為:F , G .

2、IP地址分別為:F—172.18.8.229 , G—172.18.8.224。

3、修改hosts文件如下,下麵是G這台機器的hosts文件內容,F也需要如下配置:

[root@G bin]# cat /etc/hosts
127.0.0.1 G  localhost localhost.localdomain localhost4 localhost4.localdomain4 
::1       G  localhost localhost.localdomain localhost6 localhost6.localdomain6 

172.18.8.224 G
172.18.8.229 F

4、保證兩台機器都能夠相互ping通,如下圖:

好啦,環境到此就就能滿足啦,接下來我們把rabbitmq裝在2台機器上。

學習不看官方文檔,那就別學啦,地址如下:http://www.rabbitmq.com/install-rpm.html

安裝rabbitmq依賴erlang環境,所以我們要先安裝erlang環境。

安裝完成之後,下載rabbitmq的rpm包ivh即可。如果實在不會安裝,Linux系統(二)軟體的安裝與卸載 裡面有安裝rabbitmq的實例,看官笑納,實在不會裝那加入左上方群,或者點擊網頁右上方的X吧,一定要相信不是你的錯,是你與rabbitmq緣分不到。

安裝啟動過程中如果出現error,那可參考下麵幾個方案試試:

  • vim /etc/rabbitmq/enable_plugins :刪除文件中的內容。
  • 查看hosts文件是否配置完善,相互是否可以ping通
  • 查看相關埠是否被占用,如若占用kill掉
  • 如果已經集群,那麼要查看所有集群中的/var/lib/rabbitmq/.erlang.cookie是否一致。
  • 如果不存在上述文件,echo $HOME ,打開此文件夾,查看cookie文件是否一致。
  • 重啟電腦,防止緩存數據配置未更新過來。

這裡安裝啟動成功之後,來幾個常用的操作。

[root@G bin]# ./rabbitmq-server -deched  --後臺啟動服務
[root@G bin]# ./rabbitmqctl start_app  --啟動服務
[root@G bin]# ./rabbitmqctl stop_app  --關閉服務
[root@G bin]# ./rabbitmq-plugins enable rabbitmq_management --啟動web管理插件
[root@G bin]# ./rabbitmqctl add_user zlh zlh  --添加用戶,密碼
[root@G bin]# ./rabbitmqctl set_user_tags zlh administrator --設置zlh為administrator許可權

如果你看到如下操作,即表明啟動成功啦,並且web管理頁面的插件也啟動成功,如果下麵的6為0,則需要啟動web管理插件

那具體rabbitmqctl 的命令詳細還要看官網文檔:http://www.rabbitmq.com/man/rabbitmqctl.1.man.html

搭建rabbitmq的一般模式集群

 在上述的兩台機器上安裝rabbitmq完成之後,你可以看到你的機器中有如下1個文件。路徑在$HOME中或者在/var/lib/rabbitmq中,文件名稱為.erlang.cookie,他是一個隱藏文件。那麼這文件存儲的內容是什麼,是做什麼用的呢?

這樣說吧:RabbitMQ的集群是依賴erlang集群,而erlang集群是通過這個cookie進行通信認證的,因此我們做集群的第一步就是乾cookie。怎麼乾?

1、必須使集群中也就是F,G這兩台機器的.erlang.cookie文件中cookie值一致,且許可權為owner只讀。

機器G中的Cookie: 機器F中的Cookie:

修改文件許可權如下:

[root@F ~]# chmod 600 .erlang.cookie

2、查看集群狀態,我的是已經做好的。

[root@F bin]# ./rabbitmqctl cluster_status
Cluster status of node rabbit@F ...
[{nodes,[{disc,[rabbit@G]},{ram,[rabbit@F]}]},
 {running_nodes,[rabbit@G,rabbit@F]},
 {cluster_name,<<"rabbit@F">>},
 {partitions,[]},
 {alarms,[{rabbit@G,[]},{rabbit@F,[]}]}]

3、停止當前機器中rabbitmq的服務

[root@F bin]# ./rabbitmqctl stop_app

4、把G中的rabbitmq加入到集群中來

[root@F bin]# ./rabbitmqctl join_cluster --ram rabbit@G

5、開啟當前機器的rabbitmq服務

[root@F bin]# ./rabbitmqctl start_app

6、打開網頁管理頁面查看nodes

如此便可以啦,你可以做下測試,驗證下我們序言中說的普通模式的說明,那必須是杠杠對的。

搭建rabbitmq的鏡像高可用模式集群

寫到這裡,接下來,有朋友要請我吃飯啦,我就速戰速決赴會去啦,即便如此該有的也會都有的。go,go,go。

這一節要參考的文檔是:http://www.rabbitmq.com/ha.html

首先鏡像模式要依賴policy模塊,這個模塊是做什麼用的呢?

policy中文來說是政策,策略的意思,那麼他就是要設置,那些Exchanges或者queue的數據需要複製,同步,如何複製同步?對就是做這些的。

這裡有點內容的,我先上例子慢慢說:

[root@G ~]# ./rabbitmqctl set_policy ha-all "^" '{"ha-mode":"all"}'

參數意思為:

ha-all:為策略名稱。

^:為匹配符,只有一個^代表匹配所有,^zlh為匹配名稱為zlh的exchanges或者queue。

ha-mode:為匹配類型,他分為3種模式:all-所有(所有的queue),exctly-部分(需配置ha-params參數,此參數為int類型比如3,眾多集群中的隨機3台機器),nodes-指定(需配置ha-params參數,此參數為數組類型比如["3rabbit@F","rabbit@G"]這樣指定為F與G這2台機器。)。

參考示例如下

當然在web管理界面也能配置:

配置完看隊列如下,其中表示ha-haall的說明用我的ha-haall策略啦,屬於鏡像模式,沒有表示的就是普通模式:

 

總結

接下來是大家最喜歡的總結內容啦,內容有二,如下:

1、希望能關註我其他的文章。

2、博客裡面有沒有很清楚的說明白,或者你有更好的方式,那麼歡迎加入左上方的2個交流群,我們一起學習探討。


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

-Advertisement-
Play Games
更多相關文章
  • 需求分析: 有個廠家,下麵有很多代理商(商戶或門頭等),之前商戶進貨、庫存、銷售、客戶資料等記錄在excel表格中 或者無記錄,管理比較混亂,盈利情況不明。不能有效瞭解店鋪經營情況和客戶跟蹤記錄 廠家也不能實時瞭解下麵代理商的經營狀況和庫存情況 解決方案: 本系統角色主要分兩個層級:總管理(廠家), ...
  • 功能概要:數據定時更新,可查詢歷史數據。詳細說明:1、現在有個排行榜需要幾分鐘更新一次,所以我使用了windows服務定時運行;一次的數據量在30萬左右,這樣可能到下次更新時本次的任務沒有運行完成,所以遇到這種情況就等待下次任務觸發時再運行更新。 2、當運行更新時,不斷有數據插入到榜單表,為了不影響 ...
  • 閉包是一個比較抽象的概念,尤其是對js新手來說.書上的解釋實在是比較晦澀,對我來說也是一樣. 但是他也是js能力提升中無法繞過的一環,幾乎每次面試必問的問題,因為在回答的時候.你的答案的深度,對術語的理解以及js內部解釋器的運作方式的描述,都是可以看出你js實際水平的.即使你沒答對,也能讓考官對你的 ...
  • 世界上本來沒有設計模式。用的人多了,也就成了設計模式。所以,我們不是嚴格按照它的定義去執行,可以根據自己的實際場景、需求去變通。領悟了其中的思想,實現屬於自己的設計模式。 你肯定有過這樣的體會。某某時候,聽人說起**模式。這麼牛逼,回去得看看。結果仔細一看原來自己早就是這麼用了,只是不知道它還有個這... ...
  • 一、Java的起源 最初是為家用電器設計的,因為其特點適合於internet, 於是通過internet成為一種計算語言,一個平臺,一個網路計算的架構。 二、Java平臺分類 ①JavaSE適用於普通PC及筆記本電腦,為其他JAVA程式的開發和運行提供了最基本的技術支持。 ②JAVAEE適用於企業級 ...
  • 武俠小說練功講究打通任督二脈。程式設計練到一定程度也講究打通任督二脈。好奇心強的同學可以搜搜“打通任督二脈有什麼感覺”。 spring的任督二脈ApplicationContext 最經典的任督二脈莫過於java中spring中的ApplicationContext。用慣spring的都會覺得,這裡 ...
  • 當我們在系統範圍內部署大量的微服務時,一個新的挑戰產生了,單體應用部署時不會發生。這篇文章將針對這些新的挑戰,在系統範圍內部署大量微服務時定義一套操作模型(operations model)。這篇文章分為如下幾個部分: 前提條件;擴展;問題;需要的組件;參考模型;下一步; ...
  • 什麼是白話? 今天我不陳述白話的又由來,也不陳述白話的概念,我們主要說白話到底是一個什麼東西,我認為的白話的呢,通俗的講就是大家都能聽的懂得,不會產生歧義的。此話怎麼講呢?比如“你吃了麽?”你絕對不會回答"我從北京來"。這是明顯的所問非所答。我所謂的白話,淺顯通俗,在語言上,生動、潑辣、粗獷、生活氣 ...
一周排行
    -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.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...