您的位置：首页 > 运维架构 > Tomcat

基于Tomcat容器的ActiveMQ简单实例

2016-07-19 10:07 399 查看

      在tomcat中配置ConnectionFactory和ActiveMQQueue,通过JNDI方式实现ActiveMQ。因为JNDI配置在tomcat容器中所以必须通过jsp访问tomcat容器。

      首先在在tomcat的lib目录添加如下jar文件。

Java代码

在Tomcat的conf目录下的context.xml配置中添加如下(JNDI)：

Java代码

Spring Beans配置如下：

Java代码

<?xml version="1.0" encoding="UTF-8"?>





<beans

  xmlns="http://www.springframework.org/schema/beans"

  xmlns:amq="http://activemq.apache.org/schema/core"

  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

  xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd

  http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd">

  

<bean  id="jmsConnectionFactory" class="org.springframework.jndi.JndiObjectFactoryBean">

     <property name="jndiName" value="java:comp/env/jms/ConnectionFactory"></property>

</bean>





<bean  id="tomcatQueue" class="org.springframework.jndi.JndiObjectFactoryBean">

     <property name="jndiName" value="java:comp/env/jms/Queue"></property>

</bean>





<bean id="jmsTemplate"  class="org.springframework.jms.core.JmsTemplate">

   <property name="connectionFactory" >

     <ref  bean="jmsConnectionFactory"/>

   </property>

   <property name="defaultDestination">

      <ref bean="tomcatQueue"/>

   </property>

</bean>







<bean id="sender"  class="easyway.activemq.app.demo2.MessageSender">

    <property name="jmsTemplate">

       <ref bean="jmsTemplate"/>

    </property>

</bean>



<bean id="receiver" class="easyway.activemq.app.demo2.MessageReceiver">

    <property name="jmsTemplate">

       <ref bean="jmsTemplate"/>

    </property>

</bean>





<bean id="listenerContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">

   <property name="connectionFactory">

      <ref bean="jmsConnectionFactory"/>

   </property>

   <property name="destination">

      <ref bean="tomcatQueue"/>

   </property>

   <property name="messageListener">

      <ref bean="receiver"/>

    </property>

</bean>



</beans>

代码如下：

Java代码

package easyway.activemq.app.demo2;



import javax.jms.JMSException;

import javax.jms.Message;

import javax.jms.Session;



import org.springframework.jms.core.JmsTemplate;

import org.springframework.jms.core.MessageCreator;



/**

* tomcat和activemq整合

* 消息发送者

* @author longgangbai

*

*/

public class MessageSender {

  private JmsTemplate jmsTemplate;





  public void send(final String text){

      jmsTemplate.send(new MessageCreator(){



        public Message createMessage(Session session) throws JMSException {

            // TODO Auto-generated method stub

            return session.createTextMessage(text);

        }

      });

  }





    public JmsTemplate getJmsTemplate() {

        return jmsTemplate;

    }





    public void setJmsTemplate(JmsTemplate jmsTemplate) {

        this.jmsTemplate = jmsTemplate;

    }

}

Java代码

package easyway.activemq.app.demo2;



import javax.jms.JMSException;

import javax.jms.Message;

import javax.jms.MessageListener;

import javax.jms.TextMessage;



import org.springframework.jms.core.JmsTemplate;

/**

* 消息接收者

* @author longgangbai

*

*/

public class MessageReceiver implements  MessageListener {

    private JmsTemplate jmsTemplate;



    public JmsTemplate getJmsTemplate() {

        return jmsTemplate;

    }



    public void setJmsTemplate(JmsTemplate jmsTemplate) {

        this.jmsTemplate = jmsTemplate;

    }

    public void receive() throws JMSException{

         TextMessage text=(TextMessage)this.jmsTemplate.receive();

        System.out.println("receive="+text.getText());

    }

    public void onMessage(Message message) {

         if(message instanceof TextMessage){

             TextMessage text=(TextMessage)message;

             try {

                System.out.println(text.getText());

            } catch (Exception e) {

            }

         }

    }



}

Java代码

package easyway.activemq.app.demo2;



import javax.jms.JMSException;



import org.apache.xbean.spring.context.ClassPathXmlApplicationContext;

/**

* 测试类

* @author longgangbai

*

*/

public class MessageTest {

    public void test() throws JMSException {

        ClassPathXmlApplicationContext ctx=new ClassPathXmlApplicationContext("app-activemq-tomcat.xml");

        MessageSender sender=(MessageSender)ctx.getBean("sender");

        MessageReceiver receive=(MessageReceiver)ctx.getBean("receiver");

        sender.send("helloworld");

        receive.receive();

    }



}

index.jsp内容：

Java代码

<%@ page language="java" import="easyway.activemq.app.demo2.*" pageEncoding="UTF-8"%>

<%

String path = request.getContextPath();

String basePath = request.getScheme()+"://"+request.getServerName()+":"+request.getServerPort()+path+"/";

%>



<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">

<html>

  <head>

    <base href="<%=basePath%>">



    <title>My JSP 'index.jsp' starting page</title>

    <meta http-equiv="pragma" content="no-cache">

    <meta http-equiv="cache-control" content="no-cache">

    <meta http-equiv="expires" content="0">

    <meta http-equiv="keywords" content="keyword1,keyword2,keyword3">

    <meta http-equiv="description" content="This is my page">

    

  </head>



  <body>



    <%

        MessageTest message=new MessageTest();

        message.test();

     %>

  <br>

  </body>

</html>

内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理

标签：

相关文章推荐

新的分享

章节导航