ActiveMQ 与Spring

applicationContext.xml

<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context" 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/context http://www.springframework.org/schema/context/spring-context.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 "> <!--扫描包--> <context:component-scan base-package="com.cckp.activemq"/> <!--ActiveMQ连接工厂--> <!--真正可以产生Connection的 ConnectionFactory,由对应的JMS服务厂商提供--> <!--如果连接网络 tcp://ip:61616 本地：tcp://localhost:61616以及用户名，密码--> <amq:connectionFactory id="amqConnectionFactory" brokerURL="tcp://localhost:61616" userName="admin" password="admin"/> <!--配置队列--> <!-- <amq:queue name="default_queue2" physicalName="queue" />--> <!--定义消息队列方法2 【普通的bean定义】 --> <bean id="default_queue1" class="org.apache.activemq.command.ActiveMQQueue"> <!--org.apache.activemq.command.ActiveMQQueue：的构造器有：无参数、一个参数--> <constructor-arg index="0" value="default_queue1" /> </bean> <!--Spring Caching 连接工厂--> <!--Spring 用于管理真正的ConnectionFactory的ConnectionFactory--> <bean id="connectionFactory" class="org.springframework.jms.connection.CachingConnectionFactory"> <!--目标ConnectionFactory对应的真实的可以产生JMS Connection的ConnectionFactory--> <property name="targetConnectionFactory" ref="amqConnectionFactory"/> <!--Session缓存数量--> <property name="sessionCacheSize" value="100"/> </bean> <!--spring JmsTemplate 的消息生产者 --> <!--定义JMSTemplate的Queue类型--> <bean id="jmsQueueTemplate" name="jmsTemplate" class="org.springframework.jms.core.JmsTemplate"> <!--这个connectionFactory对应的是我们定义的的Spring提供的那个connectionFactory对象--> <constructor-arg ref="connectionFactory"/> <!--非pub/sub模型（发布/订阅），即队列模式--> <property name="pubSubDomain" value="false"/> <!--设置默认的消息队列的两种方法--> <!--第一种：设置目的地，且需要关联队列【需要先配置好队列】--> <property name="defaultDestination" ref="default_queue1"/> <!--第二种：设置默认目的地的名字即可--> <property name="defaultDestinationName" value="default_queue2"/> </bean> <!--消息消费者--> <!--定义Queue监听器--> <jms:listener-container destination-type="queue" container-type="default" connection-factory="connectionFactory" acknowledge="auto"> <!-- 默认注册bean名称，应该是类名首字母小写 --> <jms:listener destination="queue1" ref="myMessageListener"/> <!--注册监听默认队列的监听器--> <jms:listener destination="default_queue2" ref="defaultMessageListener"/> <jms:listener destination="default_queue1" ref="defaultMessageListener"/> </jms:listener-container> </beans>

 上面<jms:listener destination="text_msg" ref="myMessageListener"/> 发送是时jmsTemplate.send("text_msg", new MessageCreator() { //---------------} }); 相同才会被监听器接受

activemq包下的两个类：AMQSenderService、MyMessageListener

AMQSenderService类中 

import org.apache.xbean.spring.context.ClassPathXmlApplicationContext; 项目没有错误

import org.springframework.context.support.ClassPathXmlApplicationContext;项目报错

但是先使用org.apache.xbean.spring.context.ClassPathXmlApplicationContext   项目正常运行之后，再修改成

org.springframework.context.support.ClassPathXmlApplicationContext------->项目正常运行

package activemq; import org.springframework.context.ApplicationContext; import org.springframework.context.support.ClassPathXmlApplicationContext; import org.springframework.jms.core.JmsTemplate; import org.springframework.jms.core.MessageCreator; import javax.jms.JMSException; import javax.jms.Message; import javax.jms.TextMessage; public class AMQSenderService { public static void main(String[] args){ JmsTemplate jmsTemplate; ApplicationContext ac = new ClassPathXmlApplicationContext("classpath:applicationContext.xml"); jmsTemplate = (JmsTemplate) ac.getBean("jmsTemplate"); jmsTemplate.send("text_msg", new MessageCreator() { public Message createMessage(javax.jms.Session session) throws JMSException { TextMessage mapMessage = session.createTextMessage(); mapMessage.setText("telephone:155xxxxxxxx"); return mapMessage; } }); } } package activemq; import org.springframework.stereotype.Component; import javax.jms.JMSException; import javax.jms.Message; import javax.jms.MessageListener; import javax.jms.TextMessage; @Component public class MyMessageListener implements MessageListener { public void onMessage(Message msg) { if (msg instanceof TextMessage) { try { TextMessage txtMsg = (TextMessage) msg; String message = txtMsg.getText(); //实际项目中拿到String类型的message(通常是JSON字符串)之后， //会进行反序列化成对象，做进一步的处理 System.out.println("receive txt msg===" + message); } catch (JMSException e) { throw new RuntimeException(e); } } else { throw new IllegalArgumentException("Message must be of type TextMessage"); } } } DefaultMessageListener package com.cckp.activemq; import org.springframework.stereotype.Component; import javax.jms.*; @Component public class MyMessageListener implements MessageListener { @Override public void onMessage(Message msg) { if (msg instanceof MapMessage) { try { MapMessage mapMessage = (MapMessage) msg; String message_tel = mapMessage.getString("telephone"); String message_code = mapMessage.getString("code"); //实际项目中拿到String类型的message(通常是JSON字符串)之后， //会进行反序列化成对象，做进一步的处理 System.out.println("receive txt msg===" + message_tel+message_code); } catch (JMSException e) { throw new RuntimeException(e); } } else { throw new IllegalArgumentException("Message must be of type TextMessage"); } } }

 

 

pom.xml

<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <groupId>SpringActiveMQ</groupId> <artifactId>SpringActiveMQ</artifactId> <version>1.0-SNAPSHOT</version> <properties> <!-- spring版本号 --> <spring.version>4.3.5.RELEASE</spring.version> </properties> <dependencies> <dependency> <groupId>junit</groupId> <artifactId>junit</artifactId> <version>4.11</version> <scope>test</scope> </dependency> <!--activeMQ--> <dependency> <groupId>org.apache.activemq</groupId> <artifactId>activemq-all</artifactId> <version>5.2.0</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-jms</artifactId> <version>${spring.version}</version> </dependency> <!-- 添加spring核心依赖 --> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-core</artifactId> <version>${spring.version}</version> <exclusions> <exclusion> <artifactId>commons-logging</artifactId> <groupId>commons-logging</groupId> </exclusion> </exclusions> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-web</artifactId> <version>${spring.version}</version> <exclusions> <exclusion> <artifactId>spring-beans</artifactId> <groupId>org.springframework</groupId> </exclusion> </exclusions> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-oxm</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-tx</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-jdbc</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-webmvc</artifactId> <version>${spring.version}</version> <exclusions> <exclusion> <artifactId>spring-expression</artifactId> <groupId>org.springframework</groupId> </exclusion> </exclusions> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-context</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-context-support</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-aop</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-test</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.apache.xbean</groupId> <artifactId>xbean-spring</artifactId> <version>4.0</version> </dependency> <dependency> <groupId>org.apache.xbean</groupId> <artifactId>xbean-spring</artifactId> <version>4.0</version> </dependency> </dependencies> </project>