前言

公司的RabbitMQ集群要升級最新穩定版本，升級方案：新搭建一套集群，將數據遷移到新的集群，應用連接到新的集群。

因為系統可以接受短暫停機時間，所以采用Shovel插件將舊集群的數據遷移到新集群。經過分析，需要遷移的數據主要有兩種：

隊列中積壓的消息；
延遲隊列的消息；

安裝插件

啟動插件

在新集群中的每一臺服務器上，執行以下命令啟動shovel插件：

rabbitmq-plugins enable rabbitmq_shovel
rabbitmq-plugins enable rabbitmq_shovel_management

驗證插件

進入管理界面的Admin頁簽下面，檢查是否有如下2個菜單，如有說明啟動成功。

配置

以下操作，通過rabbitMQ的管理界面進行操作。

創建exchange&queue（舊集群）

1、創建交換器exchange：

Name：shovel_demo_exchange
Arguments：x-delayed-type:direct

2、創建隊列queue：

Name：shovel_demo_queue

3、綁定路由bind：

To queue：shovel_demo_queue
Routing Key:shovel_demo_queue_routingKey

如上圖所示，輸入剛才創建的shovel_demo_exchange，按回車過濾查詢，然后點擊列表中的名稱鏈接，進入下圖的詳細界面：

創建exchange&queue（新集群）

創建方法及名稱跟舊集群一模一樣，全部名稱和配置都要一樣。

舊集群中發送消息

1、進入發送界面：

2、輸入信息發送：

3、發送完成提示：

4、重復上面的操作，再發送2條消息，總共有3條消息。

5、查看積壓的消息：

遷移數據

新集群創建shovel連接

1、打開新集群的管理界面，進入Admin頁簽，點擊Shovel Management菜單，按以下方式增加一個shovel：

queue：shovel_demo_queue
URI格式：amqp://user:password@server-name/my-vhost
Source URI：amqp://zat:zat123@10.0.101.5/zat          #舊集群URI，IP要改
Destination URI：amqp://zat:zat123@10.0.104.5/zat    #U集群URI，IP要改

2、新增成功界面：

3、檢查狀態是否正常：

注：shovel是針對queue（隊列）來操作的，有多少個隊列要遷移數據，就要創建多少個對應的shovel。

驗證

shovel創建好后，如果檢查狀態正常的話，它會自動進行遷移數據。現在我們來檢查舊集群shovel_demo_queue隊列的數據是否移到到新集群中。

1、在新集群中通過以下界面查看：

2、在舊集群中通過以下界面查看：

引用：

https://www.rabbitmq.com/shovel.html
https://www.rabbitmq.com/shovel-dynamic.html

總結

以上是生活随笔為你收集整理的RabbitMQ——使用Shovel插件迁移数据的全部內容，希望文章能夠幫你解決所遇到的問題。

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