在使用原生ActiveMQ的API编程 中，我们讲述了ActiveMQ的原生API方式的使用，这里我们再来介绍下ActivaMQ与Spring结合，首先肯定是需要引入相关的依赖

<dependency><groupId>org.apache.activemq</groupId><artifactId>activemq-all</artifactId><version>5.15.7</version>
</dependency>

这里除了引入activemq的依赖，还需要引入spring-jms，如下：

<dependency><groupId>org.springframework</groupId><artifactId>spring-jms</artifactId><version>5.2.6.RELEASE</version>
</dependency>

这里需要注意的是，可能会由于项目使用的Spring的版本问题，比如Spring需要使用JMS 2.0版本，但spring-jms的依赖没有自动导入JMS 2.0，而activemq-core会导入JMS 1.1的依赖，这就导致出现版本问题，所以这里我们需要引入JMS 2.0 依赖，同时为了避免包发送冲突，建议可以从activemq-all中去除JMS 1.1

<dependency><groupId>javax.jms</groupId><artifactId>javax.jms-api</artifactId><version>2.0.1</version>
</dependency><dependency><groupId>org.apache.activemq</groupId><artifactId>activemq-all</artifactId><version>5.15.7</version><exclusions><exclusion><artifactId>spring-context</artifactId><groupId>org.springframework</groupId></exclusion><exclusion><groupId>org.apache.geronimo.specs</groupId><artifactId>geronimo-jms_1.1_spec</artifactId></exclusion></exclusions>
</dependency>

解决好pom文件的依赖，接下来来查看其项目结构，如下：

首先我们就先来看一看消息的生产者，即producer模块，这里主要查看下applicationContext.xml 的配置文件，如下：

<?xml version="1.0" encoding="UTF-8"?>
<!-- 查找最新的schemaLocation 访问 http://www.springframework.org/schema/ -->
<beans xmlns="http://www.springframework.org/schema/beans"xmlns:context="http://www.springframework.org/schema/context"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xmlns:amq="http://activemq.apache.org/schema/core"xsi:schemaLocation="http://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans-4.1.xsdhttp://www.springframework.org/schema/contexthttp://www.springframework.org/schema/context/spring-context-4.1.xsdhttp://activemq.apache.org/schema/corehttp://activemq.apache.org/schema/core/activemq-core-5.15.7.xsd"><!-- 配置扫描路径 --><context:component-scan base-package="com.kami"/><!-- ActiveMQ连接工厂 --><amq:connectionFactory id="amqConnectionFactory" brokerURL="tcp://127.0.0.1:61616" userName="" password=""/><!-- Spring Caching连接工厂 --><!-- Spring用于管理真正的ConnectionFactory的ConnectionFactory --><bean id="connectionFactory" class="org.springframework.jms.connection.CachingConnectionFactory"><property name="targetConnectionFactory" ref="amqConnectionFactory"/><property name="sessionCacheSize" value="100"/></bean><!-- Spring JmsTemplate的消息生产者--><!-- 定义JmsTemplate的Queue类型 --><bean id="jmsQueueTemplate" class="org.springframework.jms.core.JmsTemplate"><constructor-arg ref="connectionFactory"/><!-- 点对点Queue模式--><property name="pubSubDomain" value="false"/></bean><!-- 定义JmsTemplate的Topic类型 --><bean id="jmsTopicTemplate" class="org.springframework.jms.core.JmsTemplate"><constructor-arg ref="connectionFactory"/><!-- 发布订阅Topic模式--><property name="pubSubDomain" value="true"/></bean></beans>

这里需要注意一点，就是在applicationContext.xml的命名空间中，我们需要加上activemq相关的标签

然后我们就是在其中进行配置连接工产，然后就会将其交给Spring进行管理，然后我们只需要使用Spring提供的JmsTemplate即可，上述就即配置了Topic模式的JmsTemplate 和 Queue模式的JmsTemplate的Bean

接下来在MessageSender中使用时，我们只需要将想要使用模式的Bean进行注入即可，另外在发送消息时不要忘记添加消息发送的目的地Destination

@Component
public class MessageSender {@Resource(name = "jmsQueueTemplate")private JmsTemplate queueTemplate;@Autowired@Qualifier("jmsTopicTemplate")private JmsTemplate topicTemplate;public void sendQueueMsg(){queueTemplate.send("test.queue", new MessageCreator() {@Overridepublic Message createMessage(Session session) throws JMSException {TextMessage textMessage = session.createTextMessage("Hello Queue");return textMessage;}});}public void sendTopicMsg(){topicTemplate.send("test.topic", new MessageCreator() {@Overridepublic Message createMessage(Session session) throws JMSException {TextMessage textMessage = session.createTextMessage("Hello Topic");return textMessage;}});}
}

以上我们的消息生产者就完成了，我们就可以运行测试类，进行测试，测试类ProducerTest如下：

public class ProducerTest {@Testpublic void testProducer(){ClassPathXmlApplicationContext applicationContext = new ClassPathXmlApplicationContext("classpath:conf/applicationContext.xml");applicationContext.start();MessageSender messageSender = applicationContext.getBean(MessageSender.class);messageSender.sendQueueMsg();messageSender.sendTopicMsg();}
}

---

接下来就是我们的消息消费者，同样的也是主要看其配置文件applicationContext.xml，如下：

<?xml version="1.0" encoding="UTF-8"?>
<!-- 查找最新的schemaLocation 访问 http://www.springframework.org/schema/ -->
<beans xmlns="http://www.springframework.org/schema/beans"xmlns:context="http://www.springframework.org/schema/context"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xmlns:jms="http://www.springframework.org/schema/jms"xmlns:amq="http://activemq.apache.org/schema/core"xsi:schemaLocation="http://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans-4.1.xsdhttp://www.springframework.org/schema/contexthttp://www.springframework.org/schema/context/spring-context-4.1.xsdhttp://www.springframework.org/schema/jmshttp://www.springframework.org/schema/jms/spring-jms-4.1.xsdhttp://activemq.apache.org/schema/corehttp://activemq.apache.org/schema/core/activemq-core-5.15.7.xsd"><!-- 配置扫描路径 --><context:component-scan base-package="com.kami"/><!-- ActiveMQ连接工厂 --><amq:connectionFactory id="amqConnectionFactory" brokerURL="tcp://127.0.0.1:61616" userName="" password=""/><!-- Spring Caching连接工厂 --><!-- Spring用于管理真正的ConnectionFactory的ConnectionFactory --><bean id="connectionFactory" class="org.springframework.jms.connection.CachingConnectionFactory"><property name="targetConnectionFactory" ref="amqConnectionFactory"/><property name="sessionCacheSize" value="100"/></bean><!-- 定义消息消费者--><!-- 定义Topic监听器 --><jms:listener-container destination-type="topic" container-type="default"connection-factory="connectionFactory" acknowledge="auto"><jms:listener destination="test.topic" ref="topicConsumer1"/><jms:listener destination="test.topic" ref="topicConsumer2"/></jms:listener-container><!-- 定义Queue监听器 --><jms:listener-container destination-type="queue" container-type="default"connection-factory="connectionFactory" acknowledge="auto"><jms:listener destination="test.queue" ref="queueConsumer1"/><jms:listener destination="test.queue" ref="queueConsumer2"/></jms:listener-container></beans>

其中需要注意的就是在消费者的配置文件中，我们需要额外多加入几个命名空间的标签

其余配置连接工产之类的，和消息的提供者配置一致，然后就是在其中需要添加Topic模式或者Queue模式的监听器了，两种配置我们依据destination-type="topic/queue" 进行区分

其中我们还需要指定区分的消息目的地Destination，其次其配置的ref就是我们监听消息后进行处理的Bean了，这里我们对topic和queue分别配置了两个（可以在多个项目中进行配置多个监听器，这里就在新建其它项目了）

@Component
public class TopicConsumer1 implements MessageListener {@Overridepublic void onMessage(Message message) {TextMessage textMessage = (TextMessage) message;try {System.out.println(textMessage.getText());} catch (JMSException e) {e.printStackTrace();}}
}

@Component
public class TopicConsumer2 implements MessageListener {@Overridepublic void onMessage(Message message) {TextMessage textMessage = (TextMessage) message;try {System.out.println(textMessage.getText());} catch (JMSException e) {e.printStackTrace();}}
}

@Component
public class QueueConsumer1 implements MessageListener {@Overridepublic void onMessage(Message message) {TextMessage textMessage = (TextMessage) message;try {System.out.println(textMessage.getText());} catch (JMSException e) {e.printStackTrace();}}
}

@Component
public class QueueConsumer2 implements MessageListener {@Overridepublic void onMessage(Message message) {TextMessage textMessage = (TextMessage) message;try {System.out.println(textMessage.getText());} catch (JMSException e) {e.printStackTrace();}}
}

配置的四个监听器其实都是一样的，就是打印出消费的消息内容而已，然后我们可以进行测试了，测试类ConsumerTest如下：

public class ConsumerTest {@Testpublic void testConsumer() throws IOException {ClassPathXmlApplicationContext applicationContext = new ClassPathXmlApplicationContext("classpath:conf/applicationContext.xml");applicationContext.start();System.in.read();}
}