官网参考：https://www.rabbitmq.com/shovel.html

概述

Shovel 可以实现在两个 rabbitmq之间进行消息的远程复制。
利用该组件，可以实现如下业务场景：

• 内外网之间的消息传输
• 多个消息节点之间的消息传输
• 消息远程异地传输。

启用Shovel插件

• 启用Shovel插件

cmd 下运行

rem 启用Shovel插件
rabbitmq-plugins enable rabbitmq_shovel

• 启用Shovel管理插件

rem  启用Shovel管理插件
rabbitmq-plugins enable rabbitmq_shovel_management

• 在Docker下，启用 Shovel插件

在Docker下启动rabbitmq容器，并通过--name 指定容器名字为rabbitmq1

docker run -d --name rabbitmq1 -p 5672:5672 -p 8088:15672  rabbitmq:3.7.17-management

进入容器

docker exec -it rabbitmq1 bash

成功进入容器的界面如下图所示：

image.png

在容器中，输入启用插件的命令即可，如下图所示：

image.png

如果成功启用，登录WEB管理控制台，将看到如下内容：

image.png

Shovel配置概述

定义shovels有两种方式

1. 静态方式（通过配置文件定义），配置完成后需要重启。
2. 动态方式（通过broker的运行时参数），可以随时配置，不需要重启：可以使用rabbitmqctl 的 REST API设置参数，或通过WEB管理UI进行配置（要求启用Shovel管理插件）

Shovel实战

• 创建Docker桥接 网络

要实现多个rabbitmq节点远程连接，要求多个节点的网络能连通。
Docker支持多种网络方式，这里使用桥接网络方式。
在桥接方式下，两个容器节点可以互通。

#创建名为net4rabbitmq的桥接网络
docker network create net4rabbitmq

• 使用DOCKER运行两个rabbitmq实例

运行两个rabbitmq实例，并添加到之前创建的net4rabbitmq桥接网络

docker run -d  --name rabbitmq1 -p 5672:5672 -p 8088:15672 --network net4rabbitmq --network-alias rmq1 rabbitmq:3.7.17-management
docker run -d  --name rabbitmq2 -p 5673:5672 -p 8089:15672 --network net4rabbitmq --network-alias rmq2 rabbitmq:3.7.17-management

--name参数指定了容器名称
-network 参数指定了桥接网络
--network-alias 指定了网络别名（容器之间可以通过网络别名访问）

• 启用Shovel插件

分别针对两个docker实例，启用Shovel插件

docker exec rabbitmq1 bash -c "rabbitmq-plugins enable rabbitmq_shovel"
docker exec rabbitmq1 bash -c "rabbitmq-plugins enable rabbitmq_shovel_management"
docker exec rabbitmq2 bash -c "rabbitmq-plugins enable rabbitmq_shovel"
docker exec rabbitmq2 bash -c "rabbitmq-plugins enable rabbitmq_shovel_management"

• 第二次启动容器实例如下：
  使用这种方式启动时，如果之前已启用Shovel插件，则不需要再次启用

docker start rabbitmq1
docker start rabbitmq2

• 配置 Shovel （动态方式）

Shovel可以配置在源节点，也可以配置在目标节点。
下面的示例将在目标节点上进行配置：在rabbitmq2上配置一个shovel，实现将rabbitmq1
上的队列 Q，复制到rabbitmq2的Q队列
进入rabbitmq2的WEB管理控制台，进入Shovel Management，添加一个 shovel，界面如下图所示：

image.png

添加后的界面：

image.png

可以通过Shovel Status查看shovel状态，如下图：

image.png

• 测试结果

• 测试1
  向rabbitmq1节点的Q队列，放入一个消息。
  会看到，该消息自动转发到了rabbitmq2节点的Q队列。
• 测试2
  先将rabbitmq2节点停止
  向rabbitmq1节点的Q队列，放入一个消息。（这时该消息一直停留在该队列中）
  重启rabbitmq2节点，这时rabbitmq1节点的消息自动 转发到了rabbitmq2节点上。

问题诊断

• 查看日志

#查看容器rabbitmq1的日志
docker logs -f rabbitmq1

• 网络连通测试ping

安装ping命令的方法，安装后即可使用ping

docker exec -it rabbitmq1 /bin/bash
apt-get update
apt-get install iputils-ping

ping rmq2
ping rabbitmq2
ping 容器IP