Spring JMS消息處理
在Spring系列的第4期也是***一期中，我將介紹Spring JMS（Java消息服務(wù)）框架的特性。JMS PG定義了Java 應(yīng)用程序通過(guò)面向消息的中間件（MOM）創(chuàng)建和交換消息的標(biāo)準(zhǔn)途徑。
就像在這個(gè)系列前面的文章中一樣，我將使用一個(gè)簡(jiǎn)單的示例來(lái)演示Spring JMS的特性。您將隨我一道開(kāi)發(fā)一個(gè)點(diǎn)對(duì)點(diǎn)的（P2P）基于消息的系統(tǒng)，使用Spring JMS框架通過(guò)JMS接口與IBM的WebSphere MQ集成。完成練習(xí)后，將可以通過(guò)這個(gè)系統(tǒng)發(fā)送和接收簡(jiǎn)單的文本消息。
在開(kāi)始之前，請(qǐng)下載文章的源代碼。請(qǐng)參閱參考資料訪(fǎng)問(wèn)Spring框架和IBM WebSphere MQ 5.3。還需要Apache Ant來(lái)運(yùn)行示例應(yīng)用程序。
Spring JMS
Spring JMS抽象框架簡(jiǎn)化了JMS API的使用，并與JMS提供者（比如 IBM 的 WebSphere MQ 5.3）平滑地集成。org.springframework.jms.core 包提供了在Spring中使用JMS的核心功能。它的模板類(lèi)處理資源的創(chuàng)建和釋放，簡(jiǎn)化了JMS的使用。
像其他大多數(shù)Spring模板類(lèi)一樣，JMS模板類(lèi)提供了執(zhí)行公共操作的helper方法。在需要更復(fù)雜應(yīng)用的情況下，類(lèi)把處理任務(wù)的核心委托給用戶(hù)實(shí)現(xiàn)的回調(diào)接口。JMS 類(lèi)提供了方便的方法，用來(lái)發(fā)送消息、同步地使用消息以及向用戶(hù)公開(kāi)JMS會(huì)話(huà)和消息的制作者。
以下JMS包和org.springframework.jms.core一起構(gòu)成了Spring JMS的功能：
org.springframework.jms.support
提供轉(zhuǎn)換 JMSException 的功能。轉(zhuǎn)換代碼把檢測(cè)到的JMSException層次結(jié)構(gòu)轉(zhuǎn)換成未檢測(cè)到異常的鏡像層次結(jié)構(gòu)。
org.springframework.jms.support.converter。
提供 MessageConverter 抽象，以在Java對(duì)象和JMS消息之間進(jìn)行轉(zhuǎn)換。
org.springframework.jms.support.destination
提供管理 JMS 目標(biāo)的不同策略，比如針對(duì)JNDI中保存的目標(biāo)的服務(wù)定位器。
org.springframework.jms.connection
提供適合在獨(dú)立應(yīng)用程序中使用的ConnectionFactory實(shí)現(xiàn)。connection還包含針對(duì)JMS的Spring PlatformTransactionManager實(shí)現(xiàn)。它允許把JMS作為事務(wù)性資源集成到Spring的事務(wù)管理機(jī)制中。
IBM WebSphere MQ
就像前面提到的，示例應(yīng)用程序會(huì)用Spring的JMS框架通過(guò)JMS接口與IBM的WebSphere MQ集成。通過(guò)在應(yīng)用程序和Web服務(wù)之間傳遞消息，WebSphere MQ提供了可靠的、有恢復(fù)能力的應(yīng)用程序集成。它使用隊(duì)列和事務(wù)性工具幫助保持消息跨網(wǎng)絡(luò)的完整性。WebSphere MQ降低了信息丟失的風(fēng)險(xiǎn)和調(diào)和通信IT系統(tǒng)的需要。
WebSphere MQ在它所支持的所有平臺(tái)上提供了一致的應(yīng)用程序編程接口，這有助于讓集成的程序可移植。除了標(biāo)準(zhǔn)接口外，WebSphere MQ 還完整實(shí)現(xiàn)了JMS接口，包括對(duì)發(fā)布-訂閱消息傳遞的支持。WebSphere MQ EXPlorer工具可以遠(yuǎn)程地管理和配置整個(gè)MQ網(wǎng)絡(luò)。管理和配置工具基于開(kāi)放源碼的Eclipse框架，而且是可擴(kuò)展的。
Spring JMS模板
Spring框架提供了JmsTemplate的兩個(gè)實(shí)現(xiàn)。JmsTemplate類(lèi)使用JMS 1.1 API子類(lèi)JmsTemplate102則使用JMS API我的示例應(yīng)用程序使用的是 JmsTemplate102。
JMS模板被用來(lái)發(fā)送和接收J(rèn)MS消息。Spring采用回調(diào)機(jī)制對(duì)JMS信息傳遞進(jìn)行協(xié)調(diào)。MessageCreator回調(diào)接口用JmsTemplate中的調(diào)用代碼提供的Session創(chuàng)建消息。為了支持JMS API更復(fù)雜的應(yīng)用，回調(diào)SessionCallback向用戶(hù)提供了JMS會(huì)話(huà)而callback ProdUCerCallback則公開(kāi)了Session和MessageProducer組合。
【編輯推薦】
