JMS ActiveMQ学习（一） - JAVA

这是本人第一次发表个人使用ActiveMq，如有错误，请指出。只为与众人共享我的心得。

activeMq是一个开源的支持JMS的框架：

一、特性及优势

1、实现JMS1.1规范，支持J2EE1.4以上

2、可运行于任何jvm和大部分web容器（ActiveMQ works great in any JVM）

3、支持多种语言客户端（java, C, C++, AJAX, ACTIONSCRIPT等等）

4、支持多种协议（stomp，openwire，REST）

5、良好的spring支持（ActiveMQ has great Spring Support）

6、速度很快，JBossMQ的十倍（ActiveMQ is very fast; often 10x faster than JBossMQ.）

7、与OpenJMS、JbossMQ等开源jms provider相比，ActiveMQ有Apache的支持，持续发展的优势明显。

二、下载安装

1、下载

在这个页面里有你所需要的各个版本，我用的是最新的版本-ActiveMQ 5.6.0。

2、安装
直接解压至任意目录（如：d:\ apache-activemq-5.1.0），但是我用的时候是解压到D盘的根目录下，我建议各位也这样，不用对它的一些bat进行修改。

3、启动ActiveMQ服务器

直接运行bin\activemq.bat

4、打开主页后，你可以看到activeMq中带的一些实例

三、详细实例

将tomcat和activeMq整合在一起做的一个发送接受的发布订阅的例子（我用的是tomcat6.0，activeMq5.6.0）：

首先整合tomcat和activeMq：

1、准备jar包：

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

activemq-core-5.6.0.jar

activemq-web-5.6.0.jar

geronimo-j2ee-management_1.1_spec-1.0.1.jar

geronimo-jms_1.1_spec-1.1.1.jar

geronimo-jta_1.0.1B_spec-1.0.1.jar

2、修改配置文件：

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

在节点中添加以下内容：

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&maxReconnectAttempts=5"

brokerName="localhost"

useEmbeddedBroker="false"/>

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"/>

auth="Container"

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

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

physicalName="MY.TEST.FOO"/>

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&maxReconnectAttempts=5

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

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

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

2.2 在Myeclipse中新建一个jms-test的web工程

在src下，新建一个包com.flvcd.servlet （我想这个你应该会吧，如果不会，我只能说，你不合适干）

JMS ActiveMQ学习（一）(一)