Rabbitmq集群詳解
1、什麽是rabbitmq?
MQ全稱為MessageQueue,消息隊列(MQ)是一種應用程序對應用程序的通信方法。應用程序通過寫和檢索出入列隊的針對應用程序的數據(消息)來通信,而無需專用連接來鏈接它們。
RabbitMQ 是一個由 Erlang 語言開發的 AMQP(高級消息隊列協議) 的開源實現。RabbitMQ 屬於消息中間件,主要用於組件之間的解耦,消息的發送者無需知道消息使用者的存在,反之亦然。
2、rabbitmq特點
- 可靠性(Reliability)
RabbitMQ 使用一些機制來保證可靠性,如持久化、傳輸確認、發布確認。 - 靈活的路由(Flexible Routing)
- 消息集群(Clustering)
多個 RabbitMQ 服務器可以組成一個集群,形成一個邏輯 Broker 。 - 高可用(Highly Available Queues)
隊列可以在集群中的機器上進行鏡像,使得在部分節點出問題的情況下隊列仍然可用。 - 多種協議(Multi-protocol)
RabbitMQ 支持多種消息隊列協議,比如 STOMP、MQTT 等等。 - 多語言客戶端(Many Clients)
RabbitMQ 幾乎支持所有常用語言,比如 Java、.NET、Ruby 等等。 - 管理界面(Management UI)
RabbitMQ 提供了一個易用的用戶界面,使得用戶可以監控和管理消息 Broker 的許多方面。 - 跟蹤機制(Tracing)
如果消息異常,RabbitMQ 提供了消息跟蹤機制,使用者可以找出發生了什麽。 - 插件機制(Plugin System)
RabbitMQ 提供了許多插件,來從多方面進行擴展,也可以編寫自己的插件。3、rabbitmq的內部結構
- Message
消息,消息是不具名的,它由消息頭和消息體組成。 - Publisher
消息的生產者,也是一個向交換器發布消息的客戶端應用程序。 - Exchange
交換器,用來接收生產者發送的消息並將這些消息路由給服務器中的隊列。 - Binding
綁定,用於消息隊列和交換器之間的關聯。 - Queue
消息隊列,用來保存消息直到發送給消費者。它是消息的容器,也是消息的終點。一個消息可投入一個或多個隊列。 - Connection
網絡連接,比如一個TCP連接。 - Channel
信道,多路復用連接中的一條獨立的雙向數據流通道。 - Consumer
消息的消費者,表示一個從消息隊列中取得消息的客戶端應用程序。 - Virtual Host
虛擬主機,表示一批交換器、消息隊列和相關對象。虛擬主機是共享相同的身份認證和加密環境的獨立服務器域。 - Broker
表示消息隊列服務器實體。Rabbitmq應用
rabbit應用模式
單一模式
普通模式(默認集群模式)
鏡像模式(隊列做成鏡像隊列,存在多個節點)
Rabbitmq的集群節點包括內存節點、磁盤節點,支持消息持久化、也就是數據寫在磁盤上。
rabbit工作過程
(1)客戶端連接到消息隊列服務器,打開一個channel。
(2)客戶端聲明一個exchange,並設置相關屬性。
(3)客戶端聲明一個queue,並設置相關屬性。
(4)客戶端使用routing key,在exchange和queue之間建立好綁定關系。
(5)客戶端投遞消息到exchange。
(6)Exchange接收到消息根據消息的key和已經設置的binding,進行消息路由,將消息投遞到queues中,應用程序雙方就實現了通信。
Rabbitmq部署
實驗說明:
一個集群中有三臺服務器,其中一臺使用磁盤模式,另外兩臺是內存模式。客戶端通過前端反向代理去連接兩臺內存模式服務器。註意將三臺服務器都連上互聯網並安裝軟件包。
實驗環境:
主機名 | 操作系統 | IP地址 | 用途 |
---|---|---|---|
mq01 | CentOS7 | 192.168.37.128 | 磁盤節點 |
mq02 | CentOS7 | 192.168.37.130 | 內存節點 |
mq03 | CentOS7 | 192.168.37.131 | 內存節點 |
實驗過程:
++++++三臺服務器相同操作++++++
1、關閉防火墻、安全功能
systemctl stop firewalld.service
setenforce 0
2、首先修改三臺服務器的主機名和hosts文件
hostnamectl set-hostname mq01
bash
vim /etc/hosts
192.168.37.128 mq01
192.168.37.130 mq02
192.168.37.131 mq03
3、yum安裝軟件包
yum install -y epel-release #epel為擴展軟件包
yum install -y rabbitmq-server #rabbitmq軟件包
4、建立軟連接
ln -s /usr/lib/rabbitmq/bin/* /usr/bin/
5、查看插件安裝情況
rabbitmq-plugins list
6、開啟管理服務
rabbitmq-plugins enable rabbitmq_management
7、開啟rabbitmq服務
systemctl start rabbitmq-server.service
netstat -ntap |grep 5672
8、查看各自的群集狀態
rabbitmqctl cluster_status
mq01
mq02
mq03
9、關閉服務,復制配置文件後開啟
systemctl stop rabbitmq-server.service
//隱藏文件,三臺配置一樣,將磁盤節點上的文件內容復制到其他2臺
vim /var/lib/rabbitmq/.erlang.cookie
systemctl start rabbitmq-server.service
++++++以下操作在內存節點上++++++
1、將mq02、mq03內存節點服務器分別加入到磁盤節點
rabbitmqctl stop_app
rabbitmqctl join_cluster --ram rabbit@mq01 #加入到磁盤節點
#ram:以內存節點形式添加,不加磁盤形式
rabbitmqctl cluster_status #驗證集群狀態
mq02
mq03
2、查看mq01磁盤節點服務器的集群狀態
rabbitmqctl cluster_status
++++++rabbit圖形化操作++++++
1、登錄磁盤節點服務器
http://192.168.37.128:15672/ 默認用戶:guest 密碼:guest
2、在磁盤節點服務器上創建策略
name: my_ha
pattern: ^a
Apply to : Exchange and queues
definition: ha-mode all
3、查看策略(三臺服務器同步)
mq01
mq02
mq03
4、在磁盤節點服務器上增加消息隊列
Name: aa
Durabiliy: Durable
Node: rabbit@mq01
Auto delete: No
5、在新建隊列中寫入消息
mode: 2-persistent
headers: a = 123
properties: id=1
payload: hello,world!
6、查看隊列消息
Rabbitmq集群詳解