首页 > 代码库 > rabbitmq级联之shovel插件
rabbitmq级联之shovel插件
有时候,由于各方面原因比如安全原因、系统间隔离,我们需要实现在多个rabbitmq实例或者一个rabbitmq实例的多个vhost间推送消息。在上一版的实现中,公司使用java自行实现了一个类似转发器的功能,其结构为:
内部MQ->java-pusher->外部MQ
其中在java-pusher的配置文件里面定义内部MQ和外部MQ各队列之间的映射关系。这样做除了额外的开发和维护成本外,一定程度还增加了系统资源的消耗。最近在测试rabbitmq cluster的各种异常恢复时,发现其提供了一个原生的 实现级联功能的插件shovel,虽然他被归为HA一类,但实际上应该还算不上。
shovel可以在rabbitmq.config中配置,也可以通过web控制台进行配置。
同其他插件比如trace一样,首先需要启用插件自身以及相应的管理插件。
[root@iZ23nn1p4mjZ bin]# rabbitmq-plugins enable rabbitmq_shovel
[root@iZ23nn1p4mjZ bin]# rabbitmq-plugins enable rabbitmq_shovel_management
Plugin configuration unchanged.
Applying plugin configuration to rabbit@iZ23nn1p4mjZ... nothing to do.
启用后在控制台Admin页面就多了两个tab,如下:
后面就是先找几个环境测试下稳定性以及性能。
参考:
https://www.rabbitmq.com/shovel.html#management-status
rabbitmq级联之shovel插件
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。