下面是ActiveMQ官網提供的文檔。http://activemq.apache.org/spring-support.html

下面是我添加的一些dependency:

<!-- jms activemq --><dependency>    <groupId>javax.jms</groupId>    <artifactId>javax.jms-api</artifactId>    <version>2.0</version></dependency><dependency>    <groupId>org.apache.activemq</groupId>    <artifactId>activemq-core</artifactId>    <version>${activemq.version}</version></dependency><dependency>    <groupId>org.apache.activemq</groupId>    <artifactId>activemq-pool</artifactId>    <version>${activemq.version}</version></dependency><dependency>    <groupId>org.apache.activemq</groupId>    <artifactId>activemq-spring</artifactId>    <version>${activemq.version}</version></dependency><dependency>    <groupId>org.apache.xbean</groupId>    <artifactId>xbean-spring</artifactId>    <version>3.16</version></dependency><dependency>    <groupId>org.springframework</groupId>    <artifactId>spring-jms</artifactId>    <version>${spring.version}</version></dependency>

maven中添加時要注意還有個xbean-spring；之前并沒有注意，運行發現異常提示ClassNotFound:org.apache.xbean.spring.context.v2.XBeanNamespaceHandler；后來我添加了xbean-v2，結果提示v2c，于是我添加v2c，后來感覺太傻就加了xbean-spring。

配置方面可以使用jms和activeMq的標簽:

xmlns:amq="http://activemq.apache.org/schema/core"xmlns:jms="http://www.springframework.org/schema/jms"

相應的xsi:schemaLocation:

http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsdhttp://www.springframework.org/schema/jms http://www.springframework.org/schema/jms/spring-jms.xsd

關于connectionFactory的配置可以使用amq標簽:

<amq:connectionFactory id="jmsFactory" brokerURL="tcp://localhost:61616" />

但是在這里我打算試試PooledConnectionFactory；關于org.apache.activemq.pool.PooledConnectionFactory官網有以下解釋:If you are not using a JCA container to manage your JMS connections, we recommend you use our pooling JMS connection provider, (org.apache.activemq.pool.PooledConnectionFactory) from the activemq-pool library, which will pool the JMS resources to work efficiently with Spring's JmsTemplate or with EJBs.

對于其屬性，下面根據javaDoc給出一些解釋：·MaximumActivesessionPerConnection：每個Connection的最大Session數·BlockIfSessionPoolIsFull：默認為session池滿時請求獲得session會阻塞；設置false則會拋出JMSException·MaxConnections：最大連接數·IdleTimeout：空閑時間，默認為30秒·CreateConnectionOnStartup：是否在啟動時創建connection

在這里我先用默認參數聲明，不知道為什么總是報MalformPrameterizedType...

<bean id="jmsFactory" class="org.apache.activemq.pool.PooledConnectionFactory" />上次用的隊列，這次換用Topic試試...

<bean id="destination" class="org.apache.activemq.command.ActiveMQTopic">  <constructor-arg index="0" value="spartaTopic"></constructor-arg></bean>

當然也可以使用amq標簽:

<amq:topic physicalName="sparta" />

如果是使用queue的話:

<amq:queue physicalName="sparta" />

難道我將這些放到spring里就是為了用用標簽方便DI?用<spring in action>里的話來說就是jmsTemplate是<spring對jms支持核心的部分>(另有jmsTemplate102為適應jms1.0.2的)；和jdbcTemplate那樣 jmsTemplate也有提供相似的優勢。比如，像jdbcTemplate處理失控的jdbc代碼那樣，用jmsTemplate處理失控的jms代碼。或者，如果在使用JmsTemplate是捕捉到了JMSException，JmsTemplate將捕獲該異常，然后拋出一個Spring自帶的JmsException的子類異常(個人感覺spring提供的不是更詳細的異常信息，只是側重點不同...)。

比如：·ListenerExecutionFailedException：監聽器執行失敗·MessageConversionException：消息轉換失敗·SynchedLocalTransactionFailedException：同步本地事務未完成·UncategorizedJmsException：沒有適合異常的其他情況如果我們catch了JMSException，我們依然可以把他轉為JmsException:

catch (JMSException e) {            e.printStackTrace();            JmsException je = JmsUtils.convertJmsaccessException(e);        }

現在試著配置jmsTemplate：

<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate" >    <property name="connectionFactory" >        <bean class="org.apache.activemq.pool.PooledConnectionFactory" />    </property>    <property name="defaultDestination" >        <amq:topic physicalName="sparta" />    </property></bean>

這樣編寫代碼時就變得簡單多了，之前那些connectionFactory,connection,session,consumer,producer統統不見了；我只需要使用template:

applicationContext context = new ClassPathXmlApplicationContext("classpath:applicationContext.xml");JmsTemplate template = (JmsTemplate)context.getBean("jmsTemplate");template.send(new MessageCreator() {    public Message createMessage(Session session) throws JMSException {        ActiveMQMapMessage msg = (ActiveMQMapMessage)session.createMapMessage();        msg.setString("msg", "This is sparta!!");        return msg;    }});

接收時只需要template.receive();

但需要注意！這個receive是同步接收消息的，他會一直阻塞到有消息個接收。可能會想到MessageListener，比如我們可以給一個MessageConsumer對象setMessageListener:

MessageConsumer consumer = session.createConsumer(destination);consumer.setMessageListener(new MessageListener() {    public void onMessage(Message message) {        try {            System.out.println("listener catched:::"+((TextMessage)message).getText());        } catch (JMSException e) {            e.printStackTrace();        }    }});

上面代碼中的MessageListener實例，如果新建一個專門用來監聽的類，實現MessageListener接口并加上MessageDriven標注就會出現一個問題——他不夠pojo。他有侵入性，我不想要任何實現接口的語法出現在代碼中。

于是我可以用listener-container；現在我創建一個類去監聽，比如:

public class CustomedListener {    void processHandle(HashMap<String,String> map){        System.out.println("msg:::"+map.get("msg"));    }}

上面的publisher發送的message是ActiveMQMapMessage，這就需要我把參數定義為上面那種形式。然后看一下spring中如何配置這個Listener:

<bean id="myListener" class="pac.testcase.jms.CustomedListener"/><jms:listener-container connection-factory="connectionFactory">    <jms:listener destination="sparta" ref="myListener" method="processHandle"/></jms:listener-container>

這樣我就不需要去調用receive了，有消息就接收。