1.RabbitMQ概述

簡介：

• MQ全稱為Message Queue，消息隊列是應用程序和應用程序之間的通信方法；
• RabbitMQ是開源的，實現了AMQP協議的，采用Erlang(面向并發編程語言)編寫的，可復用的企業級消息系統；
• AMQP（高級消息隊列協議）是一個異步消息傳遞所使用應用層協議規范，為面向消息中間件設計，基于此協議的客戶端與消息中間件可以無視消息來源傳遞消息，不受客戶端、消息中間件、不同的開發語言環境等條件的限制；
• 支持主流操作系統：Linux、Windows，MacOX等；
• 支持多種客戶端開發語言：Java、Python、Ruby、.NET，PHP、C/C++、Node.js等

術語說明：

• Server(Broker):接收客戶端連接，實現AMQP協議的消息隊列和路由功能的進程；
• Virtual Host：虛擬主機的概念，類似權限控制組，一個Virtual Host里可以有多個Exchange和Queue,權限控制的最小麗都是Virtual Host；
• Exchange:交換機，接收生產者發送的消息，并根據Routing Key將消息路由到服務器中的隊列Queue。
• ExchangeType:交換機類型決定了路由消息行為，RabbitMQ中有三種類型Exchange，分別是fanout、direct、topic；
• Message Queue：消息隊列，用于存儲還未被消費者消費的消息；
• Message：由Header和body組成，Header是由生產者添加的各種屬性的集合，包括Message是否被持久化、優先級是多少、由哪個Message Queue接收等；body是真正需要發送的數據內容；
  BindingKey：綁定關鍵字，將一個特定的Exchange和一個特定的Queue綁定起來。

---

2.RabbitMQ安裝啟動與管理

2.1 Windows64位環境下安裝RabbitMQ

到RabbitMQ官網下載win64位最新版erlang和rabbitmq-server的安裝包，分別是 erlang otp_win64_19.3和rabbitmq-server-3.6.9。注意安裝時計算機全名最好是英文，先安裝erlang，再安裝rabbitmq-server，根據安裝向導，采用默認安裝配置即可。安裝完成后，可以從開始-所有程序中找到RabbitMQ Server如下圖所示：

?

?

點RabbitMQ Command Prompt啟動命令行，輸入rabbitmq-plugins enable rabbitmq_management

?

啟動管理工具，在瀏覽器中輸入http://127.0.0.1:15672/即可打開管理登錄界面，默認超級管理員用戶名guest,密碼guest

---

2.2 Linux環境下安裝RabbitMQ

先安裝Erlang
wget?http://packages.erlang-solutions.com/erlang-solutions-1.0-1.noarch.rpm
rpm -Uvh erlang-solutions-1.0-1.noarch.rpm
rpm --import?http://packages.erlang-solutions.com/rpm/erlang_solutions.asc
sudo yum install erlang
再安裝RabbitMQ
rpm --import?https://www.rabbitmq.com/rabbitmq-release-signing-key.asc
yum install rabbitmq-server-3.6.9-1.noarch.rpm
操作命令：
啟動 service rabbitmq-server start
停止 service rabbitmq-server stop
重啟 service rabbitmq-server restart
設置開機啟動 chkconfig rabbitmq-server on
開啟web界面管理工具
rabbitmq-plugins enable rabbitmq_management
service rabbitmq-server restart
防火墻開放15672端口訪問
/sbin/iptables -I INPUT -p tcp --dport 15672 -j ACCEPT
/etc/rc.d/init.d/iptables save

---

2.3RabbitMQ管理界面添加用戶和Virtual host

Admin-Users-Add a user

Add a user

Tags:用戶角色說明
** 超級管理員(administrator)**
可登陸管理控制臺，可查看所有的信息，并且可以對用戶，策略(policy)進行操作。
監控者(monitoring)
可登陸管理控制臺，同時可以查看rabbitmq節點的相關信息(進程數，內存使用情況，磁盤使用情況等)
策略制定者(policymaker)
可登陸管理控制臺, 同時可以對policy進行管理,但無法查看節點的相關信息。
普通管理者(management)
僅可登陸管理控制臺，無法看到節點信息，也無法對策略進行管理。
其他none
無法登陸管理控制臺，通常就是普通的生產者和消費者。
Admin-Virtual Host-Add virtual host

Admin-Virtual Host

添加virtual host和用戶后，需要為用戶指定virtual host，之后用該用戶可以登錄

?

3.RabbitMQ的五種隊列模式與實例

3.1 簡單模式Hello World

?

簡單模式Hello World

功能：一個生產者P發送消息到隊列Q,一個消費者C接收
生產者實現思路：
創建連接工廠ConnectionFactory，設置服務地址127.0.0.1，端口號5672，設置用戶名、密碼、virtual host，從連接工廠中獲取連接connection，使用連接創建通道channel，使用通道channel創建隊列queue，使用通道channel向隊列中發送消息，關閉通道和連接。

生產者實現思路

消費者實現思路
創建連接工廠ConnectionFactory，設置服務地址127.0.0.1，端口號5672，設置用戶名、密碼、virtual host，從連接工廠中獲取連接connection，使用連接創建通道channel，使用通道channel創建隊列queue, 創建消費者并監聽隊列，從隊列中讀取消息。

消費者實現思路

?

---

3.2 工作隊列模式Work Queue

?

工作隊列模式Work Queue

功能：一個生產者，多個消費者，每個消費者獲取到的消息唯一，多個消費者只有一個隊列
任務隊列：避免立即做一個資源密集型任務，必須等待它完成，而是把這個任務安排到稍后再做。我們將任務封裝為消息并將其發送給隊列。后臺運行的工作進程將彈出任務并最終執行作業。當有多個worker同時運行時，任務將在它們之間共享。
生產者實現思路：
創建連接工廠ConnectionFactory，設置服務地址127.0.0.1，端口號5672，設置用戶名、密碼、virtual host，從連接工廠中獲取連接connection，使用連接創建通道channel，使用通道channel創建隊列queue，使用通道channel向隊列中發送消息，2條消息之間間隔一定時間，關閉通道和連接。

生產者實現思路

消費者實現思路：
創建連接工廠ConnectionFactory，設置服務地址127.0.0.1，端口號5672，設置用戶名、密碼、virtual host，從連接工廠中獲取連接connection，使用連接創建通道channel，使用通道channel創建隊列queue，創建消費者C1并監聽隊列，獲取消息并暫停10ms，另外一個消費者C2暫停1000ms，由于消費者C1消費速度快，所以C1可以執行更多的任務。

消費者實現思路

?

---

3.3發布/訂閱模式 Publish/Subscribe

?

發布/訂閱模式 Publish/Subscribe

功能：一個生產者發送的消息會被多個消費者獲取。一個生產者、一個交換機、多個隊列、多個消費者
生產者：可以將消息發送到隊列或者是交換機。
消費者：只能從隊列中獲取消息。
如果消息發送到沒有隊列綁定的交換機上，那么消息將丟失。
交換機不能存儲消息，消息存儲在隊列中
生產者實現思路：
創建連接工廠ConnectionFactory，設置服務地址127.0.0.1，端口號5672，設置用戶名、密碼、virtual host，從連接工廠中獲取連接connection，使用連接創建通道channel，使用通道channel創建隊列queue，使用通道channel創建交換機并指定交換機類型為fanout，使用通道向交換機發送消息，關閉通道和連接。

生產者實現思路

消費者實現思路：
創建連接工廠ConnectionFactory，設置服務地址127.0.0.1，端口號5672，設置用戶名、密碼、virtual host，從連接工廠中獲取連接connection，使用連接創建通道channel，使用通道channel創建隊列queue，綁定隊列到交換機，設置Qos=1，創建消費者并監聽隊列，使用手動方式返回完成。可以有多個隊列綁定到交換機，多個消費者進行監聽。

消費者實現思路

?

---

3.4路由模式Routing

?

路由模式Routing

說明：生產者發送消息到交換機并且要指定路由key，消費者將隊列綁定到交換機時需要指定路由key
生產者實現思路：
創建連接工廠ConnectionFactory，設置服務地址127.0.0.1，端口號5672，設置用戶名、密碼、virtual host，從連接工廠中獲取連接connection，使用連接創建通道channel，使用通道channel創建隊列queue，使用通道channel創建交換機并指定交換機類型為direct，使用通道向交換機發送消息并指定key=b，關閉通道和連接。

生產者實現思路

消費者實現思路：
創建連接工廠ConnectionFactory，設置服務地址127.0.0.1，端口號5672，設置用戶名、密碼、virtual host，從連接工廠中獲取連接connection，使用連接創建通道channel，使用通道channel創建隊列queue，綁定隊列到交換機，設置Qos=1，創建消費者并監聽隊列，使用手動方式返回完成。可以有多個隊列綁定到交換機,但只要綁定key=b的隊列key接收到消息，多個消費者進行監聽。

消費者實現思路

?

---

3.5通配符模式Topic

?

通配符模式Topic

說明：生產者P發送消息到交換機X，type=topic，交換機根據綁定隊列的routing key的值進行通配符匹配；
符號#：匹配一個或者多個詞 lazy.# 可以匹配 lazy.irs或者lazy.irs.cor
符號*：只能匹配一個詞 lazy.* 可以匹配 lazy.irs或者lazy.cor
生產者實現思路：
創建連接工廠ConnectionFactory，設置服務地址127.0.0.1，端口號5672，設置用戶名、密碼、virtual host，從連接工廠中獲取連接connection，使用連接創建通道channel，使用通道channel創建隊列queue，使用通道channel創建交換機并指定交換機類型為topic，使用通道向交換機發送消息并指定key=key.1，關閉通道和連接。

生產者實現思路

消費者實現思路：
創建連接工廠ConnectionFactory，設置服務地址127.0.0.1，端口號5672，設置用戶名、密碼、virtual host，從連接工廠中獲取連接connection，使用連接創建通道channel，使用通道channel創建隊列queue，綁定隊列到交換機，設置Qos=1，創建消費者并監聽隊列，使用手動方式返回完成。可以有多個隊列綁定到交換機,凡是綁定規則符合通配符規則的隊列均可以接收到消息，比如key.*,key.#，多個消費者進行監聽。

消費者實現思路

?

4.Spring集成RabbitMQ配置

Spring提供了AMQP的一個實現，并且spring-rabbit是RabbitMQ的一個實現，下面給出訂閱者模式的事例配置如下：

?

Spring集成RabbitMQ配置

5.總結

RabbitMQ提供6種模式，分別是Hello，Work Queue，Publish/Subscribe，Routing，Topics，RPC Request/reply，本文詳細講述了前5種，并給出代碼實現和思路。其中Publish/Subscribe，Routing，Topics三種模式可以統一歸為Exchange模式，只是創建時交換機的類型不一樣，分別是fanout、direct、topic。Spring提供了rabbitmq的一個實現，所以集成起來很方便，本文第4章給出了訂閱者模式的一種spring配置。

本訂閱號提供Java相關技術分享，從Java編程基礎到Java高級技術，從JavaWeb技術基礎Jsp、Servlet、>JDBC到SSH、SSM開發框架，從REST風格接口設計到分布式項目實戰。剖析主流開源技術框架，用親身
實踐來譜寫深度Java技術日志。

總結

以上是生活随笔為你收集整理的消息队列RabbitMQ入门与5种模式详解的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。