Apache ActiveMQ教程（四）

七、ActiveMQ与Tomcat整合

说明：Tomcat示例版本6.0.14，其它版本在配置上可能有一些差异

1、准备jar包：

将ActiveMQ lib目录下的5个jar包复制到Tomcat lib目录下：

activemq-core-5.1.0.jar

activemq-web-5.1.0.jar

geronimo-j2ee-management_1.0_spec-1.0.jar

geronimo-jms_1.1_spec-1.1.1.jar

geronimo-jta_1.0.1B_spec-1.0.1.jar

2、修改配置文件：

2.1 修改Tomcat的conf/context.xml文件：

   在<context></context>节点中添加以下内容：

 

<Resource

    name="jms/FailoverConnectionFactory"

    auth="Container"

    type="org.apache.activemq.ActiveMQConnectionFactory"

    description="JMS Connection Factory"

    factory="org.apache.activemq.jndi.JNDIReferenceFactory"

    brokerURL="failover:(tcp://localhost:61616)?initialReconnectDelay=100&amp;maxReconnectAttempts=5"

   brokerName="localhost"

    useEmbeddedBroker="false"/>

 

<Resource

    name="jms/NormalConnectionFactory"

    auth="Container"

    type="org.apache.activemq.ActiveMQConnectionFactory"

    description="JMS Connection Factory"

    factory="org.apache.activemq.jndi.JNDIReferenceFactory"

    brokerURL="tcp://localhost:61616"

   brokerName="localhost"

    useEmbeddedBroker="false"/>

 

<Resource name="jms/topic/MyTopic"

    auth="Container"

    type="org.apache.activemq.command.ActiveMQTopic"

    factory="org.apache.activemq.jndi.JNDIReferenceFactory"

    physicalName="MY.TEST.FOO"/>

   

<Resource name="jms/queue/MyQueue"

    auth="Container"

    type="org.apache.activemq.command.ActiveMQQueue"

    factory="org.apache.activemq.jndi.JNDIReferenceFactory"

    physicalName="MY.TEST.FOO.QUEUE"/> 配置说明：以JNDI的方式定义了ActiveMQ的broker连接url、Topic和Queue。

 

 

 

 

此处需加以注意的是Listener端的borkerURL使用了failover传输方式：

failover:(tcp://localhost:61616)?initialReconnectDelay=100&amp;maxReconnectAttempts=5

客户端使用普通传输方式：tcp://localhost:61616

failover transport是一种重新连接机制，用于建立可靠的传输。此处配置的是一旦ActiveMQ broker中断，Listener端将每隔100ms自动尝试连接，直至成功连接或重试5次连接失败为止。

failover还支持多个borker同时提供服务，实现负载均衡的同时可增加系统容错性，格式：
failover:(uri1,...,uriN)?transportOptions

分享到：

Apache ActiveMQ教程（五） | Apache ActiveMQ教程（三）

• 2008-08-27 13:38
• 浏览 20950
• 评论(5)
• 查看更多

评论

5 楼 linliangyi2007 2009-11-12  

顺便问一下楼主 useEmbeddedBroker 属性干啥用的？貌似我设置了true/false ，没发现啥不同的。

还有brokerName，这个名字也可以随便设置，是否跟服务端(broker)一致都可以，都能连上，怪怪的。

4 楼 linliangyi2007 2009-11-12  

引用

此处需加以注意的是Listener端的borkerURL使用了failover传输方式：

failover:(tcp://localhost:61616)?initialReconnectDelay=100&amp;maxReconnectAttempts=5

客户端使用普通传输方式：tcp://localhost:61616

请教楼主，你这里说的“listener端的broker使用failover，客户端使用普通”，如何理解listener呢？
我目前也刚开始研究，个人以为上述两种配置是客户端的不同形式，一个支持失效转移一个是固定IP，不知道我理解的对不对。

3 楼 fys124974704 2009-06-17  

按照楼主的配置，我能成功！不知道为什么2L 说不能？

2 楼 hszhl 2008-09-15  

按你讲的配置 是不行的

1 楼 hszhl 2008-09-15  

按的说的不行