本文主要講述用JMS template同步收發訊息。

1.       JMS template綜述

使用JmsTemplate收發訊息可以顯著減少開發的精力投入。使用JmsTemplate時，不需要費心考慮連線到JMS provider（如ActiveMQ），建立JMS Session（如QueueSession），建立訊息生產者（如QueueSender），甚至不用新建一個JMS訊息（如TextMessage）。JmsTemplate能夠自動將各種型別如String、Byte[]等轉換為響應的JMS訊息物件型別，當然也可以自己寫Converter轉換複雜的訊息。

JmsTemplate常用的方法有send、convertAndSend、receive和convertAndReceive。

2.       詳細步驟

下面通過一個例子詳細講解使用JmsTemplate同步收發訊息。

（1）       環境

JMS1.1；apache-activemq-5.4.0；Spring-2.5.4；JDK-1.5；myeclipse7.5

如果引入的是activemq-all-5.5.0.jar這個包，則不需要再引入JMS1.1包，因為all裡面已經包含了jms1.1

（2）       原始碼（Java Project）

i）                結構

ii）              原始碼

.classpath：

<?xml version="1.0" encoding="UTF-8"?>

<classpath>

         <classpathentry kind="src" path="src/main/java"/>

         <classpathentry kind="src" path="src/main/resources"/>

         <classpathentry exported="true" kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER"

         <classpathentry exported="true" kind="lib" path="lib/jms-1.1.jar"/>

         <classpathentry exported="true" kind="lib" path="lib/spring.jar"/>

         <classpathentry exported="true" kind="lib" path="lib/activemq-all-5.4.0.jar"/>

         <classpathentry kind="output" path="bin"/>

</classpath>

jndi.properties：

java.naming.factory.initial = org.apache.activemq.jndi.ActiveMQInitialContextFactory

java.naming.provider.url = tcp://localhost:61616

java.naming.security.principal=system

java.naming.security.credentials=manager

connectionFactoryNames = QueueCF

queue.queue1 = jms.queue1

app-context.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:jms="http://www.springframework.org/schema/jms"

       xsi:schemaLocation="

       http://www.springframework.org/schema/beans spring-beans-2.0.xsd

            http://www.springframework.org/schema/jms

            http://www.springframework.org/schema/jms/spring-jms-2.5.xsd">

         <bean id="jndiTemplate" class="org.springframework.jndi.JndiTemplate">

       <property name="environment">

          <props>

             <prop key="java.naming.factory.initial">

                   org.apache.activemq.jndi.ActiveMQInitialContextFactory</prop>

             <prop key="java.naming.provider.url">tcp://localhost:61616</prop>

             <prop key="java.naming.security.principal">system</prop>

             <prop key="java.naming.security.credentials">manager</prop>

          </props>

       </property>

    </bean>  

         <bean id="jndiQueueConnectionFactory" class="org.springframework.jndi.JndiObjectFactoryBean">

       <property name="jndiTemplate" ref="jndiTemplate"/>

       <property name="jndiName" value="QueueCF"/>

    </bean>  

    <bean id="queueConnectionFactory" class="org.springframework.jms.connection.CachingConnectionFactory">

        <property name="targetConnectionFactory" ref="jndiQueueConnectionFactory"/>

        <property name="sessionCacheSize" value="1"/>

    </bean> 

         <bean id="queueDestination"

            class="org.springframework.jndi.JndiObjectFactoryBean">

            <property name="jndiTemplate" ref="jndiTemplate"/>

            <property name="jndiName" value="queue1"/>

         </bean> 

         <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">

            <property name="connectionFactory" ref="queueConnectionFactory"/>

            <property name="defaultDestinationName" value="queue1"/>

            <property name="pubSubDomain" value="false"/>

         </bean>         

         <bean id="jmsSender" class="com.jms.client.JMSSender">

            <property name="jmsTemplate" ref="jmsTemplate"/>

            <property name="queueName" value="queue1"/>

         </bean> 

</beans>

JMSReceiverSync.java：

package com.jms.server; 

import org.springframework.context.ApplicationContext;

import org.springframework.context.support.ClassPathXmlApplicationContext;

import org.springframework.jms.core.JmsTemplate;

public class JMSReceiverSync { 

         public static void main(String[] args) {                  

                   try {

                            ApplicationContext ctx =

                                     new ClassPathXmlApplicationContext("app-context.xml");

                            JmsTemplate jmsTemplate = (JmsTemplate)ctx.getBean("jmsTemplate"); 

                            int counter = 0;

                            while(counter < 10) {

                    Object msg = jmsTemplate.receiveAndConvert();

                    if (msg instanceof String) {

                             System.out.println("Received: " + msg);

                    }

                    counter++;

                            }                           

                            System.exit(0);

                   } catch (Exception up) {

                            up.printStackTrace();

                   }

         }

}

JMSSender.java：

package com.jms.client; 

import javax.jms.JMSException;

import javax.jms.Message;

import javax.jms.Session;

import javax.jms.TextMessage;

import org.springframework.jms.core.JmsTemplate;

import org.springframework.jms.core.MessageCreator; 

public class JMSSender { 

         public void sendMessage() throws Exception { 

                   MessageCreator msg = new MessageCreator() {

                            public Message createMessage(Session session)throws JMSException {

                                     TextMessage msg = session.createTextMessage("TEST 1");

                          return msg;

                 }

                   };                           

                   jmsTemplate.send(queueName, msg);

                   System.out.println("Message Sent...");                                

         }

         public JmsTemplate jmsTemplate = null;

         public String queueName = null;        

         public void setJmsTemplate(JmsTemplate jmsTemplate) {

                   this.jmsTemplate = jmsTemplate;

         }        

         public void setQueueName(String queueName) {

                   this.queueName = queueName;

         }

}

JMSSenderApp.java：

package com.jms.client; 

import org.springframework.context.ApplicationContext;

import org.springframework.context.support.ClassPathXmlApplicationContext; 

public class JMSSenderApp { 

         public static void main(String[] args) {                  

             try {

                            ApplicationContext ctx =

                                     new ClassPathXmlApplicationContext("app-context.xml");

                            JMSSender jmsSender = (JMSSender)ctx.getBean("jmsSender");

                            jmsSender.sendMessage();

             System.exit(0);

             } catch (Exception exception) {

                 exception.printStackTrace();

             }

         }      

} 

（3）       說明

可以看到，用JmsTemplate收發訊息非常簡單，因為JmsTemplate幾乎幫我們做了大多數的工作，相關關係如下圖所示（可結合app-context.xml理解）：

    步驟與不使用Spring相似，只是都是通過配置完成的。

3.       疑惑

明明用app-context.xml就包含所有的上下文資訊了，可是刪掉jndi.properties依然會出錯。

PS：如果專案中引入了weblogic.jar包，則需要引入較高版本的jar（8.1是不行的），因為weblogic包中也有jms程式碼，由於該程式碼版本比較老，所以在執行JMSSenderApp，會提示錯誤：no such method javax.jms.ConnectionFactory.createConnection()Ljavax/jms/Connection

執行的時候，需要啟動ActiveMQ服務！！！啟動以後服務地址：ActiveMQ訊息管理後臺系統：http://localhost:8161/admin