用Spring JMS使異步消息變得簡單
異步處理通信是面向服務(wù)架構(gòu)(SOA)的重要部分,因為企業(yè)中的許多系統(tǒng)通信,尤其是跟外部系統(tǒng)通信本來就是異步的。Java消息服務(wù)(JMS)就是用來編寫異步消息J2EE應(yīng)用的API。使用JMS API的傳統(tǒng)消息實現(xiàn)涉及到象這樣的一些步驟:查找對列連接工廠、隊列資源以及在實際發(fā)送和接受消息前,創(chuàng)建JMS會話(JMS session)。
Spring framework簡化了用JEE組件(包括JMS)開發(fā)JMS應(yīng)用的工作。它提供了一個模板機制來隱藏典型的JMS實現(xiàn)細(xì)節(jié),所以開發(fā)者可以專注于消息處理任務(wù)而不用擔(dān)心怎樣創(chuàng)建、訪問和釋放JMS資源。
本文用一個運行在JBoss MQ server上的簡單Web應(yīng)用概述了Spring JMS API和怎樣使用它異步處理(發(fā)送和接受)消息。我將對比JMS實現(xiàn)的傳統(tǒng)方法和Spring JMS實現(xiàn)方法,以顯示使用Spring JMS來處理消息是多么的簡單和靈活。
異步消息和SOA
現(xiàn)實世界中,大多數(shù)Web請求是同步處理的。例如,當(dāng)用戶登陸一個站點,他或她輸入用戶名和口令以及服務(wù)器識別登陸憑證。如果身份驗證成功,程序讓用戶進(jìn)入站點。這里,登陸請求從客戶端被接受后,立即被處理。信用卡授權(quán)也是一個同步處理的例子;僅當(dāng)服務(wù)器核實了發(fā)送進(jìn)來的信用卡號是有效并且該客戶的帳號有足夠的信用額度后,才允許客戶繼續(xù)進(jìn)行下一步動作。讓我們來考察一下訂單處理系統(tǒng)中的支付結(jié)算步驟。一旦系統(tǒng)核實了那個用戶的信用卡信息是正確的,而且?guī)羯嫌凶銐虻馁Y金,那么不需要等到支付細(xì)節(jié)和轉(zhuǎn)帳最終完成。支付結(jié)算用異步方式處理,如此客戶便可以繼續(xù)進(jìn)行結(jié)帳處理。
與典型的同步請求相比,異步處理用于需要長時間來處理的請求。異步處理的另外一個例子是住房貸款處理應(yīng)用中,處理提交到AUS(Automated Underwriting System)的貸款請求。貸款人提交貸款申請后,抵押公司發(fā)送請求到AUS取得信用歷史信息。因為該請求要取得綜合詳細(xì)的信用報告如貸款人當(dāng)前和過去的信用帳戶,最近的支付以及其它金融詳細(xì)信息,所以從請求到獲得響應(yīng)常常需要很長時間。對客戶端程序來說開一個到服務(wù)器的連接并且長時間等待響應(yīng)是沒有意義的。于是就有了異步通信;也就是,一旦請求被提交,它就被放入隊列里面并且客戶斷開服務(wù)器連接。然后,AUS服務(wù)從特定隊列摘取請求,處理它,把結(jié)果消息放入另外一個消息隊列。最后客戶程序從消息隊列摘取響應(yīng)結(jié)果繼續(xù)處理信用歷史結(jié)果信息。
JMS
如果用過JMS的話,會發(fā)現(xiàn)它類似寫JDBC或JCA代碼。它有創(chuàng)建或檢索JMS資源的樣板代碼,每當(dāng)你需要編寫一個新類來發(fā)送或接受消息時,都得重復(fù)編寫那個樣本代碼。下面列出了傳統(tǒng)JMS實現(xiàn)涉及的步驟:
1、創(chuàng)建JNDI初始上下文context;
2、從JNDI上下文獲得隊列連接工廠;
3、從隊列連接工廠取得隊列Queue;
4、創(chuàng)建一個Session對象;
5、創(chuàng)建一個發(fā)送或接受對象;
6、利用第5部創(chuàng)建的發(fā)送或接受對象發(fā)送或接受消息;
7、處理完消息后,關(guān)閉所有JMS資源。
如你所見,只有第6步是處理消息的步驟。其他步驟都只是管理JMS資源,與實際業(yè)務(wù)需求無關(guān),但開發(fā)者不得不編寫和維護(hù)那些附加步驟代碼。
Spring JMS
Spring框架提供一個模板機制來隱藏Java API細(xì)節(jié)。JEE開發(fā)者可用JDBCTemplate 和JNDITemplate類來分別訪問后端數(shù)據(jù)庫和JEE資源(數(shù)據(jù)源,連接池)。JMS沒有異常。Spring提供了JMSTemplate類,所以開發(fā)者不必為JMS實現(xiàn)編寫樣本代碼。當(dāng)開發(fā)JMS應(yīng)用時,Spring提供了一下一些優(yōu)勢:
1、提供了一個JMS的抽象API,簡化了JMS的使用。如:訪問目的地(隊列或主體)和出版消息到特定目的地。
2、JEE開發(fā)者不必關(guān)心JMS不同版本之間的差異(如JMS 1.0.2 同 JMS 1.1);
3、開發(fā)者不必特定地處理JMS異常,因為Spring為JMS代碼拋出的任何JMS異常提供了一個unchecked異常。
一旦你在JMS應(yīng)用中開始使用Spring,你將會欣賞到異步消息處理的簡易性。Spring JMS框架提供了各種java類使JMS開發(fā)變得簡單。
【編輯推薦】