注册 登录  
 加关注
   显示下一条  |  关闭
温馨提示!由于新浪微博认证机制调整,您的新浪微博帐号绑定已过期,请重新绑定!立即重新绑定新浪微博》  |  关闭

周响 廊坊师范学院九期信息技术提高班

一个世界有你 一个世界没有你 让两者的不同最大 就是你一生的意义

 
 
 

日志

 
 

activemq+tomcat 整合  

2015-08-31 21:40:37|  分类: 默认分类 |  标签: |举报 |字号 订阅

  下载LOFTER 我的照片书  |

       在ActiveMQ的资源让容器Tomcat管理时候,可以在Tomcat的配置文件中添加相关的配置信息。

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

1、准备jar包:

ActiveMQ lib目录下的5jar包复制到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

修改配置文件:

 修改Tomcatconf/context.xml文件:

 

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

Java代码  
  1. <Resource name="jms/ConnectionFactory"    
  2.             auth="Container"    
  3.             type="org.apache.activemq.ActiveMQConnectionFactory"  
  4.             description="JMS Connection Factory"  
  5.             factory="org.apache.activemq.jndi.JNDIReferenceFactory"  
  6.             brokerURL="tcp://localhost:61616"  
  7.             brokerName="LocalActiveMQBroker" />  
  8.               
  9. <Resource name="jms/Queue"    
  10.             auth="Container"    
  11.             type="org.apache.activemq.command.ActiveMQQueue"  
  12.             description="My Queue"  
  13.             factory="org.apache.activemq.jndi.JNDIReferenceFactory"  
  14.             physicalName="TomcatQueue" />      

创建一个Java Web项目:

  备注:必须是web项目,目前ActiveMQ依赖Tomcat,Tomcat是web容器,必须创建一个web容器。

 

消息接收者:

 

Java代码  
  1. package easyway.activemq.app.demo2;  
  2.   
  3. import javax.jms.JMSException;  
  4. import javax.jms.Message;  
  5. import javax.jms.MessageListener;  
  6. import javax.jms.TextMessage;  
  7.   
  8. import org.springframework.jms.core.JmsTemplate;  
  9. /** 
  10.  * 消息接收者 
  11.  * @author longgangbai 
  12.  * 
  13.  */  
  14. public class MessageReceiver implements  MessageListener {  
  15.     private JmsTemplate jmsTemplate;  
  16.         
  17.     public JmsTemplate getJmsTemplate() {  
  18.         return jmsTemplate;  
  19.     }  
  20.   
  21.     public void setJmsTemplate(JmsTemplate jmsTemplate) {  
  22.         this.jmsTemplate = jmsTemplate;  
  23.     }  
  24.     public void receive() throws JMSException{  
  25.          TextMessage text=(TextMessage)this.jmsTemplate.receive();  
  26.         System.out.println("receive="+text.getText());  
  27.     }  
  28.     public void onMessage(Message message) {  
  29.          if(message instanceof TextMessage){  
  30.              TextMessage text=(TextMessage)message;  
  31.              try {  
  32.                 System.out.println(text.getText());  
  33.             } catch (Exception e) {  
  34.             }  
  35.          }  
  36.     }  
  37.       
  38. }  

 

消息发送者:

Java代码  
  1. package easyway.activemq.app.demo2;  
  2.   
  3. import javax.jms.JMSException;  
  4. import javax.jms.Message;  
  5. import javax.jms.Session;  
  6.   
  7. import org.springframework.jms.core.JmsTemplate;  
  8. import org.springframework.jms.core.MessageCreator;  
  9.   
  10. /** 
  11.  * tomcat和activemq整合 
  12.  * 消息发送者 
  13.  * @author longgangbai 
  14.  * 
  15.  */  
  16. public class MessageSender {  
  17.   private JmsTemplate jmsTemplate;  
  18.     
  19.     
  20.   public void send(final String text){  
  21.       jmsTemplate.send(new MessageCreator(){  
  22.   
  23.         public Message createMessage(Session session) throws JMSException {  
  24.             // TODO Auto-generated method stub  
  25.             return session.createTextMessage(text);  
  26.         }  
  27.       });  
  28.   }  
  29.   
  30.   
  31.     public JmsTemplate getJmsTemplate() {  
  32.         return jmsTemplate;  
  33.     }  
  34.       
  35.       
  36.     public void setJmsTemplate(JmsTemplate jmsTemplate) {  
  37.         this.jmsTemplate = jmsTemplate;  
  38.     }  
  39. }  

 

业务类:

Java代码  
  1. package easyway.activemq.app.demo2;  
  2.   
  3. import javax.jms.JMSException;  
  4.   
  5. import org.apache.xbean.spring.context.ClassPathXmlApplicationContext;  
  6. /** 
  7.  * 测试类 
  8.  * @author longgangbai 
  9.  * 
  10.  */  
  11. public class MessageTest {  
  12.     public void test() throws JMSException {  
  13.         ClassPathXmlApplicationContext ctx=new ClassPathXmlApplicationContext("app-activemq-tomcat.xml");  
  14.         MessageSender sender=(MessageSender)ctx.getBean("sender");  
  15.         MessageReceiver receive=(MessageReceiver)ctx.getBean("receiver");  
  16.         sender.send("helloworld");  
  17.         receive.receive();  
  18.     }  
  19.   
  20. }  

 

 

 

配置文件:

Java代码  
  1. <?xml version="1.0" encoding="UTF-8"?>  
  2. <!--  
  3.     Licensed to the Apache Software Foundation (ASF) under one or more  
  4.     contributor license agreements.  See the NOTICE file distributed with  
  5.     this work for additional information regarding copyright ownership.  
  6.     The ASF licenses this file to You under the Apache License, Version 2.0  
  7.     (the "License"); you may not use this file except in compliance with  
  8.     the License.  You may obtain a copy of the License at  
  9.      
  10.     http://www.apache.org/licenses/LICENSE-2.0  
  11.      
  12.     Unless required by applicable law or agreed to in writing, software  
  13.     distributed under the License is distributed on an "AS IS" BASIS,  
  14.     WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.  
  15.     See the License for the specific language governing permissions and  
  16.     limitations under the License.  
  17. -->  
  18. <!-- START SNIPPET: xbean -->  
  19. <beans   
  20.   xmlns="http://www.springframework.org/schema/beans"   
  21.   xmlns:amq="http://activemq.apache.org/schema/core"  
  22.   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"  
  23.   xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd  
  24.   http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd">  
  25.   <!-- 连接连接工厂 -->  
  26.  <bean  id="jmsConnectionFactory" class="org.springframework.jndi.JndiObjectFactoryBean">  
  27.      <property name="jndiName" value="java:comp/env/jms/ConnectionFactory"></property>  
  28.  </bean>  
  29.    
  30.    
  31.  <bean  id="tomcatQueue" class="org.springframework.jndi.JndiObjectFactoryBean">  
  32.      <property name="jndiName" value="java:comp/env/jms/Queue"></property>  
  33.  </bean>  
  34.   
  35.  <!-- 配置JMS的模板 -->  
  36. <bean id="jmsTemplate"  class="org.springframework.jms.core.JmsTemplate">  
  37.    <property name="connectionFactory" >  
  38.      <ref  bean="jmsConnectionFactory"/>  
  39.    </property>  
  40.    <property name="defaultDestination">  
  41.       <ref bean="tomcatQueue"/>  
  42.    </property>  
  43. </bean>  
  44.   
  45.   
  46. <!-- 发送消息队列到目的地 -->  
  47. <bean id="sender"  class="easyway.activemq.app.demo2.MessageSender">  
  48.     <property name="jmsTemplate">  
  49.        <ref bean="jmsTemplate"/>  
  50.     </property>  
  51. </bean>  
  52. <!-- 接收消息 -->  
  53. <bean id="receiver" class="easyway.activemq.app.demo2.MessageReceiver">  
  54.     <property name="jmsTemplate">  
  55.        <ref bean="jmsTemplate"/>  
  56.     </property>  
  57. </bean>  
  58.   
  59.   
  60. <bean id="listenerContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">  
  61.    <property name="connectionFactory">  
  62.       <ref bean="jmsConnectionFactory"/>  
  63.    </property>  
  64.    <property name="destination">  
  65.       <ref bean="tomcatQueue"/>  
  66.    </property>  
  67.    <property name="messageListener">  
  68.       <ref bean="receiver"/>  
  69.     </property>  
  70. </bean>  
  71.   
  72. </beans>  

 

 

创建一个jsp页面:

Java代码  
  1. <%@ page language="java" import="easyway.activemq.app.demo2.*" pageEncoding="UTF-8"%>  
  2. <%  
  3. String path = request.getContextPath();  
  4. String basePath = request.getScheme()+"://"+request.getServerName()+":"+request.getServerPort()+path+"/";  
  5. %>  
  6.   
  7. <!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">  
  8. <html>  
  9.   <head>  
  10.     <base href="<%=basePath%>">  
  11.       
  12.     <title>My JSP 'index.jsp' starting page</title>  
  13.     <meta http-equiv="pragma" content="no-cache">  
  14.     <meta http-equiv="cache-control" content="no-cache">  
  15.     <meta http-equiv="expires" content="0">      
  16.     <meta http-equiv="keywords" content="keyword1,keyword2,keyword3">  
  17.     <meta http-equiv="description" content="This is my page">  
  18.     <!--  
  19.     <link rel="stylesheet" type="text/css" href="styles.css">  
  20.     -->  
  21.   </head>  
  22.     
  23.   <body>  
  24.     
  25.     <%  
  26.         MessageTest message=new MessageTest();  
  27.         message.test();  
  28.      %>  
  29.   <br>  
  30.   </body>  
  31. </html>
  评论这张
 
阅读(56)| 评论(1)
推荐 转载

历史上的今天

在LOFTER的更多文章

评论

<#--最新日志,群博日志--> <#--推荐日志--> <#--引用记录--> <#--博主推荐--> <#--随机阅读--> <#--首页推荐--> <#--历史上的今天--> <#--被推荐日志--> <#--上一篇,下一篇--> <#-- 热度 --> <#-- 网易新闻广告 --> <#--右边模块结构--> <#--评论模块结构--> <#--引用模块结构--> <#--博主发起的投票-->
 
 
 
 
 
 
 
 
 
 
 
 
 
 

页脚

网易公司版权所有 ©1997-2017