Spring整合activeMQ方法
1.匯入座標

<dependency>
        <groupId>org.apache.activemq</groupId>
        <artifactId>activemq-all</artifactId>
        <version>5.14.0</version>
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId
 
>
        <artifactId>spring-jms</artifactId>
        <version>4.3.3.RELEASE</version>
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-context</artifactId>
        <version>4.3.3.RELEASE</version
 
>
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-context-support</artifactId>
        <version>4.3.3.RELEASE</version>
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId
 
>
        <artifactId>spring-web</artifactId>
        <version>4.3.3.RELEASE</version>
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-test</artifactId>
        <version>4.3.3.RELEASE</version>
    </dependency>
    <dependency>
        <groupId>junit</groupId>
        <artifactId>junit</artifactId>
        <version>4.12</version>
    </dependency>

2.web.xml中配置核心監聽器

<!-- spring配置檔案位置 -->
<context-param>
<param-name>contextConfigLocation</param-name>
<param-value>classpath:applicationContext.xml</param-value>
</context-param>
<!-- spring核心監聽器 -->
<listener><listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
</listener>

3.分別建立生產者和消費者的applicationContext.xml檔案,主xml檔案中引入

4.在生產者和消費者的applicationContext檔案裡面都配置如下
4.1ActiveMQ工廠配置

<!-- ActiveMQ 連線工廠 -->
    <!-- 真正可以產生Connection的ConnectionFactory，由對應的 JMS服務廠商提供-->
    <!-- 如果連線網路：tcp://ip:61616；未連線網路：tcp://localhost:61616 以及使用者名稱，密碼-->
    <amq:connectionFactory id="ConnectionFactoryamq"
        brokerURL="tcp://localhost:61616"  userName="admin" password="admin"/>

4.2spring 整合 ActiveMQ

   <!-- Spring Caching連線工廠 -->
    <!-- Spring用於管理真正的ConnectionFactory的ConnectionFactory -->  
    <bean id="ConnectionFactory" class="org.springframework.jms.connection.CachingConnectionFactory">
        <!-- 目標ConnectionFactory對應真實的可以產生JMS Connection的ConnectionFactory -->  
        <property name="targetConnectionFactory" ref="ConnectionFactoryamq"></property>
        <!-- 同上，同理 -->
        <!-- <constructor-arg ref="amqConnectionFactory" /> -->
        <!-- Session快取數量 -->
        <property name="sessionCacheSize" value="100" />
    </bean>

4.2.1activeMQ配置生產者

<!-- 配置生產者模板 -->
     <!-- 定義JmsTemplate的Queue型別 -->
    <bean id="jmsQueueTemplate" class="org.springframework.jms.core.JmsTemplate">
        <!-- 這個connectionFactory對應的是我們定義的Spring提供的那個ConnectionFactory物件 -->  
        <constructor-arg ref="ConnectionFactory" /> <引入spring整合的工廠>
        <!-- 非pub/sub模型（釋出/訂閱），即佇列模式 -->
        <property name="pubSubDomain" value="false" />
    </bean>

    <!-- 定義JmsTemplate的Topic型別 -->
    <bean id="jmsTopicTemplate" class="org.springframework.jms.core.JmsTemplate">
         <!-- 這個connectionFactory對應的是我們定義的Spring提供的那個ConnectionFactory物件 -->  
        <constructor-arg ref="ConnectionFactory" />
        <!-- pub/sub模型（釋出/訂閱） -->
        <property name="pubSubDomain" value="true" />
    </bean>

4.2.2activeMQ配置消費者

<!-- 配置消費者監聽 -->
    <jms:listener-container destination-type="queue" container-type="default" 
        connection-factory="ConnectionFactory" acknowledge="auto">
        <!-- 預設註冊bean名稱，應該是類名首字母小寫  -->
        <jms:listener destination="queue_name" ref="activeConsumersQueue"/>
         <jms:listener destination="queue_name" ref="activeConsumersQueue1"/>
    </jms:listener-container>
注:destination屬性內容引數為具體監聽釋出訊息名字   
 ref屬性為消費者實體類的類名首字母小寫,如果在實體類註解上配置了具體name,ref屬性就為具體的name屬性


    <!-- 配置消費者監聽 -->
    <jms:listener-container destination-type="topic" container-type="default" 
        connection-factory="ConnectionFactory" acknowledge="auto">
        <!-- 預設註冊bean名稱，應該是類名首字母小寫  -->
        <jms:listener destination="topic_name" ref="activeConsumersTopic"/>
         <jms:listener destination="topic_name" ref="activeConsumersTopic2"/>
    </jms:listener-container>

5.生產者實體類配置

@Service
public class ActiveMQTopic {

    @Autowired
    @Qualifier("jmsTopicTemplate")   //具體實現queue或者topic由applicationContext.xml中配置的生產者模板決定
    private JmsTemplate jmsTemplate;

    public void topicmessage(String name,final String message) {
        jmsTemplate.sendAndReceive(name, new MessageCreator() {

            public Message createMessage(Session arg0) throws JMSException {
                return arg0.createTextMessage(message);
            }
        });
    }
}

6.消費者實體類配置
6.1消費者類實現MessageListener介面

public class ActiveConsumersQueue implements MessageListener{

    public void onMessage(Message message) {
        TextMessage text=(TextMessage) message;
        try {
            System.out.println("ActiveConsumersQueue"+text.getText());
        } catch (JMSException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
}