ActiveMQ 桥接
博客专区 > chaun 的博客 > 博客详情
ActiveMQ 桥接
chaun 发表于3年前
ActiveMQ 桥接
  • 发表于 3年前
  • 阅读 311
  • 收藏 3
  • 点赞 0
  • 评论 0

【腾讯云】新注册用户域名抢购1元起>>>   

1.ActiveMQ 网络桥接

1.1 ActiveMQ传输方式

ActiveMQ 按照通信方式划分:桥接转发和双向通信

1.桥接转发是将消息传递给另外一个ActiveMQBroker

2.双向通信是用一个通道既可以收消息,也可以发消息。

 

 

 

这样推送给Broker1的消息会自动转发给Broker2中,Broker2不需要修改任何设置,只对Broker1做修改即可。

 

1.2Activemq网络桥接配置bin/activemq.xml

<bean id="bridgedBroker" class="org.apache.activemq.broker.BrokerService" init-method="start" destroy-method="stop">  

            <property name="brokerName" value = "bridgedBroker"/>  

            <property name="persistent" value="false"/>  

            <property name="transportConnectorURIs">  

                <list>  

                    <!--消息生产队列-->  

                    <value>tcp://localhost:61616</value>  

                </list>  

            </property>  

            <property name="jmsBridgeConnectors">  

                <list>  

                    <bean class="org.apache.activemq.network.jms.JmsQueueConnector">  

                        <property name="outboundQueueConnectionFactory">  

                            <bean class="org.apache.activemq.ActiveMQConnectionFactory">  

                                <!--消费者队列地址-->  

                                <property name="brokerURL" value="tcp://10.1.230.200:61616" />  

                            </bean>  

                        </property>  

                        <property name="outboundQueueBridges">  

                            <list>  

                                <bean class="org.apache.activemq.network.jms.OutboundQueueBridge">  

    <!--只转发该消息队列-->

                                    <constructor-arg value="messages.input"/>  

                                </bean>  

                            </list>  

                        </property>  

                    </bean>  

                </list>  

            </property>  

        </bean>  

1.3实例

场景:

本机ActiveMQ启动后,创建后队列,然后点击 Send TO 发送10条消息到该队列。

 


 

 

第三方队列启动后默认空。

 

我们对第一个MQ发送消息后,应该通过我们配置好的地址,对消息进行转发。这样第二个MQ应该接到10条转发过来的消息。

 

 

版权声明:本文为博主原创文章,未经博主允许不得转载。

  • 打赏
  • 点赞
  • 收藏
  • 分享
共有 人打赏支持
粉丝 84
博文 261
码字总数 96133
×
chaun
如果觉得我的文章对您有用,请随意打赏。您的支持将鼓励我继续创作!
* 金额(元)
¥1 ¥5 ¥10 ¥20 其他金额
打赏人
留言
* 支付类型
微信扫码支付
打赏金额:
已支付成功
打赏金额: