深入了解RabbitMQ工作原理及簡單使用

深入了解RabbitMQ工作原理及簡單使用

RabbitMQ系列文章

  1. RabbitMQ在Ubuntu上的環境搭建
  2. 深入了解RabbitMQ工作原理及簡單使用
  3. RabbitMQ交換器Exchange介紹與實踐
  4. RabbitMQ事務和Confirm發送方消息確認——深入解讀
  5. 使用Docker部署RabbitMQ集群
  6. 你不知道的RabbitMQ集群架構全解

RabbitMQ簡介

在介紹RabbitMQ之前實現要介紹一下MQ，MQ是什么？

MQ全稱是Message Queue，可以理解為消息隊列的意思，簡單來說就是消息以管道的方式進行傳遞。

RabbitMQ是一個實現了AMQP（Advanced Message Queuing Protocol）高級消息隊列協議的消息隊列服務，用Erlang語言的。

使用場景

在我們秒殺搶購商品的時候，系統會提醒我們稍等排隊中，而不是像幾年前一樣頁面卡死或報錯給用戶。

像這種排隊結算就用到了消息隊列機制，放入通道里面一個一個結算處理，而不是某個時間斷突然涌入大批量的查詢新增把數據庫給搞宕機，所以RabbitMQ本質上起到的作用就是削峰填谷，為業務保駕護航。

為什么選擇RabbitMQ

現在的市面上有很多MQ可以選擇，比如ActiveMQ、ZeroMQ、Appche Qpid，那問題來了為什么要選擇RabbitMQ？

  1. 除了Qpid，RabbitMQ是唯一一個實現了AMQP標準的消息服務器；
  2. 可靠性，RabbitMQ的持久化支持，保證了消息的穩定性；
  3. 高并發，RabbitMQ使用了Erlang開發語言，Erlang是為電話交換機開發的語言，天生自帶高并發光環，和高可用特性；
  4. 集群部署簡單，正是應為Erlang使得RabbitMQ集群部署變的超級簡單；
  5. 社區活躍度高，根據網上資料來看，RabbitMQ也是首選；

工作機制

生產者、消費者和代理

在了解消息通訊之前首先要了解3個概念：生產者、消費者和代理。

生產者：消息的創建者，負責創建和推送數據到消息服務器；

消費者：消息的接收方，用于處理數據和確認消息；

代理：就是RabbitMQ本身，用于扮演“快遞”的角色，本身不生產消息，只是扮演“快遞”的角色。

消息發送原理

首先你必須連接到Rabbit才能發布和消費消息，那怎么連接和發送消息的呢？

你的應用程序和Rabbit Server之間會創建一個TCP連接，一旦TCP打開，并通過了認證，認證就是你試圖連接Rabbit之前發送的Rabbit服務器連接信息和用戶名和密碼，有點像程序連接數據庫，使用Java有兩種連接認證的方式，后面代碼會詳細介紹，一旦認證通過你的應用程序和Rabbit就創建了一條AMQP信道（Channel）。

信道是創建在“真實”TCP上的虛擬連接，AMQP命令都是通過信道發送出去的，每個信道都會有一個唯一的ID，不論是發布消息，訂閱隊列或者介紹消息都是通過信道完成的。

為什么不通過TCP直接發送命令？

對于操作系統來說創建和銷毀TCP會話是非常昂貴的開銷，假設高峰期每秒有成千上萬條連接，每個連接都要創建一條TCP會話，這就造成了TCP連接的巨大浪費，而且操作系統每秒能創建的TCP也是有限的，因此很快就會遇到系統瓶頸。

如果我們每個請求都使用一條TCP連接，既滿足了性能的需要，又能確保每個連接的私密性，這就是引入信道概念的原因。

你必須知道的Rabbit

想要真正的了解Rabbit有些名詞是你必須知道的。

包括：ConnectionFactory（連接管理器）、Channel（信道）、Exchange（交換器）、Queue（隊列）、RoutingKey（路由鍵）、BindingKey（綁定鍵）。

ConnectionFactory（連接管理器）：應用程序與Rabbit之間建立連接的管理器，程序代碼中使用；

Channel（信道）：消息推送使用的通道；

Exchange（交換器）：用于接受、分配消息；

Queue（隊列）：用于存儲生產者的消息；

RoutingKey（路由鍵）：用于把生成者的數據分配到交換器上；

BindingKey（綁定鍵）：用于把交換器的消息綁定到隊列上；

看到上面的解釋，最難理解的路由鍵和綁定鍵了，那么他們具體怎么發揮作用的，請看下圖：

關于更多交換器的信息，我們在后面再講。

消息持久化

Rabbit隊列和交換器有一個不可告人的秘密，就是默認情況下重啟服務器會導致消息丟失，那么怎么保證Rabbit在重啟的時候不丟失呢？答案就是消息持久化。

當你把消息發送到Rabbit服務器的時候，你需要選擇你是否要進行持久化，但這并不能保證Rabbit能從崩潰中恢復，想要Rabbit消息能恢復必須滿足3個條件：

  1. 投遞消息的時候durable設置為true，消息持久化，代碼：channel.queueDeclare(x, true, false, false, null)，參數2設置為true持久化；
  2. 設置投遞模式deliveryMode設置為2（持久），代碼：channel.basicPublish(x, x, MessageProperties.PERSISTENT_TEXT_PLAIN,x)，參數3設置為存儲純文本到磁盤；
  3. 消息已經到達持久化交換器上；
  4. 消息已經到達持久化的隊列；

持久化工作原理

Rabbit會將你的持久化消息寫入磁盤上的持久化日志文件，等消息被消費之后，Rabbit會把這條消息標識為等待垃圾回收。

持久化的缺點

消息持久化的優點顯而易見，但缺點也很明顯，那就是性能，因為要寫入硬盤要比寫入內存性能較低很多，從而降低了服務器的吞吐量，盡管使用SSD硬盤可以使事情得到緩解，但他仍然吸干了Rabbit的性能，當消息成千上萬條要寫入磁盤的時候，性能是很低的。

所以使用者要根據自己的情況，選擇適合自己的方式。

虛擬主機

每個Rabbit都能創建很多vhost，我們稱之為虛擬主機，每個虛擬主機其實都是mini版的RabbitMQ，擁有自己的隊列，交換器和綁定，擁有自己的權限機制。

vhost特性

  1. RabbitMQ默認的vhost是“/”開箱即用；

  2. 多個vhost是隔離的，多個vhost無法通訊，并且不用擔心命名沖突（隊列和交換器和綁定），實現了多層分離；

  3. 創建用戶的時候必須指定vhost；

vhost操作

可以通過rabbitmqctl工具命令創建：

rabbitmqctl add_vhost[vhost_name]

刪除vhost：

rabbitmqctl delete_vhost[vhost_name]

查看所有的vhost：

rabbitmqctl list_vhosts

環境搭建

前文我們已經介紹了Ubuntu搭建RabbitMQ的步驟：RabbitMQ在Ubuntu上的環境搭建

如果你是在Windows10上去安裝那就更簡單了，先放下載地址：

Erlang/Rabbit Server百度網盤鏈接：https://pan.baidu.com/s/1TnKDV-ZuXLiIgyK8c8f9dg 密碼：wct9

當然也可去Erlang和Rabbit官網去下，就是速度比較慢。我的百度云Rabbit最新版本：3.7.6，Erlang版本：20.2，注意：不要下載最新的Erlang，在Windows10上打開擴展插件有問題，打不開。

  1. 安裝Erlang；

  2. 安裝Rabbit Server；

  3. 進入安裝目錄\sbin下，使用命令“rabbitmq-plugins enable rabbitmq_management”啟動網頁管理插件；

  4. 重啟Rabbit服務；

使用：http://localhost:15672進行測試，默認的登陸賬號為：guest，密碼為：guest

重復安裝Rabbit Server的坑

如果不是第一次在Windows上安裝Rabbit Server一定要把Rabbit和Erlang卸載干凈之后，找到注冊表：HKEY_LOCAL_MACHINE\SOFTWARE\Ericsson\Erlang\ErlSrv 刪除其下的所有項。

不然會出現Rabbit安裝之后啟動不了的情況，理論上卸載的順序也是先Rabbit在Erlang。

代碼實現

java版實現，使用maven項目，創建可以查看：MyEclipse2017破解設置與maven項目搭建

項目創建成功之后，添加Rabbit Client jar包，只需要在pom.xml里面配置，如下信息：

 <dependency><groupId>com.rabbitmq</groupId><artifactId>amqp-client</artifactId><version>5.2.0</version>
</dependency>

java實現代碼分為兩個類，第一個是創建Rabbit連接，第二是應用類使用最簡單的方式發布和消費消息。

Rabbit的連接，兩種方式：

方式一：

public static Connection GetRabbitConnection() {ConnectionFactory factory = new ConnectionFactory();factory.setUsername(Config.UserName);factory.setPassword(Config.Password);factory.setVirtualHost(Config.VHost);factory.setHost(Config.Host);factory.setPort(Config.Port);Connection conn = null;try {conn = factory.newConnection();} catch (Exception e) {e.printStackTrace();}return conn;
}

方式二：

public static Connection GetRabbitConnection2() {ConnectionFactory factory = new ConnectionFactory();// 連接格式：amqp://userName:password@hostName:portNumber/virtualHostString uri = String.format("amqp://%s:%s@%s:%d%s", Config.UserName, Config.Password, Config.Host, Config.Port,Config.VHost);Connection conn = null;try {factory.setUri(uri);factory.setVirtualHost(Config.VHost);conn = factory.newConnection();} catch (Exception e) {e.printStackTrace();}return conn;
}

第二部分：應用類，使用最簡單的方式發布和消費消息

public static void main(String[] args) {Publisher(); // 推送消息Consumer(); // 消費消息
}/*** 推送消息*/
public static void Publisher() {// 創建一個連接Connection conn = ConnectionFactoryUtil.GetRabbitConnection();if (conn != null) {try {// 創建通道Channel channel = conn.createChannel();// 聲明隊列【參數說明：參數一：隊列名稱，參數二：是否持久化；參數三：是否獨占模式；參數四：消費者斷開連接時是否刪除隊列；參數五：消息其他參數】channel.queueDeclare(Config.QueueName, false, false, false, null);String content = String.format("當前時間：%s", new Date().getTime());// 發送內容【參數說明：參數一：交換機名稱；參數二：隊列名稱，參數三：消息的其他屬性-routing headers，此屬性為MessageProperties.PERSISTENT_TEXT_PLAIN用于設置純文本消息存儲到硬盤；參數四：消息主體】channel.basicPublish("", Config.QueueName, null, content.getBytes("UTF-8"));System.out.println("已發送消息：" + content);// 關閉連接channel.close();conn.close();} catch (Exception e) {e.printStackTrace();}}
}/*** 消費消息*/
public static void Consumer() {// 創建一個連接Connection conn = ConnectionFactoryUtil.GetRabbitConnection();if (conn != null) {try {// 創建通道Channel channel = conn.createChannel();// 聲明隊列【參數說明：參數一：隊列名稱，參數二：是否持久化；參數三：是否獨占模式；參數四：消費者斷開連接時是否刪除隊列；參數五：消息其他參數】channel.queueDeclare(Config.QueueName, false, false, false, null);// 創建訂閱器，并接受消息channel.basicConsume(Config.QueueName, false, "", new DefaultConsumer(channel) {@Overridepublic void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties,byte[] body) throws IOException {String routingKey = envelope.getRoutingKey(); // 隊列名稱String contentType = properties.getContentType(); // 內容類型String content = new String(body, "utf-8"); // 消息正文System.out.println("消息正文：" + content);channel.basicAck(envelope.getDeliveryTag(), false); // 手動確認消息【參數說明：參數一：該消息的index；參數二：是否批量應答，true批量確認小于index的消息】}});} catch (Exception e) {e.printStackTrace();}}
}

代碼里面已經寫了很詳細的注釋，在這里也不過多的介紹了。

執行效果，如圖：

轉載于:https://www.cnblogs.com/javaGoGo/p/10111513.html

本文來自互聯網用戶投稿，該文觀點僅代表作者本人，不代表本站立場。本站僅提供信息存儲空間服務，不擁有所有權，不承擔相關法律責任。
如若轉載，請注明出處：http://www.pswp.cn/news/450395.shtml
繁體地址，請注明出處：http://hk.pswp.cn/news/450395.shtml
英文地址，請注明出處：http://en.pswp.cn/news/450395.shtml

如若內容造成侵權/違法違規/事實不符，請聯系多彩編程網進行投訴反饋email:809451989@qq.com，一經查實，立即刪除！

相關文章

使用el-checkbox實現全選，點擊失效沒有反應

使用el-checkbox實現全選，點擊失效沒有反應

最近在公司接收到了一個需求&#xff0c;給收藏夾的書籍添加批量、全選刪除實現思路&#xff1a;點擊全選改變item的checked&#xff0c;改變item的checked&#xff0c;重新便利一下所有item的checked來改變全選的selectAll1&#xff09;該組件基本功能已經實現&#xff0c;che…
閱讀更多...
Spring3.2新注解@ControllerAdvice

Spring3.2新注解@ControllerAdvice

前些天發現了一個巨牛的人工智能學習網站&#xff0c;通俗易懂&#xff0c;風趣幽默&#xff0c;忍不住分享一下給大家。點擊跳轉到教程。 ControllerAdvice&#xff0c;是spring3.2提供的新注解&#xff0c;從名字上可以看出大體意思是控制器增強。讓我們先看看ControllerAdv…
閱讀更多...
Mysql1 晨考題

Mysql1 晨考題

Mysql1 晨考題 1.描述主鍵、外鍵、候選主鍵、超鍵分別是什么 &#xff1f; &#xff08;1&#xff09;主鍵&#xff1a;數據庫表中對存儲數據對象給予唯一完整標識的數據列或屬性的組合。一個數據列只能有一個主 鍵&#xff0c;且主鍵的取值不能缺失&#xff0c;即不能為空值…
閱讀更多...
C語言關鍵字

C語言關鍵字

C語言do、while、for關鍵字—循環 C 語言中循環語句有三種&#xff1a;while 循環、do-while 循環、for 循環。while 循環&#xff1a;先判斷while 后面括號里的值&#xff0c;如果為真則執行其后面的代碼&#xff1b;否則不執行。while&#xff08;1&#xff09;表示死循環。…
閱讀更多...
C語言字符篇（五）內存函數

C語言字符篇（五）內存函數

memcpy不可以把目的地址寫成本身但是memmove可以,因為它是先保存到臨時空間 #include <string.h> void *memcpy(void *dest, const void *src, size_t n);將內存src拷貝n個字符到內存destvoid *memmove(void *dest, const void *src, size_t n);將內存src的前n個數據拷貝…
閱讀更多...
GMQ交易平臺大力探索區塊鏈技術，進一步推動產業繁榮

GMQ交易平臺大力探索區塊鏈技術，進一步推動產業繁榮

近年來&#xff0c;區塊鏈技術作為金融科技的中堅力量&#xff0c;受到了產業界的熱切關注&#xff0c;其實驗開展和應用研發正在如火如荼的進行。 在此背景下&#xff0c;各地涌現出一大批優秀的企業投入到區塊鏈產業中&#xff0c;各類企業投融 資活動十分活躍&#xff0c;充…
閱讀更多...
java 筆試題

java 筆試題

JAVA-2003筆試題 一、選擇題&#xff08;每小題2&#xff0c;共10分&#xff09; 下列語句序列執行后&#xff0c;m 的值是&#xff08; C &#xff09; int a10, b3, m5; if( ab ) ma; else ma*m; A.15 B.50 C.55 D.5若已定義byte[]x{11,22,33,-66}其中0≤k≤3&#xff0c;則…
閱讀更多...
objectdatasouce的溫故

objectdatasouce的溫故

在做ecxel的時候&#xff0c;需要前臺做一個聯動的效果。 記錄一下這個數據源的用法&#xff0c;大學時候用的&#xff0c;忘得差不多了 首先就是往頁面拖拽一個objectdatasouce的控件 然后配置數據源&#xff1a; 選擇業務對象(其實就是選擇你要用的哪個類&#xff0c;如果下拉…
閱讀更多...
都會五星回評，歡迎留下地址-博客之星

都會五星回評，歡迎留下地址-博客之星

歡迎五星回評地址https://bbs.csdn.net/topics/603961857
閱讀更多...
jQuery核心

jQuery核心

jQuery(selector) jQuery 的核心功能都是通過這個函數實現的。 jQuery中的一切都基于這個函數&#xff0c;或者說都是在以某種方式使用這個函數。這個函數最基本的用法就是向它傳遞一個表達式&#xff08;通常由 CSS 選擇器組成&#xff09;&#xff0c;然后根據這個表達式來查…
閱讀更多...
Feign api調用方式

Feign api調用方式

Feign使用簡介 基本用法 基本的使用如下所示&#xff0c;一個對于canonical Retrofit sample的適配。 interface GitHub {// RequestLine注解聲明請求方法和請求地址,可以允許有查詢參數RequestLine("GET /repos/{owner}/{repo}/contributors")List<Contributor&g…
閱讀更多...
預處理

預處理

C語言##預算符 和#運算符一樣&#xff0c;##運算符可以用于宏函數的替換部分。這個運算符把兩個語言符號組合成單個語言符號。看例子&#xff1a;#define XNAME(n) x ## n如果這樣使用宏&#xff1a;XNAME(8)則會被展開成這樣&#xff1a;x8看明白了沒&#xff1f; ##就是個粘合…
閱讀更多...
Lambda表達式使用2

Lambda表達式使用2

1.概述　　　　本篇主要介紹lambda中常用的收集器&#xff0c;收集器的作用就是從數據流中生成需要的數據接口。　　　　最常用的就是Collectors.toList()&#xff0c;只要將它傳遞給collect()函數&#xff0c;就能夠使用它了。　　　　在我們使用收集器的時候經常會用到“方法…
閱讀更多...
notepad++ 使用去掉自動檢查紅線

notepad++ 使用去掉自動檢查紅線

前些天發現了一個巨牛的人工智能學習網站&#xff0c;通俗易懂&#xff0c;風趣幽默&#xff0c;忍不住分享一下給大家。點擊跳轉到教程。 notepad新升級了之后就有自動判斷的紅線&#xff0c;單詞拼錯了就給提示&#xff0c;看著這紅線實在難受 在 菜單選項&#xff1a;[插件…
閱讀更多...
cAdvisor+InfluxDB+Grafana 監控Docker

cAdvisor+InfluxDB+Grafana 監控Docker

容器的監控方案其實有很多&#xff0c;有docker自身的docker stats命令、有Scout、有Data Dog等等&#xff0c;本文主要和大家分享一下比較經典的容器開源監控方案組合&#xff1a;cAdvisorInfluxDBGrafan 一、概念 1). InfluxDB是什么nfluxDB是用GO語言編寫的一個開源分布式時…
閱讀更多...
C語言return關鍵字

C語言return關鍵字

return 用來終止一個函數并返回其后面跟著的值。return &#xff08;Val&#xff09;&#xff1b;//此括號可以省略。但一般不省略&#xff0c;尤其在返回一個表達式的值時。return 可以返回些什么東西呢&#xff1f;看下面例子&#xff1a;char * Func(void){char str[30];…r…
閱讀更多...
win7旗艦版怎么降級到專業版

win7旗艦版怎么降級到專業版

一、操作準備及注意事項 1、UltraISO光盤制作工具9.5 2、備份C盤及桌面文件 二、win7旗艦版改成專業版的步驟 1、當前系統為Win7 SP1 64位旗艦版&#xff1b; 2、按WinR打開運行&#xff0c;輸入regedit打開注冊表編輯器&#xff0c;定位到HKEY_LOCAL_MACHINE\Software\Microso…
閱讀更多...
JPA criteria 查詢:類型安全與面向對象

JPA criteria 查詢:類型安全與面向對象

前些天發現了一個巨牛的人工智能學習網站&#xff0c;通俗易懂&#xff0c;風趣幽默&#xff0c;忍不住分享一下給大家。點擊跳轉到教程。 JPA的標準查詢,名為:JPA criteria查詢. 相比JPQL,其優勢是類型安全,更加的面向對象.使用標準查詢,開發人員可在編譯的時候就檢查 查詢的…
閱讀更多...
Algs4-1.4.18數組的局部最小元素

Algs4-1.4.18數組的局部最小元素

1.4.18數組的局部最小元素。編寫一個程序&#xff0c;給定一個含有N個不同整數的數組&#xff0c;找到一個局部最小元素:滿足a[i]<a[i-1],且a[i]<a[i1]的索引i。程序在最壞情況下所需的比較次數為~2lgN。答&#xff1a;檢查數組的中間值a[N/2]以及和它相鄰的元素a[N/2-1]…
閱讀更多...
編程技能和做員工的技能——哪個更重要？

編程技能和做員工的技能——哪個更重要？

摘要&#xff1a;不管我們程序員如何認識這個問題&#xff0c;如果你想在給別人編程打工中獲得事業成功&#xff0c;編程技能不是第一重要的。學會如何做一個好的員工才是重要的&#xff0c;甚至是非常重要的。從最最基本的層面上講&#xff0c;每個員工都應該為最求兩種基本的…
閱讀更多...
最新文章

Copyright @ 2022~2023