`
maiguang
  • 浏览: 257062 次
  • 性别: Icon_minigender_1
  • 来自: 焦作
社区版块
存档分类
最新评论

新手配置TOMCAT6.0+ActiveMq5.1+Spriing2.5

ActiveMQJMSBeanApacheSpring 
阅读更多

这个用了很多的时间都搞得成功，参考了不同的书籍，最后都成功了，在这里我把我的心得在这里写写

     首先，下载ActiveMq5.1，大家可以在官方网站下载：当大家下载解压后，就将文件夹的的包ＣＯＰＹ到web project下的lib文件夹里，需要拷贝的以下图的包(j2ee和jre除外)

 

 

好了，现在开始写配置文件了。在src文件夹下新建一spring配置文件名为：applicationContext.xml。其代码如下：

Xml代码 复制代码
  1. <?xml version="1.0" encoding="UTF-8"?>  
  2. <beans xmlns="http://www.springframework.org/schema/beans"  
  3.     xmlns:amq="http://activemq.apache.org/schema/core"  
  4.     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"  
  5.     xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd   
  6.   http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd">  
  7.   
  8.     <bean id="jmsConnectionFactory"  
  9.         class="org.springframework.jndi.JndiObjectFactoryBean">  
  10.         <property name="jndiName" value="java:comp/env/jms/ConnectionFactory"></property>  
  11.     </bean>  
  12.   
  13.     <bean id="jmsQueue"  
  14.         class="org.springframework.jndi.JndiObjectFactoryBean">  
  15.         <property name="jndiName" value="java:comp/env/jms/Queue"></property>  
  16.     </bean>  
  17.   
  18.     <bean id="jmsTemplate"  
  19.         class="org.springframework.jms.core.JmsTemplate">  
  20.         <property name="connectionFactory" ref="jmsConnectionFactory"></property>  
  21.         <property name="defaultDestination" ref="jmsQueue"></property>  
  22.     </bean>  
  23.   
  24.     <bean id="sender" class="message.Sender">  
  25.         <property name="jmsTemplate" ref="jmsTemplate"></property>  
  26.     </bean>  
  27.   
  28.     <bean id="receive" class="message.Receiver"></bean>  
  29.     <bean id="listenerContainer"  
  30.         class="org.springframework.jms.listener.DefaultMessageListenerContainer">  
  31.         <property name="connectionFactory" ref="jmsConnectionFactory"></property>  
  32.         <property name="destination" ref="jmsQueue"></property>  
  33.         <property name="messageListener" ref="receive"></property>  
  34.     </bean>  
  35.   
  36.   
  37. </beans>  
<?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="jmsQueue"
		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="jmsConnectionFactory"></property>
		<property name="defaultDestination" ref="jmsQueue"></property>
	</bean>

	<bean id="sender" class="message.Sender">
		<property name="jmsTemplate" ref="jmsTemplate"></property>
	</bean>

	<bean id="receive" class="message.Receiver"></bean>
	<bean id="listenerContainer"
		class="org.springframework.jms.listener.DefaultMessageListenerContainer">
		<property name="connectionFactory" ref="jmsConnectionFactory"></property>
		<property name="destination" ref="jmsQueue"></property>
		<property name="messageListener" ref="receive"></property>
	</bean>


</beans>

 

这里中，其中就有一个地方花了我很多时间找资料。这里是用了ActiveMq的方式来配置Spring的配置文件，其中引入了xsd的文件。

Xml代码 复制代码
  1. <beans xmlns="http://www.springframework.org/schema/beans"  
  2.     xmlns:amq="http://activemq.apache.org/schema/core"  
  3.     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"  
  4.     xsi:schemaLocation="http://www.springframework.org/schema/beans    
  5.                http://www.springframework.org/schema/beans/spring-beans-2.0.xsd   
  6.                http://activemq.apache.org/schema/core    
  7.                http://activemq.apache.org/schema/core/activemq-core.xsd">  
  8.   
  9. ...................   
  10.   
  11. <beans>  
<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">

...................

<beans>

  由于面的配置文件中使用了jndi，所以也得在Tomcat目录下的conf/context.xml配置,需加入

Xml代码 复制代码
  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="vm://localhost"    
  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="FOO.BAR"/>  
<Resource name="jms/ConnectionFactory" 
  auth="Container"   
  type="org.apache.activemq.ActiveMQConnectionFactory" 
  description="JMS Connection Factory"
  factory="org.apache.activemq.jndi.JNDIReferenceFactory" 
  brokerURL="vm://localhost" 
  brokerName="LocalActiveMQBroker"/>
 
<Resource name="jms/Queue" 
auth="Container" 
type="org.apache.activemq.command.ActiveMQQueue"
description="my Queue"
factory="org.apache.activemq.jndi.JNDIReferenceFactory" 
physicalName="FOO.BAR"/>

 在这里我分别配置了jmsConnectionFactory和jms点对点

  之后，就由消息生产者的代码

Java代码 复制代码
  1. package message;   
  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. public class Sender {   
  12.   
  13.     private JmsTemplate jmsTemplate;   
  14.   
  15.     public void setJmsTemplate(JmsTemplate jmsTemplate) {   
  16.         this.jmsTemplate = jmsTemplate;   
  17.     }   
  18.        
  19.     public void send(final String text){   
  20.         System.out.println("---Send:"+text);   
  21.         jmsTemplate.send(new MessageCreator(){   
  22.   
  23.             public Message createMessage(Session arg0) throws JMSException {   
  24.                 // TODO Auto-generated method stub   
  25.                 return arg0.createTextMessage(text);   
  26.             }   
  27.                
  28.         });   
  29.     }   
  30.   
  31. }  
package message;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Session;

import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;


public class Sender {

	private JmsTemplate jmsTemplate;

	public void setJmsTemplate(JmsTemplate jmsTemplate) {
		this.jmsTemplate = jmsTemplate;
	}
	
	public void send(final String text){
		System.out.println("---Send:"+text);
		jmsTemplate.send(new MessageCreator(){

			public Message createMessage(Session arg0) throws JMSException {
				// TODO Auto-generated method stub
				return arg0.createTextMessage(text);
			}
			
		});
	}

}

 

消息接收者

Java代码 复制代码
  1. package message;   
  2.   
  3. import javax.jms.JMSException;   
  4. import javax.jms.Message;   
  5. import javax.jms.MessageListener;   
  6. import javax.jms.TextMessage;   
  7.   
  8. public class Receiver implements MessageListener {   
  9.   
  10.     public void onMessage(Message message) {   
  11.         if (message instanceof TextMessage) {   
  12.             TextMessage text = (TextMessage) message;   
  13.   
  14.             try {   
  15.                 System.out.println("Receive:" + text.getText());   
  16.             } catch (JMSException e) {   
  17.                 // TODO Auto-generated catch block   
  18.                 e.printStackTrace();   
  19.             }   
  20.   
  21.         }   
  22.     }   
  23. }  
package message;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;

public class Receiver implements MessageListener {

	public void onMessage(Message message) {
		if (message instanceof TextMessage) {
			TextMessage text = (TextMessage) message;

			try {
				System.out.println("Receive:" + text.getText());
			} catch (JMSException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}

		}
	}
}

 

这里分别帖了最简单的JMS配置，希望对初入门的有用。

分享到：
| PO VO BO DTO POJO DAO
评论
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

Magicbox
Global site tag (gtag.js) - Google Analytics