安科网

基于Tomcat容器的ActiveMQ简单实例

taikewu

taikewu

2011-09-15

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

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

<classpathentry kind="lib" path="src/activemq-all-5.5.0.jar"/>   

    <classpathentry kind="lib" path="src/slf4j-api-1.5.2-sources.jar"/>   


    <classpathentry kind="lib" path="src/slf4j-api-1.5.2.jar"/>   


    <classpathentry kind="lib" path="src/slf4j-simple-1.5.2.jar"/>   


    <classpathentry kind="lib" path="src/log4j-1.2.8.jar"/>   


    <classpathentry kind="lib" path="src/commons-dbcp-1.4.jar"/>   


    <classpathentry kind="lib" path="src/commons-pool-1.5.4.jar"/>   


    <classpathentry kind="lib" path="src/commons-collections-3.2.1.jar"/>   


    <classpathentry kind="lib" path="src/xbean-server-3.3.jar"/>  
<classpathentry kind="lib" path="src/activemq-all-5.5.0.jar"/>
	<classpathentry kind="lib" path="src/slf4j-api-1.5.2-sources.jar"/>
	<classpathentry kind="lib" path="src/slf4j-api-1.5.2.jar"/>
	<classpathentry kind="lib" path="src/slf4j-simple-1.5.2.jar"/>
	<classpathentry kind="lib" path="src/log4j-1.2.8.jar"/>
	<classpathentry kind="lib" path="src/commons-dbcp-1.4.jar"/>
	<classpathentry kind="lib" path="src/commons-pool-1.5.4.jar"/>
	<classpathentry kind="lib" path="src/commons-collections-3.2.1.jar"/>
	<classpathentry kind="lib" path="src/xbean-server-3.3.jar"/>

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

<Resource name="jms/ConnectionFactory"     

                auth="Container"     


                type="org.apache.activemq.ActiveMQConnectionFactory"  


                description="JMS Connection Factory"  


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


                brokerURL="tcp://localhost:61616"  


                brokerName="LocalActiveMQBroker" />   

                   

    <Resource name="jms/Queue"     


                auth="Container"     


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


                description="My Queue"  


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


                physicalName="TomcatQueue" />      
<Resource name="jms/ConnectionFactory"  
				auth="Container"  
				type="org.apache.activemq.ActiveMQConnectionFactory"
				description="JMS Connection Factory"
				factory="org.apache.activemq.jndi.JNDIReferenceFactory"
				brokerURL="tcp://localhost:61616"
				brokerName="LocalActiveMQBroker" />
				
	<Resource name="jms/Queue"  
				auth="Container"  
				type="org.apache.activemq.command.ActiveMQQueue"
				description="My Queue"
				factory="org.apache.activemq.jndi.JNDIReferenceFactory"
				physicalName="TomcatQueue" />

 配置如下：

<?xml version="1.0" encoding="UTF-8"?>   
<!--   
    Licensed to the Apache Software Foundation (ASF) under one or more   
    contributor license agreements.  See the NOTICE file distributed with   

    this work for additional information regarding copyright ownership.   


    The ASF licenses this file to You under the Apache License, Version 2.0  


    (the "License"); you may not use this file except in compliance with   

    the License.  You may obtain a copy of the License at   
      

    http://www.apache.org/licenses/LICENSE-2.0   

      
    Unless required by applicable law or agreed to in writing, software   

    distributed under the License is distributed on an "AS IS" BASIS,   

    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.   

    See the License for the specific language governing permissions and   

    limitations under the License.   
-->   
<!-- START SNIPPET: xbean -->   
<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>   
  
 <!-- 配置JMS的模板 -->   

<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>  
<?xml version="1.0" encoding="UTF-8"?>
<!--
    Licensed to the Apache Software Foundation (ASF) under one or more
    contributor license agreements.  See the NOTICE file distributed with
    this work for additional information regarding copyright ownership.
    The ASF licenses this file to You under the Apache License, Version 2.0
    (the "License"); you may not use this file except in compliance with
    the License.  You may obtain a copy of the License at
   
    http://www.apache.org/licenses/LICENSE-2.0
   
    Unless required by applicable law or agreed to in writing, software
    distributed under the License is distributed on an "AS IS" BASIS,
    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    See the License for the specific language governing permissions and
    limitations under the License.
-->
<!-- START SNIPPET: xbean -->
<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>

 <!-- 配置JMS的模板 -->
<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>

代码如下：

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;   

    }   
}  
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;
	}
}
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) {   

            }   
         }   
    }   
       
}  
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) {
			}
		 }
	}
    
}
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();   
    }   
  
}  
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内容：

<%@ 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">   

    <!--   

    <link rel="stylesheet" type="text/css" href="styles.css">   

    -->   
  </head>   
     
  <body>   
     
    <%   

        MessageTest message=new MessageTest();   

        message.test();   
     %>   
  <br>   
  </body>   
</html>  

activemq lib文件 lib 容器

taikewu

taikewu

0 关注 0 粉丝 0 动态

关注 关注

相关推荐

Artemis安装

Artemis是下一代的ActiveMQ，也就是说目前的ActiveMQ是5.x，Artemis将是6.x. Broker实例是包含与Broker进程关联的所有配置和运行时数据的目录。官网文档建议我们不要在${ARTEMIS_HOME}下创建实例目录。Yo

胡献根 2020-07-18

mqtt用户名密码activemq

<authenticationUser username="test1" password="123456" groups="users"/>. <authenticationU

胡献根 2020-07-05

ActiveMQ

--消息队列连接池-->

xinglun 2020-06-14

linux配置ActiveMQ消息服务

1 下载ActiveMQ 前往Apache官方网站或者直接引擎搜索 ActiveMQ即可，点击对应的OS版本进行下载操作。至此，ActiveMQ的包已经被正确解压缩。在没有设置环境变量的情况下，我们在系统的任意目录下执行 启动activemq的脚本是无效的

jiangtie 2020-06-10

ActiveMq安装以及简单的测试

如果你还没有使用过消息中间件，这篇文章可以带你初步感受一下消息中间件。下面就带大家简单测试一下ActiveMq;先创建一个maven项目；System.out.println("exit code 0 ！！！！！！！！！

onlylixiaobei 2020-06-09

ActiveMQ配置用户认证信息

以apache-activemq-5.15.12-bin.tar.gz为例，修改activemq.xml. -- 配置生产者连接池 -->

xinglun 2020-06-02

CentOS7安装配置ActiveMQ

检查java版本，可以看到系统自带的OpenJDK版本信息。上述所列文件中，noarch文件可以不用删除，删除掉其余java相关文件。将jdk压缩包jdk-8u161-linux-x64.tar.gz上传至CentOS的/usr/soft目录。将下载好的a

方新德 2020-05-31

activeMQ安装

ActiveMQ默认使用的TCP连接端口是61616, 通过查看该端口的信息可以测试ActiveMQ是否成功启动 netstat -an|find “61616”。ActiveMQ默认启动时，启动了内置的jetty服务器，提供一个用于监控ActiveMQ的

Java高知 2020-05-20

activemq

// 1)获取工厂 ConnectionFactory,使用摸摸人的用户名和密码admin/admin, 指定URL. // 4)创建Session ,参数transacted:事务，acknowledgeMode响应模式。// 6)创建消费者，

Java高知 2020-05-08

消息队列

消息队列是指利用高效可靠的消息传递机制进行与平台无关的数据交流，并基于数据通信来进行分布式系统的集成。注册时的短信、邮件通知，减少响应时间；信息发送者和消息接受者无需耦合，比如调用第三方；支持来自Java，C，C ++，C＃，Ruby，Perl，Pytho

Java高知 2020-05-03

24、springboot集成ActiveMQ

消息队列中间件是分布式系统中重要的组件，主要解决应用耦合，异步消息，流量削锋等问题。目前使用较多的消息队列有ActiveMQ、RabbitMQ、Kafka、RocketMQ、MetaMQ等。spring boot提供了对JMS系统的支持；springboo

onlylixiaobei 2020-05-02

从入门到精通的ActiveMQ（三）

前面2篇博客地址如下：《从入门到精通的ActiveMQ（一）》、《从入门到精通的ActiveMQ（二）》。注意到只有Master对外提供了服务，Slave是待机状态。当Master出现故障，ZK内部的选举机制，会让一个Slave升级成Master对外提供服

Java高知 2020-04-22

从入门到精通ActiveMQ（二）

接上一篇《从入门到精通ActiveMQ（一）》，本篇主要讨论的话题是：消息的顺序消费、JMS Selectors、消息的同步/异步接受方式、Message、P2P/PubSub、持久化订阅、持久化消息到MySQL以及与Spring整合等知识。消息的顺序消费

胡献根 2020-04-22

从入门到精通ActiveMQ（二）

在上一篇文章中，我们已经明确知道了ActiveMQ并不能保证消费的顺序性，即便我们使用了消息优先级。而在实际开发中，有些场景又是需要对消息进行顺序消费的，比如：用户从下单、到支付、再到发货等。首先来说，在实际中，我们并不需要的是对全部消息的全局有序消费，我

heweiyabeijing 2020-04-21

从入门到精通的ActiveMQ（一）

话不多说，我们来一起瞧一瞧！client进程和server服务进程都必须可用，如果server出现问题或者网络故障，那么client端会收到异常。需要注意的是，JMS只是定义了Java访问消息中间件的接口，其实就是在包javax.jms中，你会发现这个包下

方新德 2020-04-20

如何避免activeMQ数据丢失

做消息持久化 借助 jdbc， kahadb或 leveldb+zookeeper首先将将消息发送设置为持久化发送，然后再借助jdbc kahadb leveldb+zookeeper等做消息的存储来持久化。思想都是发送者将消息发送出去后，消息中心首先将消

胡献根 2020-04-10

ActiveMQ

包含点对点和发布/订阅2种消息模型，提供可靠的消息传输、事务和消息过滤等机制。主要特点包括：1）消息异步接受，消息发送者不需要等待消息接受者的响应；2）消息可靠接受，缺陷消息在中间件可保存，只有接收方收到后才删除消息，多个消息也可以组成原子事物。那么这些个

onlylixiaobei 2020-04-10

activeMQ中queue 与 topic 区别

3.queue模式生产者与消费者之间没有时间相关性，topic模式下生产者和消费者之间有一定的时间相关性，消费者只能接收到订阅之后的生产者发送的消息。

方新德 2020-04-08

ActiveMQ架构设计与实践，需要一万字

xjjdog以前写过很多关于消息队列的文章。今天介绍一下ActiveMQ。ActiveMQ是最常用、特性最丰富的消息中间件，通常用于消息异步通信、削峰解耦等多种场景，是JMS规范的实现者之一。支持大部分消息协议，而且支持XA。它也是比较古老的消息队列，虽然

xuedabao 2020-03-30

centos 安装activeMq

Apache ActiveMQ是一个免费的开源消息代理和集成模式服务器。它支持来自JAVA、c++、C、Python、Perl、PHP等多种语言的客户端和协议。它提供了许多功能，如消息组、虚拟目的地、通配符和组合目的地等。它可以很容易地集成到spring应

heweiyabeijing 2020-03-28
taikewu

taikewu

W3CSchool教程
HTML 教程
CSS 教程
Bootstrap 教程
Javascript 教程
jQuery 教程
后端教程
C 教程
Java 教程
PHP 教程
Python 教程
Go 教程
移动开发
Android 教程
Swift 教程
Kotlin 教程
jQuery Mobile 教程
ionic 教程
关于我们
新闻动态
联系方式
招聘英才
安科实验室
帮助与反馈

安科网(Ancii)，中国第一极客网

Copyright © 2013 - 2019 Ancii.com

京ICP备18063983号 京公网安备11010802014868号