场景

现在有Rabbitmq普通模式架构服务A和服务B ，由于业务需要，要求把服务A上mq的数据迁移到服务B上，rabbitmq的数据包括元数据（RabbitMQ用户、vhost、队列、交换和绑定）和消息数据，而消息数据存储在单独的消息存储库中。

操作步骤一共三步

• 1. 元数据备份和还原
• 2. 消息数据备份&还原
• 3. 核验

普通模式的数据迁移，请先定位到 服务A&服务B的 主节点；

这里以 docker-compose 部署的为服务A
172.16.123.111:5672、172.16.123.112:5672、172.16.123.113:5672

CNCP管理台页面快速构建的rabbitmq为服务B
172.16.123.52:5672、172.16.123.53:5672、172.16.123.54:5672

操作

步骤一 元数据备份和还原

1、操作
在服务B上搭建rabbitmq服务 (这里是在CNCP的管理台页面新建一个rabbitmq)

元数据迁移，登录 UI 管理界面，默认为 ip:15672, 选择 Export definitions，download 元数据信息 json文件，然后在新的集群上选择 Import definitions，upload 上传元数据信息(注意队列可能在不同节点的情况)

2、登陆服务A导出元数据

image.png

3、登陆服务B导入上面导出的元数据

image.png

4、验证数据
刷新页面，查看元数据 等信息是否存在

步骤二 消息数据备份&还原

这里的实现方案是用的 rabbitmq 的 Shovel 插件

1.为什么需要使用 shovel 插件？
答：当业务需要可靠且连续地将消息从一个 broker 的 queue 里搬运（转发）到另一个 broker 的 exchange 时（最终达到某个 queue 里 ）使用；作为 source 的 queue 和作为 destination 的 exchange 可以位于同一个 broker 上（通常要求处于不同的 vhost 下），也可以位于不同的 broker 上。
2.使用 shovel 插件的好处？
答：shovel 基于 RabbitMQ 的 Erlang 客户端实现，且作为 built-in 插件被使用，故可以随 broker 的启动而自动启动；shovel 具有松耦合特性：通过该插件可以在分属不同管理域下的 broker 或 cluster 之间进行消息的搬运；shovel 具有 WAN 友好特性：基于 AMQP 0-9-1 协议实现，并设计成能够保证在不稳定网络场景下不丢失消息；shovel 具有高度可定制性：允许在 shovel 建立连接后，立即执行指定的 AMQP 方法进行定制化操作（例如声明 queue 的动作）；

注意：因为 docker-compose 之前给到用户的版本并没有默认开启，本次消息数据迁移所依赖的文件，这里需要先开启插件

1. 开启服务A 的两个插件 rabbitmq_shovel & rabbitmq_shovel_management

# 创建一个插件配置文件 
vi /tmp/rabbitmq-db-2/etc/enabled_plugins
# 写入内容
[rabbitmq_management,rabbitmq_prometheus,rabbitmq_shovel,rabbitmq_shovel_management].

# 修改 docker-compose.yaml 添加一行 volumes
vi /root/rabbitmq_cluster/rabbitmq/rabbitmq03/docker-compose.yaml
# 添加一行 
- /tmp/rabbitmq-db-2/etc:/rabbitmq_server-3.8.5/etc/rabbitmq

image.png

# 进入指定目录停止 rabbitmq ,执行 
docker-compose down
# 进入指定目录启动 rabbitmq ,执行 
docker-compose up

注 上面开启插件那么复杂的原因是，笔者在 docker 内重启 rabbitmq 失败，无奈之下通过修改挂初始化插件的方式，重启 docker-compose，如果操作者可以在 rabbitmq-plugins enable rabbitmq_shovel & rabbitmq-plugins enable rabbitmq_shovel_management 后可以重启rabbtimq 那就不用上面那么复杂的又是挂卷又是重启docker

登陆服务A 的UI界面 新增插件如下

image.png

2. 配置插件
   登陆UI -> admin -> Shovel Management -> Add a new shovel

配置 数据源 & 数据目标

image.png

注：这里的适用于我们平台的 url 格式为 amqp://user:password@server-name/my-vhost
connect to server-name, with credentials and overridden virtual host
例如 amqp://rmq:rmq123@172.16.123.111:5672

6. 效果

   
   
   image.png

步骤三 核验

笔者使用 postman 发送200个消息到 rabbitmq，会发现服务A中消息都为0，查看服务B，发现服务B新增了200条消息，即数据实时迁移成功；

image.png

image.png

结束

当服务A 不再接受业务后，可以彻底停止 服务A;

注意：上诉动作中，因为是不停服操作，需要和用户核验 元数据是否增加。以免反复同步 元数据。以及新增 shovel。