• 訊息佇列MQ簡介
  訊息佇列技術是分散式應用間交換資訊的一種技術。使用訊息佇列可以很好的將任務以非同步的方式進行處理或者進行資料傳送和儲存等。例如當你頻繁地向資料庫中插入資料、頻繁的向搜尋引擎提交資料，就可採取訊息佇列來非同步插入。另外，還可以將較慢/較複雜的處理邏輯、有併發數量限制的處理邏輯，通過訊息佇列放在後臺處理。
  常規的使用場景：簡訊服務、電子郵件服務、圖片處理服務、好友動態推送服務等。
  特性：非同步、順序讀寫、高效能、協議簡單。所以一般會用於解決大量的伺服器端非同步請求，同時可以實現服務端的負載均衡和業務的容災。

  1. ActiveMQ簡介

       ActiveMQ 是Apache出品，最流行的，能力強勁的開源訊息匯流排。ActiveMQ 是一個完全支援JMS1.1和J2EE 1.4規範的 JMS Provider實現，儘管JMS規範出臺已經是很久的事情了，但是JMS在當今的J2EE應用中間仍然扮演著特殊的地位
      
     

• 訊息模型： 點對點(p2p)、釋出/廣播(Pub/Sub)。

• 流程：
  p2p：訊息生產者>訊息佇列>訊息消費者

  Pub/Sub：主題>釋出者>訂閱者

  1. ActiveMQ準備

  apache官網下載activeMQ：

進行解壓後執行其bin目錄下面的win32或者win64資料夾下的activemq.bat檔案啟動activeMQ。

• Maven配置

        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId
 
>spring-jms</artifactId>
            <version>4.1.1.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.apache.activemq</groupId>
            <artifactId>activemq-core</artifactId>
            <version>5.7.0</version
 
>
        </dependency>

配置connectionFactory
connectionFactory是Spring用於建立到JMS伺服器連結的，Spring提供了多種connectionFactory.

PooledConnectionFactory： JmsTemlate每次傳送訊息時只會快取connection，session和productor，不會快取consumer。因此只適合於生產者傳送訊息,這個只是在要求訊息處理的及時性不是特別高的情況下。

SingleConnectionFactory： 對於建立JMS伺服器連結的請求會一直返回同一個連結，並且會忽略Connection的close方法呼叫。

CachingConnectionFactory： 繼承了SingleConnectionFactory，所以它擁有SingleConnectionFactory的所有功能，同時它還新增了快取功能，它可以快取Session、MessageProducer和MessageConsumer。我們使用CachingConnectionFactory來作為示例。

1. Spring配置

   applicationContext.xml 設定：

    <!-- 獲取ActiveMQ提供的ConnectionFactory -->
    <amq:connectionFactory id="amqConnectionFactory"
    <!--設定ActiveMQ伺服器地址及埠-->
        brokerURL="failover:(tcp://localhost:61616)?initialReconnectDelay=100" />

    <!-- 配置ActiveMQ伺服器連線conneciotnFactory -->
    <bean id="connectionFactory"
        class="org.springframework.jms.connection.CachingConnectionFactory">
        <!-- 將ActiveMQ提供的ConnectionFactory注入到Spring管理的connectionFactory中 -->
        <constructor-arg ref="amqConnectionFactory" />
        <!--設定快取大小-->
        <property name="sessionCacheSize" value="100" />
    </bean>

    <!-- 配置JMS訊息生產者 -->
    <!-- Spring提供的JMS工具類，它可以進行訊息傳送、接收等 -->
    <bean id="jmsQueueTemplate" class="org.springframework.jms.core.JmsTemplate">
        <constructor-arg ref="connectionFactory" />
        <!-- 非pub/sub模型（釋出/訂閱），即佇列模式 -->
        <property name="pubSubDomain" value="false" />
    </bean>

    <!-- 定義Queue監聽器 -->
    <jms:listener-container concurrency="10"
        destination-type="queue" container-type="default" connection-factory="connectionFactory" acknowledge="auto">
        <!--監聽的java類-->
        <jms:listener destination="queue" ref="ConsumerMessageListener" />
    </jms:listener-container>

5. **JAVA程式碼**  

**實現傳送訊息到訊息佇列**

@Service("ProducerService")
public class ProducerServiceImpl{

    @Autowired
    private JmsTemplate jmsQueueTemplate;

    public void sendMessage(String destinationName, final String message) {
        System.out.println("------生產者傳送訊息------");
        System.out.println("------生產者發了一個訊息：" + message);
        jmsQueueTemplate.send(destinationName, new MessageCreator() {
            public Message createMessage(Session session) throws JMSException {
                // TODO Auto-generated method stub
                return session.createTextMessage(message);
            }
        });
    }

}

實現訊息監聽，獲取訊息並消費

@Component("ConsumerMessageListener")
public class ConsumerMessageListener implements MessageListener {

    public void onMessage(Message message) {
        // TODO Auto-generated method stub
        TextMessage textMsg = (TextMessage) message;
        System.out.println("接收到一個純文字訊息.");
        try {
            System.out.println("訊息內容是：" + textMsg.getText());
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

}