rabbitmq级联之shovel插件和exchange.bind

清风听雨

　　有时候，由于各方面原因比如安全原因、系统间隔离，我们需要实现在多个rabbitmq实例或者一个rabbitmq实例的多个vhost间推送消息。在上一版的实现中，公司使用java自行实现了一个类似转发器的功能，其结构为：
　　内部MQ->java-pusher->外部MQ
　　其中在java-pusher的配置文件里面定义内部MQ和外部MQ各队列之间的映射关系。这样做除了额外的开发和维护成本外，一定程度还增加了系统资源的消耗。最近在测试rabbitmq cluster的各种异常恢复时，发现其提供了一个原生的 实现级联功能的插件shovel，虽然他被归为HA一类，但实际上应该还算不上。
　　shovel可以在rabbitmq.config中配置，也可以通过web控制台进行配置。
　　同其他插件比如trace一样，首先需要启用插件自身以及相应的管理插件。

[iyunv@iZ23nn1p4mjZ bin]# rabbitmq-plugins enable rabbitmq_shovel
　　[iyunv@iZ23nn1p4mjZ bin]# rabbitmq-plugins enable rabbitmq_shovel_management
   Plugin configuration unchanged.
　　Applying plugin configuration to rabbit@iZ23nn1p4mjZ... nothing to do.
　　启用后在控制台Admin页面就多了两个tab，如下：

　　除此之外，rabbitmq还支持exchange 2 exchange的绑定，这样可以在不引入shovel的前提下，实现更为灵活的路由策略，如下：

　　java中绑定：



Channel ch = conn.createChannel();
ch.exchangeBind("destinationExch", "sourceExch", "routingKey");
　　此时，消费者得到的exchange仍然是发布时的exchange，后需经过的exhange不会修改原始exhcange。
　　不过，要是用的是rpc模式，就不知道shovel是什么结果了。
　　参考：
　　https://www.rabbitmq.com/shovel.html#management-status
　　http://www.rabbitmq.com/blog/2010/10/19/exchange-to-exchange-bindings/
　　https://www.zhihu.com/question/41976893
　　https://www.rabbitmq.com/shovel.html