技術文章 » docker安裝RabbitMQ及安裝延遲外掛

docker安裝RabbitMQ及安裝延遲外掛

2022-06-05 06:00:59

我這個安裝攻略首先得保證伺服器上安裝過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介面

  1. 瀏覽器輸入地址 hhtp://ip:15672 即可存取後臺管理介面 這裡的ip為執行RabbitMQ的伺服器ip
  2. 預設的使用者名稱和密碼都是guest
  3. 但由於我們啟動的時候設定了預設的使用者名稱和密碼，所以我們可以使用設定的使用者名稱和密碼登入。

    如果無法存取 可以嘗試開啟防火牆 如果是在阿里或者騰訊之類的伺服器 要開啟安全組的埠！！
    到這裡 我們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及延遲外掛的安裝就已經結束了！！