当前位置:编程学习 > JAVA >>

JMS ActiveMQ学习(一)

      这是本人第一次发表个人使用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文件:

                      在<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&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&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 (我想这个你应该会吧,如果不会,我只能说,你不合适干)

              然后在修改web.xml,在里面加上:

<servlet>

<servlet-name>jms-listener</servlet-name>

<servlet-class>

com.flvcd.servlet.JMSListener

</servlet-class>

<load-on-startup>1</load-on-startup>

</servlet>

          

然后在src下的包里新建一个类,类名是JMSListener.java

再复制一下代码

补充:软件开发 , Java ,
CopyRight © 2022 站长资源库 编程知识问答 zzzyk.com All Rights Reserved
部分文章来自网络,