1.JMS簡介：

    Java 訊息服務（ Java Message Service  ， JMS ）是一個 Java 標準，定義了使用訊息代理的通用API 。在 JMS 出現之前，每個訊息代理都有私有的 API ，這就使得不同代理之間的訊息程式碼很難通用。但是藉助 JMS ，所有遵從規範的實現都使用通用的介面，這就類似於 JDBC 為資料庫操作提供了通用的介面一樣。Spring 通過基於模板的抽象為 JMS 功能提供了支援，這個模板也就是 JmsTemplate 。使用 JmsTemplate ，能夠非常容易地在訊息生產方傳送佇列和主題訊息，在消費訊息的那一方,也能夠非常容易地接收這些訊息。 Spring 還提供了訊息驅動 POJO 的理念：這是一個簡單的 Java 物件，它能夠以非同步的方式響應佇列或主題上到達的訊息。

二.安裝訊息代理activemq

    ActiveMQ 是一個偉大的開源訊息代理產品，也是使用 JMS 進行非同步訊息傳遞的最佳選擇。在開始使用 ActiveMQ 之前，我們需要從 http://activemq.apache.org 下載二進位制發行包。下載完 ActiveMQ 後，我們將其解壓縮到本地硬碟中。在解壓目錄中，我們會找到檔案 activemq-core-5.9.1.jar 。為了能夠使用 ActiveMQ 的 API ，我們需要將此 JAR 檔案新增到應用程式的類路徑中。安裝完成解壓縮會有下面目錄結構：

執行bin目錄下的activemq.bat出現下面結果表明安裝成功：

三：spring配置JMS

                專案目錄結構    

第一步：建立實體類

package chapter17.domain;

import java.io.Serializable;


public class JinNang implements Serializable{
	private static final long serialVersionUID = 1L; 	
	private String jice;//計策
	private String people;//計策實施者
	
	public JinNang(){}
	
	public JinNang(String jice,String people){
		this.jice=jice;
		this.people=people;
	}

	public String getJice() {
		return jice;
	}

	public void setJice(String jice) {
		this.jice = jice;
	}

	public String getPeople() {
		return people;
	}

	public void setPeople(String people) {
		this.people = people;
	}
}
 

第二步：建立service介面和實現類

package chapter17.service.interfaces;

public interface JinNangService {
	public abstract void sendJinNang();

}

service實現類：

package chapter17.service;

import org.springframework.jms.core.JmsOperations;
import chapter17.domain.JinNang;
import chapter17.service.interfaces.JinNangService;

public class JinNangServiceImpl implements JinNangService{

	JmsOperations jmsOperations;
	
	public JinNangServiceImpl(JmsOperations jmsOperations){
		this.jmsOperations=jmsOperations;
	}
	
	@Override
	public void sendJinNang() {
		JinNang jinnang=new JinNang("空城計","諸葛亮");
		jmsOperations.convertAndSend(jinnang);
	}
}

JinNangServiceImpl有一個JmsOperations屬性，並通過建構函式例項化，JmsTemplate 可以建立連線、獲得會話以及傳送和接收訊息。這使得我們可以專注於構建要傳送的訊息或者處理接收到的訊息。另外， JmsTemplate 可以處理所有丟擲的笨拙的 JMSException 異常。如果在使用 JmsTemplate 時丟擲 JMSException 異常， JmsTemplate 將捕獲該異常，然後丟擲一個非檢查型異常，該異常是 Spring 自帶的 JmsException 異常的子類。

第三步：建立訊息生產者

import org.springframework.context.support.ClassPathXmlApplicationContext;
import chapter17.service.interfaces.JinNangService;


public class JinNangProduce {
	
	public static void main(String[] args) {
		 ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("chapter17/messaging.xml");
		    JinNangService alertService = context.getBean(JinNangService.class);     
		    alertService.sendJinNang();
	}
}

生產者通過呼叫JinNangService來發送訊息給訊息代理activemq.

message.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:p="http://www.springframework.org/schema/p"
	xmlns:jms="http://www.springframework.org/schema/jms"
	xmlns:amq="http://activemq.apache.org/schema/core"
	xmlns:c="http://www.springframework.org/schema/c"
	xsi:schemaLocation="http://www.springframework.org/schema/jms http://www.springframework.org/schema/jms/spring-jms-3.2.xsd
		http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd
		http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">
<!--定義訊息佇列  點對點模型-->
<amq:queue id="jinnangQueue" physicalName="chapter17.queue" />
<!-- 定義訊息主題  對應訂閱釋出模型 -->
<amq:topic id="jinnangTopic" physicalName="chapter17.topic" />
<!-- 連線工廠 連線到activemq訊息代理 -->
<amq:connectionFactory id="connectionFactory" 
      brokerURL="tcp://localhost:61616" />
<!--定義jmsTemplate spring封裝的jms模板，類似於jdbcTemplate  -->
<bean id="jmsTemplate" 
      class="org.springframework.jms.core.JmsTemplate"
      c:_-ref="connectionFactory" 
      p:defaultDestinationName="chapter17.queue" />
<!-- 定義service實現類 -->
<bean id="jinNangService" class="chapter17.service.JinNangServiceImpl"
      c:_-ref="jmsTemplate" />
<!--jms監聽器容器，新增監聽器，當訊息代理返回訊息，觸發監聽器執行相應的程式碼  -->
<jms:listener-container>
  <jms:listener destination="chapter17.queue" 
                ref="jinnangConsumer" 
                method="getJinnang" />
</jms:listener-container>
<!-- 定義訊息消費者 -->
<bean id="jinnangConsumer" class="chapter17.test.JinNangConsumer" />
</beans>

最後一步：定義訊息消費者：

package chapter17.test;

import chapter17.domain.JinNang;

public class JinNangConsumer {
	
	public void getJinnang(JinNang jinnang){
		System.out.println(jinnang.getPeople()+"實施"+jinnang.getJice());
	}
}

通過執行訊息生產者JinNangProduce生產一條訊息-傳送一個JinNang物件給訊息代理，jms:listener-container定義了一個監聽器容器，該容器不停的去詢問訊息代理，有訊息給我了沒，如果有，該監聽器容器查詢該訊息佇列對應的監聽器，然後監聽器執行消費者程式碼jinnangConsumer.getJinNang();