zoukankan      html  css  js  c++  java
  • 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一样,首先需要启用插件自身以及相应的管理插件。

    [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,如下:

    除此之外,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

  • 相关阅读:
    Linux菜鸟起飞之路【三】Linux常用命令
    Linux菜鸟起飞之路【二】Linux基本常识
    Linux菜鸟起飞之路【一】基本知识与Linux的安装
    交换机和路由器区别
    netdom join more ou
    keepalive.conf配置模板
    mysql7.7.22 Gtid主从搭建
    python 列表处理
    python openpyxl模块使用
    mysql5.7
  • 原文地址:https://www.cnblogs.com/zhjh256/p/6418660.html
Copyright © 2011-2022 走看看