RabbitMq（5）Shovel

Shovel可以持续可靠的从源端队列（或交换器）获取消息并转发到目的端队列（或交换器）。远端队列和目的断队列可以位于同一个broker中（不同vhost）或者位于不同的broker中。
Shovel的优势在于：

松耦合：Shovel可以移动不同管理域中Broker上的消息，这些Broker可以有不同的用户和vhost，可以运行在不同版本的RabbitMq和Erlang上。
支持WAN：Shovel可以容忍时断时续的联通情形，并且可以保证消息的可靠性。
高度定制：当Shovel连接成功后，可以对其进行配置通过AMQP命令。

一、Shovel的使用

首先在单机上启动了两个RabbitMq节点rabbitmq1@hadoop和rabbitmq2@hadoop，来作为源端与目的端。

（1）开始Shovel插件功能

Shovel插件开启后，web管理界面会出现Shovel Status和Shovel Management两个菜单。

（2）在rabbitmq2@hadoop上定义一个Shovel

其中src-uri和src-queue指定了源端的uri和源端队列，dest-uri和dest-queue指定了目的端uri和目的端队列。如果源队列和目的队列不存在，会自动创建。Shovel创建完成后如下图所示：

消息的流转如下图所示，看似消息直接有Shovel转发到了dest_queue，实际上中间经过了默认交换器的转发。

除了源端队列，目的段队列外，还有源端队列，目的端交换器和源端交换器，目的端浇交换器两种情况。

源端队列、目的端交换器

源端交换器，目的端交换器

二、参数说明

在定义Shovel时，会使用到各项参数，以下是各个参数的介绍。
Shovel

reconnect-delay：当Shovel连接断开后，等待重连的秒数，默认为1。
ack-mode：用于设置Shovel的消息确认模式。当设置为on-confirm时，消息被目的端成功接收后向源端发送确认消息，on-confirm可以处理由于网络异常和节点宕机造成消息丢失的；当设置为on-publish时，消息从源端被获取转发后，向源端发送确认消息，on-publish只能处理由于网络异常造成的消息丢失；当设置no-ack时，不会发送确认消息。默认on-confirm。
src-protocol：指定源端使用的AMQP协议，只能设置AMQP091和AMQP10，默认为AMQP091。
dest-protocol：设置目的端AMQP协议，同src-protocol。

AMQP 0.9.1 源端

src-uri：用于指定源端的AMQP URI，必须的。该参数值可以为一个字符串或者字符列表，当为字符列表时，Shovel随机从列表中选取一个URI，字符列表用于集群情况，不建议使用不同集群中节点的uri。
src-queue：指定源端queue。src-queue和src-exchange被要求必须设置一个，但不要求都设置。如果源端queue不存在，Shovel将自动创建一个durable的queue。
src-exchange：指定源端exchange。src-exchange和src-queue被要求必须设置一个，但不要求都设置。Shovel在从源端获取消息前，会声明一个exclusive的queue并使用src-exchange-key属性值绑定该源端exchange。如果源端exchange不存在并不会被创建，并且Shovel设置失败。
src-exchange-key：当设置src-exchange时所需的路由key。
src-prefetch-count：源端被转发的未确认消息的数量，默认为1000。
src-delete-after：用于确定是否删除自身。当为never时，表示从不删除；当设置为queue-length，启动时会检测queue的长度，消息被全部转发后，queue被删除；当被设置为其他整数，Shovel会转发该数量的消息后删除queue。

AMQP 0.9.1 目的端

dest-uri：指定目的端AMQP URI。强制的，同src-uri。
dest-queue：指定目的端queue，dest-queue和dest-exchange可以被设置一个，但不要求都设置，如果两者都没有被设置，消息会基于消息原始的exchange和路由key被投递。如果目的端queue不存在会被Shovel自动创建一个durable的queue。
dest-exchange：目的端exchange，dest-exchange和dest-queue可以被设置一个，但不要求都设置。如果目的端exchange不存才不会被创建，并且Shovel设置失败。
dest-exchange-key：当设置dest-exchange时所需的路由key，如果该属性没有被设置，使用消息原始的路由key。
dest-publish-properties：用于改写被Shovel的消息的属性的设置，针对header的设置暂不支持，默认为{}。
dest-add-forward-header：为Shovel的消息添加x-shovelled header属性，表示消息从哪里被Shovel哪里。
dest-add-timestamp-header：为Shovel的消息添加x-shovelled-timestamp header属性，表示消息Shovel转发的时间戳。