文档章节

ActiveMQ 桥接

chaun
 chaun
发布于 2015/08/17 16:22
字数 325
阅读 317
收藏 3

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条转发过来的消息。

 

 

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

本文转载自:http://blog.csdn.net/gaodml/article/details/44832029

共有 人打赏支持
chaun
粉丝 91
博文 269
码字总数 91059
作品 0
深圳
高级程序员
私信 提问
JBoss WildFly 7 连接到 ActiveMQ 5.9

我们最近发现大量的客户都有一个同样的问题:在运行于JBoss Wildfly 7中的HornetQ JMS实现和独立运行的ActiveMQ服务器之间,如何才能建立一个桥接。ActiveMQ作为一个独立运行的消息代理(mes...

oschina
2014/07/17
2.4K
4
Ubuntu下安装ActiveMQ

主要参考http://www.jmkg.co.uk/2010/08/31/installing-activemq-on-ubuntu/,略有补充 1. 下载安装包,建立activemq用户,安装 下载最新的activemq,写此文时为5.7。 cd /opt/tar xvzf xxx...

RuralHunter
2013/01/22
0
0
ActiveMQ集群方案(上)

版权声明:欢迎转载,但是看在我辛勤劳动的份上,请注明来源:http://blog.csdn.net/yinwenjie(未经允许严禁用于商业用途!) https://blog.csdn.net/yinwenjie/article/details/51124749 目...

yunlielai
04/15
0
0
Win7环境下安装ActiveMQ

参考ActiveMQ官方文档:http://activemq.apache.org/getting-started.html 安装ActiveMQ 近来要学习JMS,在网上查了些资料,发现ActiveMQ是比较流行的JMS开源框架,决定使用ActiveMQ来学习J...

纠结名字
2015/08/09
0
0
JMS配置说明-----activeMQ-5.6

1 简介 activeMQ是一个完全支持JMS1.1 和J2EE规范的JMS Provider实现; 尽管规范出台已经是很久的事情了,但JMS在当今的J2EE应用中仍然扮演着特殊的地位; 特性列表 多种语言和协议编写客户端...

次渠龙哥
06/26
0
0

没有更多内容

加载失败,请刷新页面

加载更多

Java提高班(六)反射和动态代理(JDK Proxy和Cglib)

反射和动态代理放有一定的相关性,但单纯的说动态代理是由反射机制实现的,其实是不够全面不准确的,动态代理是一种功能行为,而它的实现方法有很多。要怎么理解以上这句话,请看下文。 一、...

王磊的博客
18分钟前
1
0
Ext grid 渲染

// 单元格字体颜色渲染function renderer_Meta_useStatus(value, cellmeta, record,rowIndex, columnIndex, store){ var color = ""; if("空闲"==value){ color = "green";......

MoksMo
27分钟前
4
0
log4j2在spring中的配置

<?xml version="1.0" encoding="UTF-8"?><!--日志级别以及优先级排序: OFF > FATAL > ERROR > WARN > INFO > DEBUG > TRACE > ALL --><!--Configuration后面的status,这个用于设置l......

TonyTaotao
33分钟前
3
0
java 中间变量缓存机制(i++,++i)

public class Test { public static void main(String[] args) { int i = 0; i = i ++ ; System.out.println(i); } } 答案是 0 如果是 i = ++......

shzwork
40分钟前
5
0
初识多线程及其原理-笔记

什么情况下应该使用多线程? 通过并行计算提高程序执行性能 需要等待网络、I/O响应导致耗费大量的执行时间, 可以采用异步线程的方式来减少阻塞 tomcat7 以前的io模型 客户端阻塞 线程级别阻...

Java搬砖工程师
51分钟前
2
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部