MQ開發其實很簡單：

本文以最新版本的ActiveMQ為例子，介紹了安裝和開發第一個MQ程式。

準備環境，JDK8，activeMQ 5.14.3，WIN7測試環境，Spring 4.3.4

首先是安裝 :

安裝MQ非常簡單，下載連結：https://activemq.apache.org/download.html

如果，系統的java環境沒有配置錯誤，執行D:\greenPro\mq514\bin\win64下的

activemq.bat

即可啟動成功。

啟動完成後，可以本地訪問mq控制檯：

http://localhost:8161/

預設使用者名稱和密碼：

admin/admin

點選：Manage ActiveMQ broker就可以進入佇列配置介面：

這裡我定義了一個自己的佇列myQuery1,便於後面開發和測試：

為了簡化原來程式，做了以下改進，去掉了無用的郵件傳送類和執行緒池，將客戶端和服務端程式碼整合在一起了。

修改了pom.xml更新為最新的依賴包，去掉了一些無用的包。

最新原始碼上傳於我的空間：

如果要只發送不接收，則可以註釋掉spring-mq.xml最後幾行，禁止ConsumerSessionAwareMessageListener啟動，測試訊息堆積於佇列中的情況。

<?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:p="http://www.springframework.org/schema/p"
    xmlns:context="http://www.springframework.org/schema/context"
    xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"
    xsi:schemaLocation="http://www.springframework.org/schema/beans  
           http://www.springframework.org/schema/beans/spring-beans-3.2.xsd  
           http://www.springframework.org/schema/aop   
           http://www.springframework.org/schema/aop/spring-aop-3.2.xsd  
           http://www.springframework.org/schema/tx  
           http://www.springframework.org/schema/tx/spring-tx-3.2.xsd  
           http://www.springframework.org/schema/context  
           http://www.springframework.org/schema/context/spring-context-3.2.xsd"
    default-autowire="byName" default-lazy-init="false">
    
    <!-- 基於Dubbo的分散式系統架構視訊教程，吳水成，

[email protected]，學習交流QQ群：367211134 -->

    <!-- 真正可以產生Connection的ConnectionFactory，由對應的 JMS服務廠商提供 -->
    <bean id="targetConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
        <!-- ActiveMQ服務地址 -->
        <property name="brokerURL" value="${mq.brokerURL}" />
        <property name="userName" value="${mq.userName}"></property>
        <property name="password" value="${mq.password}"></property>
    </bean>

    <!--
        ActiveMQ為我們提供了一個PooledConnectionFactory，通過往裡面注入一個ActiveMQConnectionFactory
        可以用來將Connection、Session和MessageProducer池化，這樣可以大大的減少我們的資源消耗。
        要依賴於 activemq-pool包
     -->
    <bean id="pooledConnectionFactory" class="org.apache.activemq.pool.PooledConnectionFactory">
        <property name="connectionFactory" ref="targetConnectionFactory" />
        <property name="maxConnections" value="${mq.pool.maxConnections}" />
    </bean>

    <!-- Spring用於管理真正的ConnectionFactory的ConnectionFactory -->
    <bean id="connectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory">
        <!-- 目標ConnectionFactory對應真實的可以產生JMS Connection的ConnectionFactory -->
        <property name="targetConnectionFactory" ref="pooledConnectionFactory" />
    </bean>
    
    <!-- Spring提供的JMS工具類，它可以進行訊息傳送、接收等 -->
    
    <!-- 佇列模板 -->
    <bean id="activeMqJmsTemplate" class="org.springframework.jms.core.JmsTemplate">  
        <!-- 這個connectionFactory對應的是我們定義的Spring提供的那個ConnectionFactory物件 -->  
        <property name="connectionFactory" ref="connectionFactory"/>  
        <property name="defaultDestinationName" value="${queueName}"></property>
    </bean>


<!--這個是sessionAwareQueue目的地 -->
    <bean id="sessionAwareQueue" class="org.apache.activemq.command.ActiveMQQueue">
        <constructor-arg>
            <value>${queueName}</value>
        </constructor-arg>
    </bean>

     <!-- 可以獲取session的MessageListener -->
<!--     <bean id="consumerSessionAwareMessageListener" class="wusc.edu.demo.mqtest.listener.ConsumerSessionAwareMessageListener"></bean> -->

<!--     <bean id="sessionAwareListenerContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer"> -->
<!--         <property name="connectionFactory" ref="connectionFactory" /> -->
<!--         <property name="destination" ref="sessionAwareQueue" /> -->
<!--         <property name="messageListener" ref="consumerSessionAwareMessageListener" /> -->
<!--     </bean> -->
</beans>

紅字部分為註釋掉的內容。

反覆執行MQProducerTest，可以不斷髮訊息，佇列堆積後，可以從管理控制檯看到：

需要接收訊息，將紅色註釋開啟，再次執行MQProducerTest，就可以了。從控制檯看到輸出內容如下：

一月 16, 2017 3:58:24 下午 org.springframework.context.support.ClassPathXmlApplicationContext prepareRefresh
資訊: Refreshing org[email protected]7a07c5b4: startup date [Mon Jan 16 15:58:24 CST 2017]; root of context hierarchy
一月 16, 2017 3:58:24 下午 org.springframework.beans.factory.xml.XmlBeanDefinitionReader loadBeanDefinitions
資訊: Loading XML bean definitions from class path resource [spring/spring-context.xml]
一月 16, 2017 3:58:24 下午 org.springframework.beans.factory.xml.XmlBeanDefinitionReader loadBeanDefinitions
資訊: Loading XML bean definitions from class path resource [spring/spring-mq.xml]
一月 16, 2017 3:58:24 下午 org.springframework.beans.factory.support.DefaultListableBeanFactory registerBeanDefinition
資訊: Overriding bean definition for bean 'consumerSessionAwareMessageListener' with a different definition: replacing [Generic bean: class [wusc.edu.demo.mqtest.listener.ConsumerSessionAwareMessageListener]; scope=singleton; abstract=false; lazyInit=false; autowireMode=1; dependencyCheck=0; autowireCandidate=true; primary=false; factoryBeanName=null; factoryMethodName=null; initMethodName=null; destroyMethodName=null; defined in file [D:\worksapce2MVN\MyJava\target\classes\wusc\edu\demo\mqtest\listener\ConsumerSessionAwareMessageListener.class]] with [Generic bean: class [wusc.edu.demo.mqtest.listener.ConsumerSessionAwareMessageListener]; scope=; abstract=false; lazyInit=false; autowireMode=1; dependencyCheck=0; autowireCandidate=true; primary=false; factoryBeanName=null; factoryMethodName=null; initMethodName=null; destroyMethodName=null; defined in class path resource [spring/spring-mq.xml]]
一月 16, 2017 3:58:24 下午 org.springframework.context.support.PropertySourcesPlaceholderConfigurer loadProperties
資訊: Loading properties file from class path resource [mq.properties]
SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
SLF4J: Defaulting to no-operation (NOP) logger implementation
SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.
一月 16, 2017 3:58:25 下午 org.springframework.context.support.DefaultLifecycleProcessor start
資訊: Starting beans in phase 2147483647
一月 16, 2017 3:58:25 下午 org.springframework.jms.connection.SingleConnectionFactory initConnection
資訊: Established shared JMS Connection: PooledConnection { ConnectionPool[ActiveMQConnection {id=ID:zhouxj-PC-58711-1484553505143-1:1,clientId=null,started=false}] }
一月 16, 2017 3:58:25 下午 org.springframework.context.support.DefaultLifecycleProcessor start
資訊: Starting beans in phase 2147483647
==>receive message:{"content":"通過ActiveMQ非同步傳送郵件！0.05456176353420983","subject":"ActiveMQ測試34234","to":"[email protected]"}
一月 16, 2017 3:58:25 下午 wusc.edu.demo.mqtest.listener.ConsumerSessionAwareMessageListener onMessage
資訊: ==>receive message:{"content":"通過ActiveMQ非同步傳送郵件！0.05456176353420983","subject":"ActiveMQ測試34234","to":"[email protected]"}
Reciver2:通過ActiveMQ非同步傳送郵件！0.05456176353420983
一月 16, 2017 3:58:25 下午 wusc.edu.demo.mqtest.listener.ConsumerSessionAwareMessageListener onMessage
資訊: ==>receive message:{"content":"通過ActiveMQ非同步傳送郵件！0.25300105506652026","subject":"ActiveMQ測試34234","to":"[email protected]"}
一月 16, 2017 3:58:25 下午 wusc.edu.demo.mqtest.listener.ConsumerSessionAwareMessageListener onMessage
資訊: ==>receive message:{"content":"通過ActiveMQ非同步傳送郵件！0.33069073442419183","subject":"ActiveMQ測試34234","to":"[email protected]"}
一月 16, 2017 3:58:25 下午 wusc.edu.demo.mqtest.listener.ConsumerSessionAwareMessageListener onMessage
資訊: ==>receive message:{"content":"通過ActiveMQ非同步傳送郵件！0.9560044771945856","subject":"ActiveMQ測試34234","to":"[email protected]"}
一月 16, 2017 3:58:25 下午 wusc.edu.demo.mqtest.listener.ConsumerSessionAwareMessageListener onMessage
資訊: ==>receive message:{"content":"通過ActiveMQ非同步傳送郵件！0.1364193001852111","subject":"ActiveMQ測試34234","to":"[email protected]"}
一月 16, 2017 3:58:25 下午 wusc.edu.demo.mqtest.listener.ConsumerSessionAwareMessageListener onMessage
資訊: ==>receive message:{"content":"通過ActiveMQ非同步傳送郵件！0.7340194987950655","subject":"ActiveMQ測試34234","to":"[email protected]"}
send:通過ActiveMQ非同步傳送郵件！0.7340194987950655
==>receive message:{"content":"通過ActiveMQ非同步傳送郵件！0.25300105506652026","subject":"ActiveMQ測試34234","to":"[email protected]"}
Reciver2:通過ActiveMQ非同步傳送郵件！0.25300105506652026
==>receive message:{"content":"通過ActiveMQ非同步傳送郵件！0.33069073442419183","subject":"ActiveMQ測試34234","to":"[email protected]"}
Reciver2:通過ActiveMQ非同步傳送郵件！0.33069073442419183
==>receive message:{"content":"通過ActiveMQ非同步傳送郵件！0.9560044771945856","subject":"ActiveMQ測試34234","to":"[email protected]"}
Reciver2:通過ActiveMQ非同步傳送郵件！0.9560044771945856
==>receive message:{"content":"通過ActiveMQ非同步傳送郵件！0.1364193001852111","subject":"ActiveMQ測試34234","to":"[email protected]"}
Reciver2:通過ActiveMQ非同步傳送郵件！0.1364193001852111
==>receive message:{"content":"通過ActiveMQ非同步傳送郵件！0.7340194987950655","subject":"ActiveMQ測試34234","to":"[email protected]"}
Reciver2:通過ActiveMQ非同步傳送郵件！0.7340194987950655
一月 16, 2017 3:58:25 下午 org.springframework.context.support.DefaultLifecycleProcessor stop
資訊: Stopping beans in phase 2147483647
一月 16, 2017 3:58:26 下午 wusc.edu.demo.mqtest.MQProducerTest main
資訊: ===>System.exit

附件Maven依賴包截圖：