1.ActiveMQ 网络桥接
1.1 ActiveMQ传输方式
ActiveMQ 按照通信方式划分：桥接转发和双向通信
1.桥接转发是将消息传递给另外一个ActiveMQ的Broker。
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条转发过来的消息。
版权声明：本文为博主原创文章，未经博主允许不得转载。