目錄
- 1.首先說一下什么是MQ
- 1.1為什么要用MQ/MQ有什么用
- 1.1.1流量消峰
- 1.1.2應用解耦
- 1.1.3異步處理
- 2.安裝RabbitMq
- 2.1首先拉取鏡像
- 2.2啟動鏡像
- 2.3啟動 rabbitmq_management (RabbitMQ后臺管理)
- 2.3.1打開RabbitMQweb界面
- 3.插件下載并安裝
- 安裝完成后用工具將插件文件上傳到服務器上
我這個安裝攻略首先得保證服務器上安裝過docker了 如果沒安裝docker請先去安裝docker
1.首先說一下什么是MQ
MQ(message queue)字面意思上來說消息隊列，FIFO先入先出，隊列中存入的內容是message，是一種跨進程的通信機制，用于上下游傳遞消息。MQ 是一種非常常見的上下游“邏輯解耦+物理解耦”的消息通信服務。使用了 MQ 之后，消息發送上游只需要依賴 MQ，不用依賴其他服務。
1.1為什么要用MQ/MQ有什么用
1.1.1流量消峰
比如說訂單系統最多一次可以處理一萬次訂單,這個處理能力在正常時段下單時綽綽有余,但是在高峰期時如果有兩萬次下單操作系統是處理不了的只能限制訂單超過一萬次后不允許用戶下單，但是如果使用消息隊列做緩沖，我們可以取消這個限制，把一米內的訂單分散成一段時間來處理，這個時候有些用戶可能在下單十幾秒后才能收到下單成功消息 但是這樣總比不能讓用戶下單體驗好
1.1.2應用解耦
以電商應用為例，應用中有訂單系統、庫存系統、物流系統、支付系統。用戶創建訂單后，如果耦合調用庫存系統、物流系統、支付系統，任何一個子系統出了故障，都會造成下單操作異常。當轉變成基于消息隊列的方式后，系統間調用的問題會減少很多，比如物流系統因為發生故障，需要幾分鐘來修復。在這幾分鐘的時間里，物流系統要處理的內存被緩存在消息隊列中，用戶的下單操作可以正常完成。當物流系統恢復后，繼續處理訂單信息即可，中單用戶感受不到物流系統的故障，提升系統的可用性
1.1.3異步處理
有些服務間調用是異步的，例如 A 調用 B，B 需要花費很長時間執行，但是 A 需要知道 B 什么時候可以執行完，一般有兩種方式，A 過一段時間去調用 B 的查詢 api 查詢。或者 A 提供一個 callbackB 執行完之后調用 api 通知 A 服務。這兩種方式都不是很優雅，使用消息總線，可以很方便解決這個問題，A 調用 B 服務后，只需要監聽 B 處理完成的消息，當 B 處理完成后，會發送一條消息給 MQ，MQ 會將此消息轉發給 A 服務。這樣 A 服務既不用循環調用 B 的查詢 api，也不用提供 callback同樣 B 服務也不用做這些操作。A 服務還能及時的得到異步處理成功的消息。
2.安裝RabbitMq
接下來使用docker進行RabbitMQ的安裝
2.1首先拉取鏡像
直接拉取鏡像的話默認拉取最新的版本
docker pull rabbitmq:management
2.2啟動鏡像
注意修改用戶名和密碼
docker run -d -p 15672:15672 -p 5672:5672 \ -e RABBITMQ_DEFAULT_VHOST=my_vhost \ -e RABBITMQ_DEFAULT_USER=admin \ -e RABBITMQ_DEFAULT_PASS=admin \ --hostname myRabbit \ --name rabbitmq \ rabbitmq
參數說明:
- -d：表示在后臺運行容器；
- -p：將容器的端口 5672（應用訪問端口）和 15672 （控制臺Web端口號）映射到主機中；
- -e：指定環境變量：
- RABBITMQ_DEFAULT_VHOST：默認虛擬機名；
- RABBITMQ_DEFAULT_USER：默認的用戶名；
- RABBITMQ_DEFAULT_PASS：默認的用戶密碼；
- –hostname：指定主機名（RabbitMQ 的一個重要注意事項是它根據所謂的 節點名稱 存儲數據，默認為主機名）；
- –name rabbitmq：設置容器名稱；
- rabbitmq：容器使用的鏡像名稱；
啟動完成后可以通過 docker ps 命令來查看容器是否啟動
還可以設置docker啟動時自動啟動
docker update rabbitmq --restart=always
2.3啟動 rabbitmq_management (RabbitMQ后臺管理)
//進入容器內部 我這里使用容器名字進入 也可以使用容器id docker exec -it rabbitmq /bin/bash ---------------------------------- //開啟web后臺管理界面 rabbitmq-plugins enable rabbitmq_management
2.3.1打開RabbitMQweb界面
- 瀏覽器輸入地址 hhtp://ip:15672 即可訪問后臺管理界面 這里的ip為運行RabbitMQ的服務器ip
- 默認的用戶名和密碼都是guest
- 但由于我們啟動的時候設置了默認的用戶名和密碼，所以我們可以使用設置的用戶名和密碼登錄。
如果無法訪問 可以嘗試打開防火墻 如果是在阿里或者騰訊之類的服務器 要打開安全組的端口！！
到這里 我們docker安裝RabbitMQ就完成了 接下來進行延遲插件的安裝
3.插件下載并安裝
下載地址 https://www.rabbitmq.com/community-plugins.html
進入web端后左上角有顯示當前安裝的RabbitMQ版本
我這里安裝的是3.10版本所以我直接下載最新版的插件就可以
安裝完成后用工具將插件文件上傳到服務器上
將剛剛上傳的插件拷貝到容器內plugins目錄下
docker cp /root/rabbitmq_delayed_message_exchange-3.10.2.ez rabbitmq:/plugins
上傳之后進入容器內部
//進入容器 我這里使用容器名字 也可以用容器id進入 docker exec -it rabbitmq /bin/bash ------------------------------------- //移動到plugins目錄下 cd plugins ------------------------------------- //查看是否上傳成功 ls
然后我們啟動插件
rabbitmq-plugins enable rabbitmq_delayed_message_exchange
安裝成功后 退出容器
exit
然后重啟容器
//我這里還是使用容器名稱 也可以使用容器id docker restart rabbitmq
容器啟動成功之后，登錄RabbitMQ的管理界面（ip:15672 訪問web界面），找到ExchangesTab頁。點擊Add a new exchange，在Type里面查看是否有x-delayed-message選項，如果存在就代表插件安裝成功。
到這里我們的docker 安裝RabbitMQ及延遲插件的安裝就已經結束了！！
