activemq是一款JMS消息隊列的服務產(chǎn)品。其出品公司是大家所知的Apache。具體介紹大家自行百度吧，本文著重講解spring+activemq的整合。

1、安裝activemq##

1)windows環(huán)境安裝####

**從http://activemq.apache.org/官網(wǎng)處下載apache-activemq-5.14.0.zip。****解壓之后，目錄結構如下：

然后打開bin目錄下，如果屬于32位的電腦，運行win32/activemq.bat,如果屬于64位的電腦，運行win64/activemq.bat即可啟動（前提是需要安裝JDK。沒有JDK環(huán)境的同學請自行安裝JDK）。
運行成功結果如下：

運行成功之后不要關閉。（mq運行期間不能關閉此頁面）
打開瀏覽器地址欄輸入：http://localhost:8161/admin/
默認用戶名密碼都是admin.
進入管理頁面如下：

2）、CentOS(Linux)安裝####

從http://activemq.apache.org/官網(wǎng)處下載apache-activemq-5.14.4-bin.tar.gz，rz至/home/（路徑可自行選擇）

tar -zxvf apache-activemq-5.14.4-bin.tar.gz

cd apache-activemq-5.14.4/bin

./activemq start

即可啟動mq。

2、整合Spring##

首先創(chuàng)建activemq.properties

mq.url=tcp://localhost:61616
mq.uername=admin
mq.password=admin
shopQueue=shop.topic
apQueue=ap.topic
userQueue=user.topic

然后創(chuàng)建spring-activemq.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:jms="http://www.springframework.org/schema/jms" xmlns:amq="http://activemq.apache.org/schema/core"
       xsi:schemaLocation="http://www.springframework.org/schema/jms http://www.springframework.org/schema/jms/spring-jms-3.1.xsd
        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-3.1.xsd http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd">
     <!--配置文件-->
    <context:property-placeholder location="classpath:activemq.properties" ignore-unresolvable="true"  />
      <!--創(chuàng)建連接工廠-->
    <bean id="connectionFactory" class="org.apache.activemq.spring.ActiveMQConnectionFactory">
        <property name="brokerURL" value="${mq.url}" />
        <property name="userName" value="${mq.username}"/>
        <property name="password" value="${mq.password}"/>
        <property name="useAsyncSend" value="true" />
    </bean>

      <!--配置監(jiān)聽模板，pubSubDomain=true代表用Topic主題訂閱模式，默認是false（隊列模式）-->
    <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
        <property name="connectionFactory" ref="connectionFactory" />
        <property name="pubSubDomain" value="true" />
    </bean>
      <!--定義topic1-->
    <bean id="apTopic" class="org.apache.activemq.command.ActiveMQTopic">
        <constructor-arg value="${apQueue}" />
    </bean>
    <!--定義topic2-->
    <bean id="shopTopic" class="org.apache.activemq.command.ActiveMQTopic">
        <constructor-arg value="${shopQueue}" />
    </bean>
      <!--定義topic3-->
    <bean id="userTopic" class="org.apache.activemq.command.ActiveMQTopic">
        <constructor-arg value="${userQueue}" />
    </bean>
      <!--分別定義topic的監(jiān)聽類-->
    <bean id="shopMessageListener" class="com.riil.its.bysy.attendance.jms.ShopMessageListener"</bean>
    <bean id="apMessageListener" class="com.riil.its.bysy.attendance.jms.ApMessageListener"></bean>
    <bean id="userMessageListener" class="com.riil.its.bysy.attendance.jms.UserMessageListener"></bean>

    <jms:listener-container>
        <jms:listener destination="apTopic" ref="apMessageListener" />
        <jms:listener destination="shopTopic" ref="shopMessageListener" />
        <jms:listener destination="userTopic" ref="userMessageListener" />
    </jms:listener-container>

      <!--監(jiān)聽容器1-->
    <bean id="jmsContainer1"
          class="org.springframework.jms.listener.DefaultMessageListenerContainer">
      <!--指定連接工廠-->
        <property name="connectionFactory" ref="connectionFactory" />
      <!--指定Topic-->
        <property name="destination" ref="apTopic" />
      <!--客戶端ID，配置持久訂閱者必須指定一個clientId的值-->
        <property name="clientId" value="clientId_001"/>
      <!--指定監(jiān)聽類-->
        <property name="messageListener" ref="apMessageListener" />
      <!--訂閱topic模式-->
        <property name="pubSubDomain" value="true"/><!-- default is false -->
      <!--表示是一個持久訂閱者，-->
        <property name="subscriptionDurable" value="true"/>
        </bean>
      <!--監(jiān)聽容器2-->
    <bean id="jmsContainer2"
          class="org.springframework.jms.listener.DefaultMessageListenerContainer">
        <property name="connectionFactory" ref="connectionFactory" />
        <property name="destination" ref="shopTopic" />
        <property name="clientId" value="clientId_002"/>
        <property name="messageListener" ref="shopMessageListener" />
        <property name="pubSubDomain" value="true"/><!-- default is false -->
        <property name="subscriptionDurable" value="true"/>
    </bean>
         <!--監(jiān)聽容器3-->
    <bean id="jmsContainer3"
          class="org.springframework.jms.listener.DefaultMessageListenerContainer">
        <property name="connectionFactory" ref="connectionFactory" />
        <property name="destination" ref="userTopic" />
        <property name="clientId" value="clientId_003"/>
        <property name="messageListener" ref="userMessageListener" />
        <property name="pubSubDomain" value="true"/><!-- default is false -->
        <property name="subscriptionDurable" value="true"/>
    </bean>
</beans>

此時，spring+mvc整合基本完成。