Spring框架則簡化了使用JEE組件(包括JMS)的任務。它提供的模板機制隱藏了典型的JMS實現(xiàn)的細節(jié)，這樣開發(fā)人員可以集中精力放在處理消息的實際工作中，而不用擔心如何去創(chuàng)建，訪問或清除JMS資源。

　　 本文將對Spring JMS API作一個概述，并通過一個運行在JBoss MQ服務器上的web例程來介紹如何使用Spring JMS API來異步處理（發(fā)送和接收）消息。我將通過傳統(tǒng)JMS實現(xiàn)和Spring JMS實現(xiàn)兩者間的比較，來展示使用Spring JMS處理消息是如何的簡單和靈活。

異步消息傳遞和面向服務架構

　　在現(xiàn)實中，大多數(shù)web請求都是同步處理的。例如，當用戶要登入一個網(wǎng)站，首先輸入用戶名和密碼，然后服務器驗證登錄合法性。如果驗證成功，程序將允許該用戶進入網(wǎng)站。這里，登錄請求在從客戶端接收以后被即時處理了。信用卡驗證是另一個同步處理的例子；只有服務器證實輸入的信用卡號是有效的，同時客戶在帳戶上有足夠的存款，客戶才被允許繼續(xù)操作。但是讓我們思考一下在順序處理系統(tǒng)上的支付結算步驟。一旦系統(tǒng)證實該用戶信用卡的信息是準確的，并且在帳戶上有足夠的資金，就不必等到所有的支付細節(jié)落實、轉賬完成。支付結算可以異步方式進行，這樣客戶可以繼續(xù)進行核查操作。

　　 需要比典型同步請求耗費更長時間的請求，可以使用異步處理。另一個異步處理的例子是，在本地貸款處理程序中，提交至自動承銷系統(tǒng)（AUS）的信用請求處理過程。當借方提交貸款申請后，抵押公司會向AUS發(fā)送請求，以獲取信用歷史記錄。由于這個請求要求得到全面而又詳細的信用報告，包括借方現(xiàn)今和過去的帳戶，最近的付款和其他財務資料，服務器需要耗費較長的時間（幾小時或著有時甚至是幾天）來對這些請求作出響應。客戶端程序（應用）要與服務器連接并耗費如此長的時間來等待結果，這是毫無意義的。因此通信應該是異步發(fā)生的；也就是，一旦請求被提交，它就被放置在隊列中，同時客戶端與服務器斷開連接。然后AUS服務從指定的隊列中選出請求進行處理，并將處理得到的消息放置在另一個消息隊列里。最后，客戶端程序從這個隊列中選出處理結果，緊接著處理這個信用歷史數(shù)據(jù)。

JMS

　　 如果您使用過JMS代碼，您會發(fā)現(xiàn)它與JDBC或JCA很像。它所包含的樣本代碼創(chuàng)建或JMS資源對象回溯，使得每一次您需要寫一個新類來發(fā)送和接收消息時，都具有更好的代碼密集性和重復性。以下序列顯示了傳統(tǒng)JMS實現(xiàn)所包括的步驟：

1. 創(chuàng)建JNDI初始上下文（context）。
2. 從JNDI上下文獲取一個隊列連接工廠。
3. 從隊列連接工廠中獲取一個Quene。
4. 創(chuàng)建一個Session對象。
5. 創(chuàng)建一個發(fā)送者（sender）或接收者（receiver）對象。
6. 使用步驟5創(chuàng)建的發(fā)送者或接收者對象發(fā)送或接收消息。
7. 處理完消息后，關閉所有JMS資源。

您可以看到，步驟6是處理消息的唯一地方。其他步驟都只是管理與實際業(yè)務要求無關的JMS資源，但是開發(fā)人員必須編寫并維護這些額外步驟的代碼。

Spring JMS

　　 Spring框架提供了一個模板機制來隱藏Java APIs的細節(jié)。JEE開發(fā)人員可以使用JDBCTemplate和JNDITemplate類來分別訪問后臺數(shù)據(jù)庫和JEE資源（數(shù)據(jù)源，連接池）。JMS也不例外。Spring提供JMSTemplate類，因此開發(fā)人員不用為一個JMS實現(xiàn)去編寫樣本代碼。接下來是在開發(fā)JMS應用程序時Spring所具有一些的優(yōu)勢。

1. 提供JMS抽象API，簡化了訪問目標（隊列或主題）和向指定目標發(fā)布消息時JMS的使用。
2. JEE開發(fā)人員不需要關心JMS不同版本（例如JMS 1.0.2與JMS 1.1）之間的差異。
3. 開發(fā)人員不必專門處理JMS異常，因為Spring為所有JMS異常提供了一個未經(jīng)檢查的異常，并在JMS代碼中重新拋出。

示例程序

        說明：因為只是為了演示如何使用spring編寫jms的應用，所以本例沒有什么實際用途。

        程序功能：MessageProducer.java根據(jù)一用戶信息產生一個消息發(fā)送到 JMS Provider；由MessageConsumer.java接收。

1.在Jboss里配置XML文件創(chuàng)建一個新的JMS provider。
打開位于%JBOSS_HOME%server\default\deploy\jms文件夾下的jbossmq-destinations-service.xml文件，加入以下代碼片斷：
 <!--  Register User Send/Receive Queue  -->
 <mbean code="org.jboss.mq.server.jmx.Queue"
   name="jboss.mq.destination:service=Queue,name=registerUserQueue">
   <depends optional-attribute-name="DestinationManager">jboss.mq:service=DestinationManager</depends>
 </mbean>
 <!--  Register User Send/Receive Topic  -->
 <mbean code="org.jboss.mq.server.jmx.Topic"
  name="jboss.mq.destination:service=Topic,name=registerUserTopic">
   <depends optional-attribute-name="DestinationManager">jboss.mq:service=DestinationManager</depends>
 </mbean>
2.在spring的配置文件中配置JMS組件的具體細節(jié)。
 （1）JNDI上下文是取得JMS資源的起始位置，因此首先我們要配置JNDI模板：
    <!-- JNDI上下文(它是取得JMS資源的起始位置) -->
   <bean id="jndiTemplate" class="org.springframework.jndi.JndiTemplate">
    <property name="environment">
     <props>
      <prop key="java.naming.factory.initial">
       org.jnp.interfaces.NamingContextFactory
      </prop>
      <prop key="java.naming.provider.url">localhost</prop>
      <prop key="java.naming.factory.url.pkgs">
       org.jnp.interfaces:org.jboss.naming
      </prop>
     </props>
    </property>
   </bean>
   注意：此JNDI模板用到了org.jnp.interfaces.NamingContextFactory所以要把%JBOSS_HOME%\client下的jbossall-client.jar加到你的項目的classpath中。
（2）配置連接工廠：
   <!-- JMS連接工廠 -->
     <bean id="jmsConnectionFactory"class="org.springframework.jndi.JndiObjectFactoryBean">
    <property name="jndiTemplate">
     <ref bean="jndiTemplate" />
    </property>
    <property name="jndiName">
     <value>XAConnectionFactory</value>
    </property>
   </bean>
   注意：XAConnectionFactory這個JNDI名字是在%JBOSS_HOME%server\default\deploy\jms文件夾下的jms-ds.xml中定義的(它是由JBoss指定的)。
 （3）配置JmsTemplate組件。在例程中我們使用JmsTemplate102。同時使用defaultDestination屬性來指定JMS目標。
  <!-- JMS模板配置 -->
  <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate102">
   <property name="connectionFactory" ref="jmsConnectionFactory" />
   <property name="defaultDestination" ref="destination" />
   <property name="pubSubDomain">
    <value>true</value>
   </property>
   <!-- 等待消息的時間(ms) -->
   <property name="receiveTimeout">
         <value>30000</value>
      </property>
  </bean>
  注意：如果使用topic-subscribe(主題訂閱)模式，該模板的pubSubDomain屬性值為true;若使用PToP(點對點)模式，pubSubDomain屬性值為false或不配置該屬性。
 (4)定義一個JMS目標來發(fā)送和接收消息:
  <bean id="destination" class="org.springframework.jndi.JndiObjectFactoryBean">
   <property name="jndiTemplate">
    <ref bean="jndiTemplate" />
   </property>
   <property name="jndiName">
    <value>topic/registerUserTopic</value>
   </property>
  </bean>
 (5)配置發(fā)送者和接收者組件:
  <!-- 消息發(fā)布者 -->
  <bean id="msgProducer" class="com.boco.jms.MessageProducer">
   <property name="jmsTemplate" ref="jmsTemplate" />
  </bean>
  <!-- 消息接收者 -->
  <bean id="msgConsumer" class="com.boco.jms.MessageConsumer">
   <property name="jmsTemplate" ref="jmsTemplate" />
  </bean>
3.相應的類:
 (1). User對象。
   /**
   *  User.java
   *  created on Jul 2, 2006
   *  Copyrights 2006 BOCO,Inc. All rights reserved.
   */
  package com.boco.dto;
  
  import java.io.Serializable;
  
  /**
   * desc: 用戶信息 Bean
   * @author qiujy
   */
  public class User {
   private int id;
   private String username;
   private String password;
   private String email;
   
   public User(){}
   
   //以下為Getter,setter方法略
   ......
  }
  
 (2).消息生產者：
   /**
   *  MessageProducer.java
   *  created on Jul 22, 2006
   *  Copyrights 2006 BOCO,Inc. All rights reserved.
   */
  package com.boco.jms;
  
  import javax.jms.JMSException;
  import javax.jms.MapMessage;
  import javax.jms.Message;
  import javax.jms.Session;
  
  import org.springframework.jms.core.JmsTemplate;
  import org.springframework.jms.core.MessageCreator;
  
  import com.boco.dto.User;
  
  /**
   * desc:消息生產者
   * @author qiujy
   *
   */
  public class MessageProducer {
   /** JMS模板 */
   private JmsTemplate jmsTemplate;
   
   public void setJmsTemplate(JmsTemplate jmsTemplate){
    this.jmsTemplate = jmsTemplate;
   }
   
   public void sendMessage(final User user){
    //調用模板的send來發(fā)送消息
    jmsTemplate.send(new MessageCreator(){
  
     public Message createMessage(Session session) throws JMSException {
      //構造一個要發(fā)送的消息
      MapMessage message = session.createMapMessage();
       message.setInt("id", user.getId());
       message.setString("username", user.getUsername());
       message.setString("password", user.getPassword());
       message.setString("email", user.getEmail());
      System.out.println("send success!!");
      return message;
     }
    });
   }
  }
  
 (3).消息消費者：
  /**
   *  MessageConsumer.java
   *  created on Jul 22, 2006
   *  Copyrights 2006 BOCO,Inc. All rights reserved.
   */
  package com.boco.jms;
  
  import javax.jms.JMSException;
  import javax.jms.MapMessage;
  
  import org.springframework.jms.core.JmsTemplate;
  
  import com.boco.dto.User;
  
  /**
   * desc:消息消費者
   * @author qiujy
   *
   */
  public class MessageConsumer {
   /** JMS模板 */
   private JmsTemplate jmsTemplate;
   
   public void setJmsTemplate(JmsTemplate jmsTemplate){
    this.jmsTemplate = jmsTemplate;
   }
   
   public User receiveMessage(){
    //參數(shù)為Destination的JNDI名字去掉前面的模式類型標識
    //MapMessage msg = (MapMessage)jmsTemplate.receive("registerUserQueue");
    MapMessage msg = (MapMessage)jmsTemplate.receive("registerUserTopic");
    User user = new User();
    
    try {
     user.setId(msg.getInt("id"));
     user.setUsername(msg.getString("username"));
     user.setPassword(msg.getString("password"));
     user.setEmail(msg.getString("email"));
    } catch (JMSException e) {
     // TODO Auto-generated catch block
     e.printStackTrace();
    }
    
    return user;
   }
  }

 (4).測試用例：
   //======== 生產者測試用例 ===============
   /**
   *  TestMsgProducer.java
   *  created on Jul 22, 2006
   *  Copyrights 2006 BOCO,Inc. All rights reserved.
   */
  package com.boco.jms;
  
  import junit.framework.TestCase;
  
  import org.springframework.context.ApplicationContext;
  import org.springframework.context.support.ClassPathXmlApplicationContext;
  
  import com.boco.dto.User;
  
  /**
   * desc:
   * @author qiujy
   *
   */
  public class TestMsgProducer extends TestCase {
  
   private ApplicationContext context;
   /**
    * @param arg0
    */
   public TestMsgProducer(String arg0) {
    super(arg0);
    context = new ClassPathXmlApplicationContext("applicationContext_jms.xml");
   }
  
   /* (non-Javadoc)
    * @see junit.framework.TestCase#setUp()
    */
   protected void setUp() throws Exception {
    super.setUp();
   }
  
   /* (non-Javadoc)
    * @see junit.framework.TestCase#tearDown()
    */
   protected void tearDown() throws Exception {
    super.tearDown();
   }
  
   /**
    * Test method for {@link com.boco.jms.MessageProducer#sendMessage(com.boco.dto.User)}.
    */
   public void testSendMessage() {
    User user = new User();
    user.setId(132);
    user.setUsername("JMSTest");
    user.setPassword("password");
    user.setEmail("support@boco.com.cn");
    
    MessageProducer producer = (MessageProducer)context.getBean("msgProducer");
    
    producer.sendMessage(user);
    
   }
  
  }

  //============ 消費者測試用例 ===============
  /**
   *  TestMsgConsumer.java
   *  created on Jul 22, 2006
   *  Copyrights 2006 BOCO,Inc. All rights reserved.
   */
  package com.boco.jms;
  
  import junit.framework.TestCase;
  
  import org.springframework.context.ApplicationContext;
  import org.springframework.context.support.ClassPathXmlApplicationContext;
  
  import com.boco.dto.User;
  
  /**
   * desc:
   * @author qiujy
   *
   */
  public class TestMsgConsumer extends TestCase {
   private ApplicationContext context;
   /**
    * @param arg0
    */
   public TestMsgConsumer(String arg0) {
    super(arg0);
    context = new ClassPathXmlApplicationContext("applicationContext_jms.xml");
   }
  
   /* (non-Javadoc)
    * @see junit.framework.TestCase#setUp()
    */
   protected void setUp() throws Exception {
    super.setUp();
   }
  
   /* (non-Javadoc)
    * @see junit.framework.TestCase#tearDown()
    */
   protected void tearDown() throws Exception {
    super.tearDown();
   }
  
   /**
    * Test method for {@link com.boco.jms.MessageConsumer#receiveMessage()}.
    */
   public void testReceiveMessage() {
    MessageConsumer consumer = (MessageConsumer)context.getBean("msgConsumer");
    User user = consumer.receiveMessage();
    assertNotNull(user);
    System.out.println( "id========" + user.getId()
        + "\nname======" + user.getUsername()
        + "\npassword==" + user.getPassword()
        + "\nemail=====" + user.getEmail());
   }
  
  }