`

ActiveMq-JMS简单实例使用tomcat

 
阅读更多
ActiveMq初级操作 

(工具:tomcat6.0、activeMq5.3.2、Myeclipse7.0,java1。5) 

这是本人第一次发表个人使用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、下载 

http://activemq.apache.org/download.html,在这个页面里有你所需要的各个版本,我用的是最新的版本-ActiveMQ 5.3.2。 

2、安装 

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

3、启动ActiveMQ服务器 

方法1: 

直接运行bin\activemq.bat 

方法2(在JVM中嵌套启动):(这个我没用过,你可以试试) 

cd example 

ant embedBroker 

4、ActiveMQ消息管理后台系统: http://localhost:8161/admin 

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

三、详细实例 

以下为本人的一个简单的实例,希望对各位有所帮助, 

我是利用网上的资料,将tomcat和activeMq整合在一起做的一个发送接受的发布订阅的例子(我用的是tomcat6.0,activeMq5.3.2): 

首先整合tomcat和activeMq: 

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 

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> 

2.3 修改activemq.xml文件:为了支持持久化消息,需修改ActiveMQ的配置文件如下,使用默认的AMQ Message Store方式(索引文件方式)存储消息,据官网介绍是快速、稳定的。数据库存储方式可参照官网相关文档。 

<broker xmlns="http://activemq.apache.org/schema/core" brokerName="localhost" persistent="true" useShutdownHook="false"> 

<persistenceAdapter> 

<amqPersistenceAdapter directory="activemq-data" maxFileLength="32mb"/> </persistenceAdapter> 

</broker> 

(备注:2.3中红色部分直接加到后面就行,不用修改) 

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

再复制一下代码到你的类中: 

package com.flvcd.servlet; 



import java.io.*; 

import javax.servlet.*; 

import javax.servlet.http.*; 

import javax.naming.*; 

import javax.jms.*; 

import org.apache.activemq.ActiveMQConnectionFactory; 



public class JMSListener extends HttpServlet implements MessageListener { 

   

    public void init(ServletConfig config) throws ServletException { 

        try { 

            InitialContext initCtx = new InitialContext(); 

            Context envContext = (Context) initCtx.lookup("java:comp/env"); 

            ConnectionFactory connectionFactory = (ConnectionFactory) envContext 

                    .lookup("jms/FailoverConnectionFactory"); 

            Connection connection = connectionFactory.createConnection(); 

            connection.setClientID("MyClient"); 

            Session jmsSession = connection.createSession(false, 

                    Session.AUTO_ACKNOWLEDGE); 

            // 普通消息订阅者,无法接收持久消息 //MessageConsumer consumer = 

            // jmsSession.createConsumer((Destination) 

            // envContext.lookup("jms/topic/MyTopic")); 

            // //基于Topic创建持久的消息订阅者,前提:Connection必须指定一个唯一的clientId,当前为MyClient 

        TopicSubscriber consumer=jmsSession.createDurableSubscriber((Topic)envContext.lookup("jms/topic/MyTopic"), "MySub"); 

            consumer.setMessageListener(this); 

            connection.start(); 

        } catch (NamingException e) { 

            e.printStackTrace(); 

        } catch (JMSException e) { 

            e.printStackTrace(); 

        } 

    } 



   

    public void onMessage(Message message) { 

        if (checkText(message, "RefreshArticleId") != null) { 

            String articleId = checkText(message, "RefreshArticleId"); 

            System.out.println("接收刷新文章消息,开始刷新文章ID=" + articleId); 

        } else if (checkText(message, "RefreshThreadId") != null) { 

            String threadId = checkText(message, "RefreshThreadId"); 

            System.out.println("接收刷新论坛帖子消息,开始刷新帖子ID=" + threadId); 

        } else { 

            System.out.println("接收普通消息,不做任何处理!"); 

        } 

    } 



    private static String checkText(Message m, String s) { 

        try { 

            return m.getStringProperty(s); 

        } catch (JMSException e) { 

            e.printStackTrace(System.out); 

            return null; 

        } 

    } 





你的监听端建好 

现在开始建立你发布端 

同样是新建一个类MyPublish.java 

然后复制一下代码到你的类里 

package com.flvcd.servlet; 



import java.io.IOException; 

import java.io.PrintWriter; 



import javax.jms.Connection; 

import javax.jms.ConnectionFactory; 

import javax.jms.DeliveryMode; 

import javax.jms.Destination; 

import javax.jms.JMSException; 

import javax.jms.Message; 

import javax.jms.MessageListener; 

import javax.jms.MessageProducer; 

import javax.jms.Session; 

import javax.naming.Context; 

import javax.naming.InitialContext; 

import javax.naming.NamingException; 

import javax.servlet.ServletException; 

import javax.servlet.http.HttpServlet; 

import javax.servlet.http.HttpServletRequest; 

import javax.servlet.http.HttpServletResponse; 



public class MyPublish extends HttpServlet implements MessageListener { 

   

   

    //定义初始化所需要的变量 

    private InitialContext initCtx; 

    private Context envContext; 

    private ConnectionFactory connectionFactory; 

    private Connection connection; 

    private Session jmsSession; 

    private MessageProducer producer; 

   

   

    public void onMessage(Message message) { 

        // TODO Auto-generated method stub 



    } 



   

    public MyPublish() { 

        super(); 

    } 



   

    public void destroy() { 

        super.destroy(); // Just puts "destroy" string in log 

        // Put your code here 

    } 



   

    public void doGet(HttpServletRequest request, HttpServletResponse response) 

            throws ServletException, IOException { 



    doPost(request, response); 

    } 



   

    public void doPost(HttpServletRequest request, HttpServletResponse response) 

            throws ServletException, IOException { 

        String content=request.getParameter("content"); 

        //设置持久方式 

        try { 

            producer.setDeliveryMode(DeliveryMode.PERSISTENT); 

            Message testMessage = jmsSession.createMessage(); 

            // 发布刷新文章消息 

            testMessage.setStringProperty("RefreshArticleId", content); 

            producer.send(testMessage); 

            // 发布刷新帖子消息 

            testMessage.clearProperties(); 

            testMessage.setStringProperty("RefreshThreadId", content); 

            producer.send(testMessage); 

        } catch (Exception e) { 

            e.printStackTrace(); 

        } 

       

       

    } 



   

    public void init() throws ServletException { 

        // Put your code here 

        try { 

            initCtx = new InitialContext(); 

            envContext = (Context) initCtx.lookup("java:comp/env"); 

            connectionFactory = (ConnectionFactory) envContext.lookup("jms/NormalConnectionFactory"); 

            connection = connectionFactory.createConnection(); 

            jmsSession = connection.createSession(false,Session.AUTO_ACKNOWLEDGE); 

            producer = jmsSession.createProducer((Destination) envContext.lookup("jms/topic/MyTopic")); 



        } catch (NamingException e) { 

            e.printStackTrace(); 

        } catch (JMSException e) { 

            e.printStackTrace(); 

        } 

    } 









最后,建一个MyPublish.jsp页面,加上一下代码 

<form action="myPublish.do"> 

        <input type="text" name="content" /> 

        <input type="submit" value="提交" > 

    </form> 

在web.xml中加上一下代码 

   

  <servlet> 

    <description>This is the description of my J2EE component</description> 

    <display-name>This is the display name of my J2EE component</display-name> 

    <servlet-name>MyPublish</servlet-name> 

    <servlet-class>com.flvcd.servlet.MyPublish</servlet-class> 

  </servlet> 

  <servlet> 

  <servlet-mapping> 

    <servlet-name>MyPublish</servlet-name> 

    <url-pattern>/myPublish.do</url-pattern> 

  </servlet-mapping> 



将你的工程装载到你的tomcat中 

然后先启动activeMq(前面已说明启动方式),然后用Myeclipse启动tomcat,在页面上输入http://localhost:8080/jms-test/MyPublish.jsp,在页面上输入一些英文字符,然后你在后台可以看到你输入的字符, 

注意事项,在Myeclipse中导入activeMq的jar包,我用是5.3所以有一个activemq-all-5.3.2.jar,这个jar包是全部的内容都包括,直接用Myeclipse导包方法导入的。 
分享到:
评论

相关推荐

    ActiveMq-JMS简单实例使用tomcat.pdf

    【ActiveMQ-JMS简单实例使用Tomcat】是一个关于如何在Tomcat环境下集成并使用ActiveMQ进行JMS消息传递的初级教程。ActiveMQ是一款开源的消息中间件,它遵循JMS(Java Message Service)1.1规范,能兼容J2EE1.4及以上...

    ActiveMq-JMS简单实例

    在这个"ActiveMQ-JMS简单实例"中,我们将探讨如何在Tomcat服务器上部署并使用ActiveMQ,以及通过代码实现JMS的基本功能。 首先,让我们了解ActiveMQ的核心概念。ActiveMQ作为消息代理,它接收和转发消息,提供持久...

    ActiveMq-JMS简单实例使用tomcat.doc

    在本文中,我们将探讨如何在Tomcat服务器上设置和使用ActiveMQ的简单实例。 **一、ActiveMQ的特点与优势** 1. **遵循JMS1.1规范**,兼容J2EE1.4及以上版本。 2. **跨平台**,可以在任何JVM和大多数Web容器中运行,...

    ActiveMq-JMS好用实例详解

    下面介绍如何将ActiveMQ与Tomcat整合,以便在Web应用中使用JMS。 ##### 准备工作 1. **准备JAR包** 将ActiveMQ `lib` 目录下的5个核心JAR包复制到Tomcat `lib` 目录下: - `activemq-core-5.1.0.jar` - `...

    activemq与tomcat整合

    这些jar包包括activemq-core、activemq-web、geronimo-j2ee-management、geronimo-jms和geronimo-jta等,它们是ActiveMQ运行和Tomcat识别其API所必需的。 2. **修改Tomcat配置**:接下来,需要编辑Tomcat的`conf/...

    基于Spring+JMS+ActiveMQ+Tomcat的整合ActiveMQSpringDemo实例源码.zip

    基于Spring+JMS+ActiveMQ+Tomcat的整合ActiveMQSpringDemo实例源码,此实例基于Spring+JMS+ActiveMQ+Tomcat,注解的完整实例,包含jar包,可供学习及设计参考。

    基于Spring+JMS+ActiveMQ+Tomcat整合

    基于Spring+JMS+ActiveMQ+Tomcat,做一个Spring4.1.0和ActiveMQ5.11.1整合实例,实现了Point-To-Point的异步队列消息和PUB/SUB(发布/订阅)模型,简单实例,不包含任何业务。

    JMS教程+activemq以及activemq和tomcat的整合+整合实例代码+持久化消息配置以及工程+tomcat服务器的配置

    JMS简明教程+JMS规范教程+activemq以及activemq和tomcat的整合+整合实例代码+持久化消息配置以及工程+tomcat服务器的配置+整合需要的lib文件+部署多个tomcat服务器方案等

    spring-activeMQ-demo:spring-activeMQ-演示

    在"spring-activeMQ-demo"中,我们可以看到如何设置消息生产者(发送消息)和消费者(接收消息)的代码实例,以及如何在Spring环境中启动和关闭ActiveMQ连接。这个例子是学习和理解Spring与ActiveMQ整合的绝佳起点,...

    JMS教程+activemq以及activemq和tomcat的整合

    5. **编写Java代码**: 使用JMS API创建生产者和消费者,连接到ActiveMQ服务器并发送/接收消息。 **持久化消息配置** 在ActiveMQ中,持久化消息意味着即使在服务器重启后,消息也不会丢失。这可以通过在发送消息时...

    Spring集成ActiveMQ配置

    6. **Missian ActiveMQ-JMS简单实例**:这可能是一个具体的项目实例,它展示了如何在Spring应用中使用ActiveMQ实现异步RPC(远程过程调用)。在这种模式下,一个服务通过消息将请求发送到队列,另一端的服务监听队列...

    String+tomcat+jms实例

    在tomcat 下的context.xml文件中加入 auth="Container" type="org.apache.activemq.ActiveMQConnectionFactory" description="JMS Connection Factory" factory="org.apache.activemq.jndi....

    Spring和ActiveMQ的整合实例源码

    9. **Spring注解**:在提供的实例中,可能包含了使用注解的方式配置Spring与ActiveMQ的集成,如`@EnableJms`启动JMS支持,`@JmsListener`定义消息监听器等。 10. **Tomcat服务器**:Tomcat是一个流行的Java Web...

    activemq整合spring完整实例代码(内含所有相关jar包)

    这个实例代码是将ActiveMQ与Spring进行整合的一个实际项目,可以在Tomcat服务器上运行。由于提供了所有必要的jar包,所以无需额外下载,直接解压后部署到Tomcat即可。这表明该实例考虑到了用户友好性和易用性,避免...

    spring jms tomcat 异步消息传递入门实例

    综上所述,"spring jms tomcat 异步消息传递入门实例"旨在引导开发者理解如何在Spring应用中结合Tomcat使用JMS实现异步消息传递,从而提升系统的响应能力和处理大规模并发的能力。通过这个实例,你可以学习到Spring...

    ActiveMQ实例

    ActiveMQ实例主要展示了如何在不同的应用场景中集成并使用Apache ActiveMQ,这是一个功能强大的开源消息代理,它遵循Java消息服务(JMS)规范,提供了消息传递的平台。在这个实例中,我们将深入探讨ActiveMQ如何与...

    ActiveMQ快速上手 PDF

    - **单独应用的开发**:编写 Java 应用程序使用 ActiveMQ 的 JMS API 进行消息收发。 - **结合Spring的开发**:利用 Spring 的支持简化 ActiveMQ 的配置,并通过 Spring 管理连接和事务。 #### 五、ActiveMQ的...

    Spring整合ActiveMQ超级详细实例

    这个实例是基于Java编程语言,利用Spring的JMS(Java消息服务)支持和ActiveMQ作为消息代理,同时在Tomcat服务器上运行。我们将讨论关键概念、配置和代码实现,帮助你理解和应用这个技术栈。 首先,ActiveMQ是...

Global site tag (gtag.js) - Google Analytics