當前位置：首頁 > 编程资源 > 编程问答 >内容正文

编程问答

RabbitMQ之呕心沥血的总结（图文并茂、万字级别、毕生所学）

發布時間：2024/10/5 编程问答 37 豆豆

生活随笔收集整理的這篇文章主要介紹了 RabbitMQ之呕心沥血的总结（图文并茂、万字级别、毕生所学）小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

文章目錄

一、消息中間件的相關問題
- 1、消息中間件是什么？
- - 1.1、同步詳解
  - 1.2、異步詳解
- 2、為什么要使用消息中間件？
- - 2.1、消息中間件的優點
  - 2.2、異步提升性能分析
  - 2.3、降低耦合度分析
  - 2.4、流量削峰
- 3、協議精講
- 4、消息中間件技術選型
二、RabbitMQ安裝
- 2.1、Erlang的下載安裝
- 2.2、RabbitMQ的下載安裝
- 2.3、查看RabbitMQ是否安裝成功
三、安裝RabbitMQ的web客戶端
- 1、安裝
- 2、權限指令總結
四、Docker安裝RabbitMQ
- 1、Docker的安裝
- 2、Docker安裝RabbitMQ
待寫...........

學習一門中間件技術之前當然要對其進行了解，心中要有相關疑問，帶著問題去學習一門技術，才能把握其重點。從一個問題的引入，慢慢向深層次靠攏。

比如：看到消息中間件這個詞，應該想到的是消息中間件是什么？
然后就去了解消息中間件；之后可能又會有疑問，為什么要引入消息中間件呢？心中無疑問時，或許你已經了解的差不多了
帶著疑問去學習，更能把握技術主干。

一、消息中間件的相關問題

1、消息中間件是什么？

消息中間件是利用高效可靠的消息傳遞機制進行異步的數據傳輸，并基于數據通信進行分布式系統的集成。通過提供消息隊列模型和消息傳遞機制，可以在分布式環境下擴展進程間的通信。

看到官方提供的術語，可能難以理解；可以通過概念中的異步分析，了解消息中間件。有異步當然就有同步這個概念。

消息中間件負責消息的傳遞、存儲、分發，數據的存儲和分發要遵循某種規范（為了不同語言可以進行交互）

1.1、同步詳解

平常我們在做項目時，為了完成業務需求，我們可能需要不同系統間調用接口。

用戶發起請求給系統A，系統A接到請求直接調用系統B，系統B返回結果后，系統A才能返回結果給用戶，這種模式就是同步調用。

從這你就可以看出，同步調用時，系統之間相互依賴；用戶發起請求，相關的系統都要跟著運行，如果一個系統出現了問題，那么整個就over了。

1.2、異步詳解

想必都了解異步是什么意思，發送方和接收方誰也不知道誰；比如發送方只管我發消息了，也不管有沒有接收。相對來說就是相互透明的。（在軟件開發中，透明是看不到的意思）

從這張圖我可以看出，生產者不斷發送消息到消息隊列；消費者不斷從隊列獲取消息，所以生產者只關心消息的發送，消費者只關心獲取消息；輕松實現系統間解耦。

通過異步可以輕松理解消息中間件的實現機制。
簡單了說消息中間件是一個獨立部署的系統，可以實現系統之間的異步調用。

2、為什么要使用消息中間件？

2.1、消息中間件的優點

異步提升性能、降低耦合度、流量削峰

2.2、異步提升性能分析

可以看出不使用消息中間件一共耗時20ms，這樣的串行執行處于一種阻塞狀態，意思是某個系統沒有執行完是不會返回結果的。

如果引入消息中間件之后呢？

一共耗時100ms，異步執行處于非阻塞狀態，即便某個系統需要執行很久，不過不會影響其他系統的執行。

2.3、降低耦合度分析

可以看出如果不使用消息中間件，一旦B系統出現了問題，那么層層結果返回，用戶收到的就是一個異常，然后就需要等著系統修復

使用了消息中間件之后，A系統發送消息到消息中間件之后就會直接返回結果；B系統被工程師修復好之后，重新獲取消息執行未執行的操作就行了。系統之間相互分離，耦合度大大降低。

2.4、流量削峰

如上圖，如果系統B最高以4000QPS的速度查詢數據庫，當系統A中的QPS超過一萬時，此時超過了系統A的最大限值，此時請求全部打到了系統B，此時B是最高以4000QPS的速度查詢數據庫，所以數據庫就會崩潰。

如果使用了消息中間件，系統A的全部請求會累積到消息中間件中，然后系統B根據自己的需求每次從消息中間件中讀取多少請求。

使用消息中間件可以屏蔽不同語言的差異性（簡單了說就是語言之間可以相互通訊，使用消息中間件屏蔽了具體的實現細節）

3、協議精講

消息中間件一般負責數據的傳遞、存儲、分發三個部分；
然后問題來了，假設兩個系統A系統和B系統，采用了不同的語言進行實現；那么怎么進行消息傳遞呢？所以說消息中間件需要遵循某種協議。

另外這個協議一般來說是比較簡單的協議，比如AMQP、Kalfka等
注：不適用http協議，這個協議比較復雜，包含了狀態碼、響應碼、數據加密解密等

4、消息中間件技術選型

1、ActiveMQ：老牌的Apache產品，完全支持JMS規范（JMS定義了Java API層面的標準）
2、Kafka：大數據領域的產品，基于TCP/IP二進制協議，速度非常快，但不支持事務，消息可能丟失、重復、錯誤。
3、RocketMQ：阿里巴巴出品，性能很高，但事務方面沒有開源。
4、RabbitMQ：使用Erlang語言開發的消息隊列系統，基于AMQP協議實現，AMQP的主要特征是面向消息、隊列、路由（包括點對點和發布/訂閱）、可靠性、安全。AMQP協議更多用在企業系統內，對數據一致性、穩定性和可靠性要求很高的場景，對性能和吞吐量的要求還在其次。

作為穩定、流行、開源等綜合性最強的RabbitMQ當然要受到鄙人的關注了

二、RabbitMQ安裝

我用的是阿里云服務器（我絕對不是打廣告的哈😀）
遠程連接工具用的是Xshell，還有文件傳輸工具Xftp

2.1、Erlang的下載安裝

1.下載Erlang的JDK（因為RabbitMQ是使用erlang語言編寫的）

wget https://packages.erlang-solutions.com/erlang-solutions-2.0-1.noarch.rpm

2、解壓Erlang壓縮包

rpm -Uvh erlang-solution-2.0.1.noarch.rpm

3、安裝Erlang

yum install -y erlang

4、查Erlang是否安裝成功

erl -v

2.2、RabbitMQ的下載安裝

1、安裝RabbitMQ依賴的插件socat

yum install -y socat

2、下載RabbitMQ

查看系統版本

lsb_release -a

去官網下載查詢版本

https://www.rabbitmq.com/download.html

右鍵RHEL/Centos 8.x --》復制連接地址

下載RabbitMQ

wget https://github.com/rabbitmq/rabbitmq-server/releases/download/v3.8.14/rabbitmq-server-3.8.14-1.el8.noarch.rpm

3、安裝RabbitMQ

解壓RabbitMQ壓縮包

安裝RabbitMQ

yum install rabbitmq-server -y

2.3、查看RabbitMQ是否安裝成功

1、啟動服務

systemctl start rabbitmq-server

2、查看rabbitmq的狀態

systemctl status rabbitmq-server

出現這個就說明安裝成功了。

三、安裝RabbitMQ的web客戶端

1、安裝

1.1、輸入

rabbitmq-plugins enable rabbitmq_management

1.2、重啟服務

systemctl restart rabbitmq-server

1.3、瀏覽器訪問http://你的ip地址:15672

注意云服務器一定要在安全組中開放15672端口

1.3.1、如果是本地服務器

username：guest
password：guest

1.3.2、如果是遠程服務器需要進行授權

1.3.2.1、新增用戶

rabbitmqctl add_user root root

1.3.2.2、設置用戶權限

rabbitmqctl set_user_tags root administrator

下面的權限是借鑒的網友

management
用戶可以通過AMQP做的任何事外加：
列出自己可以通過AMQP登入的virtual hosts
查看自己的virtual hosts中的queues, exchanges 和 bindings
查看和關閉自己的channels 和 connections
查看有關自己的virtual hosts的“全局”的統計信息，包含其他用戶在這些virtual hosts中的活動。

policymaker
management可以做的任何事外加：
查看、創建和刪除自己的virtual hosts所屬的policies和parameters

monitoring
management可以做的任何事外加：
列出所有virtual hosts，包括他們不能登錄的virtual hosts
查看其他用戶的connections和channels
查看節點級別的數據如clustering和memory使用情況
查看真正的關于所有virtual hosts的全局的統計信息

administrator
policymaker和monitoring可以做的任何事外加:
創建和刪除virtual hosts
查看、創建和刪除users
查看創建和刪除permissions
關閉其他用戶的connection

1.3.3、輸入username：root，password：root登錄控制臺

2、權限指令總結

1、rabbitmqctl add_user 賬號密碼添加用戶

2、rabbitmqctl set_user_tags 賬號權限賦予權限

3、rabbitmqctl change_password Username Newpassword 修改密碼

4、rabbitmqctl delete_user Username 刪除用戶

5、rabbitmqctl list_user 查看所有用戶

6、rabbitmqctl set_permissions -p / Username “.* " ". " ". *” 設置用戶為administrator角色

四、Docker安裝RabbitMQ

1、Docker的安裝

1、更新yum包

yum update

2、安裝軟件包yum-util（提供yum-config-manager功能),還有device-mapper的依賴包

yum install -y yum-utils device-mapper-persistent-data lvm2

3、設置docker倉庫為阿里云

yum-config-manager --add-repo http://mirrors.aliyun.com/docker-ce/linux/centos/docker-ce.repo

4、安裝docker

yum install docker-ce -y

5、查看docker 版本

docker -v

6、配置加速鏡像

vim /etc/docker/daemon.json

修改為如下內容

{
“registry-mirrors”: [“https://registry.docker-cn.com”]
}
systemctl restart docker.service

重啟docker即可

sudo systemctl restart docker

本地Centos7安裝docker步驟：https://blog.csdn.net/Kevinnsm/article/details/111409921

2、Docker安裝RabbitMQ

下載rabbitmq

docker pull rabbitmq

啟動rabbitmq

docker run -d --hostname my-rabbit --name myrabbit -p 15672:15672 -p 5672:5672 rabbitmq

–hostname：指定容器主機名稱
–name：指定容器名稱
-p ：端口映射（docker內部端口和外網端口）

查看鏡像ID

docker ps

安裝rabbitmq客戶端

docker exec -it 鏡像ID /bin/bash //進入容器內部