ActiveMQ 与spring 整合的实例

该整合实例是在maven项目中整合，先要构建一个maven项目

第一步在maven项目的pom.xml文件中导入依赖

<!--这些依赖都是activemq和spring整合需要的依赖--> <dependency>     <groupId>org.springframework</groupId>     <artifactId>spring-jms</artifactId> </dependency> <!-- xbean 如<amq:connectionFactory /> --> <dependency>     <groupId>org.apache.xbean</groupId>     <artifactId>xbean-spring</artifactId>     <version>3.16</version> </dependency> <!-- activemq --> <dependency>     <groupId>org.apache.activemq</groupId>     <artifactId>activemq-core</artifactId>     <version>5.7.0</version> </dependency> <dependency>     <groupId>org.apache.activemq</groupId>     <artifactId>activemq-pool</artifactId> </dependency>

第二步，在spring的core配置文件中配置

<!--接收和发送的配置是一样的--> <?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:mvc="http://www.springframework.org/schema/mvc" xmlns:context="http://www.springframework.org/schema/context" xmlns:tx="http://www.springframework.org/schema/tx" xmlns:aop="http://www.springframework.org/schema/aop" xmlns:p="http://www.springframework.org/schema/p" xmlns:task="http://www.springframework.org/schema/task" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:amq="http://activemq.apache.org/schema/core" xmlns:jms="http://www.springframework.org/schema/jms" xsi:schemaLocation="         http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd         http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc.xsd         http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd         http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task.xsd         http://www.springframework.org/schema/jms http://www.springframework.org/schema/jms/spring-jms.xsd         http://activemq.apache.org/schema/core  http://activemq.apache.org/schema/core/activemq-core.xsd"> <!-- 配置连接工厂 --> <amq:connectionFactory id="activeConnectionFactory" brokerURL="tcp://127.0.0.1:61616" userName="admin" password="admin" /> <bean id="connectionFactory" class="org.springframework.jms.connection.CachingConnectionFactory"> <constructor-arg ref="activeConnectionFactory" /> <property name="sessionCacheSize" value="100" /> </bean> <!-- 配置目的地 --> <bean id="queueDestination" class="org.apache.activemq.command.ActiveMQQueue"> <constructor-arg index="0" value="FirstQueue" /> </bean> <!-- 配置JmsTemplate --> <bean id="JmsTemplate" class="org.springframework.jms.core.JmsTemplate"> <property name="connectionFactory" ref="connectionFactory" /> <property name="defaultDestination" ref="queueDestination" /> <property name="receiveTimeout" value="10000" /> <!-- true是topic，false是queue，默认是false，此处显示写出false --> <property name="pubSubDomain" value="false" /> </bean> </beans>

第三步、使用junit测试

//消息发送 @RunWith(SpringJUnit4ClassRunner.class) @ContextConfiguration(value = "classpath:/spring/spring-core.xml") public class Sender { @Resource(name = "JmsTemplate") private JmsTemplate jmsTemplate; @Test public void test() { System.out.println(jmsTemplate); System.out.println("向" + jmsTemplate.getDefaultDestination().toString() + "发送消息"); jmsTemplate.send(new MessageCreator() { @Override public Message createMessage(Session session) throws JMSException { return session.createTextMessage("发送消息"); } }); } } //消息接收 @RunWith(SpringJUnit4ClassRunner.class) @ContextConfiguration(value = "classpath:/spring/spring-core.xml") public class Consumer { @Resource(name = "JmsTemplate") private JmsTemplate jmsTemplate; @Resource(name = "queueDestination") private Destination destination; @Test public void test() { System.out.println(jmsTemplate); TextMessage message = (TextMessage) jmsTemplate.receive(destination); try { System.out.println("接受消息>>>>>>>>>>>" + message.getText()); } catch (JMSException e) { e.printStackTrace(); } } }

注意：使用MessageListener接收信息的配置

1、实现一个Message监听器 package com.web.consumer; import javax.jms.JMSException; import javax.jms.Message; import javax.jms.MessageListener; import javax.jms.TextMessage; public class demoMessageListener implements MessageListener { @Override public void onMessage(Message message) { try { System.out.println("接受到消息>>>>>>>>"+((TextMessage)message).getText()); } catch (JMSException e) { e.printStackTrace(); } } } 2、在配置文件中添加如下配置 <bean id="demoMessageListener" class="com.web.consumer.demoMessageListener" /> <bean class="org.springframework.jms.listener.DefaultMessageListenerContainer"> <property name="connectionFactory" ref="connectionFactory" /> <property name="destination" ref="queueDestination" /> <property name="messageListener" ref="demoMessageListener" /> </bean>