作者: 劉建華
——向你的Java程序加入開放性資源、基於XML的即時消息
摘要
Jabber對於即時消息是一個開放的、基於XML的數據模型和協議。聯系不斷增加的基於Jabber開放資源和商業產品的數目,這種協議提供了擺脫即時消息服務器所有權束縛的一種方法。多種多樣的開放資源Java APIs能夠幫助你建立基於Jabber的服務器並將即時消息整合到你的應用程序中去。在這篇文章中專門闡述了這一點。
即時消息作為個人——個人通迅工具取得了顯著的成功。在有些地方它已經作為在線聯系的首選方法取代了email。現在,開發者正將這一技術應用到應用程序——個人和應用程序——應用程序通迅上。
直到最近,也只有少數服務提供商掌握了這一技術。通常流行的即時消息服務是建立在所有權協議基礎上的通迅孤島。實施面臨一個困難的決策:支持多協議或鎖定到一個單獨的。不管哪種選擇,實現都必須依賴一個屬於即時消息(IM)服務提供商的服務器。
開放式協議能夠幫助開發者擺脫所有權陷阱。其優勢有多種:開放協議鼓勵競爭實現的發展(一些開放資源)。他們鼓勵廣泛采用一種公共協議,這樣可以阻止通迅孤島和服務供應的孤立主義方法的發展。用多種方法,開放協議使因特網成為可能。在即時消息領域,開放協議確保封閉系統及協議不會阻礙基於IM服務器的發展的互操作性。
Jabber是一種針對即時消息和現場服務的開放協議。作為一個公共協議的最主要的侯選者,Jabber有潛力打破所有權在即時消息服務的控制。
這篇文章將解釋如何實踐發送簡單Jabber消息和開發一個簡單的基於開放標准及開放資源APIs和產品的布告服務器。
為什麼使用Jabber?
Jabber標准和結構幫助創建一個分布式的IM系統,使人聯想到分布在因特網上的email系統,用戶在本地連接到這些系統。這個方法直接與象AIM(AOL即時信使)、ICQ、MSN(Microsoft網絡)及Yahoo這樣的流行服務提供商提供的單一系統結構作對,在那裡一個單獨的中央服務器或集中服務器組提供消息服務。Jabber在其他情形也類似於email結構:Jabber使用一個幾乎與基本SMTP(簡單郵件傳輸協議)方案一樣的地址方案確定它的終點(人,機器,軟件)地址。例如,myname@elogex.com是一個有效的Jabber地址,或使用Jabber說法叫JID(Jabber ID)。因為這些原因,基於Jabber的系統衡量起來好於已存在的專有系統。加之,對於專有即時消息服務的網關允許的協議是必需的。
多種多樣的Jabber服務器,包括我們在這篇文章中使用的其中之一,都是自由可使用的,意思就是說你不再需要依賴一個第三方IM服務提供商(第三方Jabber服務對於那些要求第三方主機服務的來說也是有用的)。
標准化
當討論Jabber標准的益處時,我應該提及IETF IM標准的工作。在寫這篇文章時,其IMPPWG(即時消息和現場協議工作組)已有多個RFC有效,其中最重要的是:
·RFC 2778:現場和即時消息模型
·RFC 2779:即時消息/現場協議要求
IMPPWG已經起草了一個名叫CPIM(公共現場和即時消息)協議的因特網標准。Jabber協議也是一個草擬的因特網標准,但不是IMPPWG工作的部份。
Jabber在哪兒適合這一標准工作呢?依照Jabber網站,Jabber是“承諾完全支持任何開放實時消息協議,包括IETF協議”。如果當對於這個IETF協議的支持增長時,Jabber打算將自己定位為IETF協議的領導開放資源的平台。到目前為止,IETF的工作更多地主要集中在收集要求上而不是執行。暫時,Jabber僅是一個帶有重要開放資源支持的開放即時消息和現場服務協議。結果,它成為開放即時消息事實上的標准。
另一個值得密切注意的競爭對手是Sun微系統的Jxta協議,另一個基於XML針對peer-to-peer(P2P)應用程序開發者的協議。各種各樣的Jxta實施在今天已經能夠被提供。但是,由於其起源相對較近,Jxta比起Jabber只有很少的牽引力。
下載並安裝
要開始使用Jabber,你首先需要下載必要的工具:你需要一個Jabber服務器,一個Jabber客戶端,一個幫助管理和隱藏一些復雜socket處理的API,XML語法分析,消息創建等等。
Jabber服務器
為了運行Jabber,你選擇的Jabber服務器不能有問題,自從他們都接受了標准Jabber XML及與終端應用程序通迅以釋放負荷,其也是標准Jabber XML。Jabberd,最初的Jabber服務器,是開放資源(但不是基於Java),安裝配置簡單並在多數平台上都有效,包括Unix、Linux、Windows和Mac OS X。JabaServer開放資源方案也值得提及,但現在,這些基於Java的方案仍不如Jabberd成熟。同時,JabaServer安裝不怎麼簡單易懂,因為你必須下載、安裝並配置一個第三方數據庫,加上創建必需的數據庫規劃。
對於這篇文章的例子,我選擇Jabberd。當二進制及源下載對於jabberd都有效時,我就不在這兒描述怎樣建立一個源發布。除非你真想自己編譯,可以從jabberd 主頁下載二進制發布。在Windows平台上安裝是相對容易的。發布是一個.exe程序,按照安裝向導一步一步執行。
安裝完成後,你無需配置。在Windows2000,不要求配置。只要雙擊二進制程序就可啟動服務器。
用戶代理/客戶
我決定使用Exodus客戶端,對於這個方案這是另一個開放資源技術。我尤其喜歡Exodus的調試標簽,可以允許你正確地查看客戶發送和接收的XML。另外你能夠作為純粹的XML鍵入Jabber消息並將它們發送給服務器。所有這些都證明用Jabber協議和服務器測試的有用性。
Exodus的安裝簡單易懂。下載Exodus 壓縮文件(我在文章中使用的是0.6版本)。將文件直接解壓到你想要安裝客戶端的目錄。在這個版本中,文件是些簡單的二進制文件和一個.dll文件。你可以從 Muse 主頁下載Muse API。
發送你的第一個Jabber消息
要發送一個Jabber即時消息,你必須初始化Muse Jabber API。通過創建一個JabberContext 類的實例來完成,接下來使用內容作為一個參數到Jabber session factory類的createSession()方法:
1 //初始化Jabber context
2 JabberContext jabberContext = new JabberContext("user", "pass", "localhost");
4 //創建一個Jabber session factory的實例
5 Jabber jabber = new Jabber();
6 //創建新會話
7 JabberSession jabberSession = jabber.createSession(jabberContext);
上面的例子在第2行顯示了一個新context的創建。JabberContext存儲了指定的用戶相關信息(用戶名、密碼、用戶地址)以及稍後要使用context建立session時包含的一個唯一的會話標識。為了闡述意圖,我直接使用了username、passWord和server。
在第5行,一個Jabber session factory被創建,我們在第7行使用它創建了一個新的JabberSession,Muse進入由Jabber服務器提供的服務的主要接口。服務器的主要服務是:
·連接服務: 從Jabber服務器連接和斷開
·用戶服務: 針對用戶鑒定及注冊
·現場服務: 接收從其它用戶/服務來的及你自己廣播的現場信息
·登記表服務: 密友列表或地址薄
·聊天服務: 發送多種類型的消息—組聊、私聊、標題等等
·服務器服務: 獲得與由這個Jabber服務器提供的服務相關的信息
·客戶服務: 獲得關於其他用戶的信息,比如用戶登錄的最後時間
現在我們已經有了一個已經初始化的Jabber session,我們能夠用它在我們才創建的JabberSession對象中使用connect()方法去連接到Jabber 服務器:
8 //連接到服務器
9 jabberSession.connect("localhost", 5222);
要連接到一個Jabber服務器,我們指定地址及在指定服務器上的機器端口號。標准來說,缺省Jabber端口是5222。
現在JabberSession已經連接到服務器,我們能夠在我們的服務中用login()方法登錄:
10 //登錄到Jabber服務器
11 jabberSession.getUserService().login();
在第11行,我們使用JabberSession獲得一個到UserService的引用,接下來在我們服務中調用login()方法。注意方法自身不指定任何用戶信息。當在上面第7行JabberSession被創建時login()從與JabberSession相關的JabberContext中獲得這些信息。
現在我們已經成功登錄到Jabber服務器,我們能夠開始發送和接收消息。下面代碼段顯示了如何構造一個簡單的標題風格的消息:
12 //構造測試消息
13 JabberChatMessage msg = new
14 JabberChatMessage(JabberChatMessage.TYPE_HEADLINE);
15 msg.setSubject("Hello world");
16 msg.setBody("Hello world");
17 msg.setTo("user2@localhost");
在第13行,我們創建了一個JabberChatMessage實例。單個參數指定了我們要求的消息類型:TYPE_HEADLINE。JabberChatMessage類的名字容易引起誤解,實際上,它可以用來包含在Jabber協議中定義的消息的任何四種類型—普通、聊天、標題及錯誤。在第15行,setSubject()和setBody()分別指定主題和內容。最後,setTo()在第17行設置消息接收器的JID。
在封裝下,JabberChatMessage將所有這些信息轉換成一個內在的DOM(文檔對象模型)樹,這樣當我們已經准備好發送消息給Jabber服務器時能夠輕松產生XML。
最後步驟:用sendMessage()方法發送消息:
18 //發送消息
19 jabberSession.sendMessage(msg);
在封裝下
依據上面例子所得的事實,Muse API有效地隱藏了與連接管理和XML語法分析有關的所有細節,因此允許你集中精力在手邊的任務上:創建一個消息服務。然而,理解一些基礎協議交換證明是有用的。讓我們關注一下當我們連接到服務器時發生的XML交換,登錄,並象上面代碼描述的一樣發送消息。在下面的XML交換中,被客戶接收的消息(我們例子代碼)帶了RECV前綴,送到服務器的消息帶有SEND前綴:
SEND: <?XML version="1.0" encoding="UTF-8" ?>
<stream:stream to="localhost"
XMLns="jabber:clIEnt"
XMLns:stream="http://etherx.jabber.org/streams">
RECV: <stream:stream from="localhost" id="3D160545">
所有的Jabber交換都發生在一個XML流的上下文。在我們客戶與Jabber服務器之間連接的生命期間,兩個完全的XML文檔在一個時間傳輸一個片段。上面顯示的最初交換允許客戶開始發送XML流文檔到服務器並且服務器開始發送XML流文檔到客戶。
下面,一個要求鑒定的信息被發送給服務器:
SEND: <iq XMLns="jabber:clIEnt" type='get' id='id_10028'>
<query XMLns="jabber:iq:auth">
<username>user</username>
</query>
</iq>
RECV: <iq XMLns="jabber:clIEnt" type='result' id='id_10028'>
<query XMLns="jabber:iq:auth">
<username>user</username>
<passWord />
<digest/>
<sequence>482</sequence>
<token>3D15E63A</token>
<resource />
</query>
</iq>
在用戶鑒定程序前述那段顯示了第一次交換。開始,客戶向服務器詢問哪種鑒定方式對於給定用戶是有效的。服務器段用下面的鑒定方法回答:
·Plain 文本:<passWord />標簽
·零知識鑒定:使用<sequence>和<token>標簽
·<digest/>:象plain文本,但密碼是SHA-1 (安全無序運算法則)-用用戶的plain文本密碼進行編碼
我們實際上使用<digest/>,象下面代碼段描述的一樣:
SEND: <iq XMLns="jabber:clIEnt" type='set' id='id_10030'>
<query XMLns="jabber:iq:auth">
<username>user</username>
<hash>425c73373237061edcc5f23ba239c6cc69556f5c</hash>
<resource>Home</resource>
</query>
</iq>
RECV: <iq XMLns="jabber:clIEnt" type='result' id='id_10030'></iq>
在這一點,用戶連接到服務器並能夠開始發送和接收消息:
SEND: <message XMLns="jabber:clIEnt" type='headline'
id='id_10032' to='user2@localhost'>
<thread XMLns="jabber:clIEnt">id_10033</thread>
<subject XMLns="jabber:clIEnt">Hello world</subject>
<body XMLns="jabber:clIEnt">Hello world</body>
</message>
上面片段顯示了我們發送給接收者user2@localhost的測試標題消息。
你可能已經注意到在前述協議段有一個重復出現元素:ID標簽。因為session能夠由多個異步會話組成,ID標簽匹配查詢並響應。
接收消息
自從這篇文章的主要方向是向你顯示如何開發一個報警系統,我就很少注意消息接收。然而,為了完整性的利益,我應該討論在Muse API中處理接收消息的一些有用特性。另外,因為報警服務是被登錄到Jabber服務器的用戶執行的,你能夠適當地期望一些消息接收者試圖與發送者通信。
Muse使用一個listener附在session上以接收進入消息的提示。下面代碼顯示了如何創建一個listener並將其附到session——listener實際上附加到連接上,但自從我們的接口是在session級別並且JabberSession類有一個便利的方法添加一個listener,我們就將其附加到session:
1 jabberSession.addMessageListener(
2 new JabberMessageListener() {
3 public void messageReceived(JabberMessageEvent event) {
4 if (event.getMessageType() == JabberCode.MSG_CHAT ) {
5 JabberChatMessage msg =
6 (JabberChatMessage)event.getMessage();
7 JabberChatMessage reply = new
8 JabberChatMessage(JabberChatMessage.TYPE_HEADLINE);
9 reply.setTo(msg.getFrom());
10 reply.setSubject("Re: "+msg.getSubject());
11 reply.setBody(
12 "I'm just a sender: please send messages to someone else");
13
14 //發送消息
15 jabberSession.sendMessage(reply);
16 }
17 }
18 }
19 );
客戶能夠添加幾個消息listeners,每次一個消息被接收它們都要被調用。典型的,你為要處理的每一個類型的消息添加一個listener。另一個選擇:為同一種消息類型但在那些消息中的每一種不同的行為添加多個listeners。然而另一種選擇將添加一個要處理所有消息類型的listener。選擇依賴於你想完成什麼。
在上面的例子中,一個單獨的listener被附加。Listener必須是實現JabberMessageListener接口的類的一個實例。這個接口要求一個要被執行的單個方法: void messageReceived(JabberMessageEvent)。當一個消息從服務器被接收時這個方法將被調用。在例子代碼中,messageReceived()方法首先檢查在第4行接收的消息類型。自從Jabber用戶代理使用了MSG_CHAT類型發送消息,就只對這種類型消息才感興趣。在第5行,Jabber消息從JabberMessageEvent 提取。在第9行通過設置收件人接收消息被用來構成一個給消息發送者的回復並且在第10行拷貝接收消息的主題。一個缺省錯誤文本被作為消息體在第11行被設置,並且,在第15行,消息使用前面例子同樣的方法利用JabberSession對象的sendMessage()方法傳輸。
試試Jabber
這篇文章提供了一個對於Jabber協議及少量你能夠將這一技術應用到你的應用程序中去的開放資源方案的基本介紹。對這個協議有用的應用程序多種多樣,並不限於傳統P2P感覺的即時消息領域。例如,jogger.jabber.org提供的Jogger,一個允許你通過發送一個消息給Weblog應用程序(blog)就能更新個人網絡雜志的有趣服務。Jabber在用戶服務應用程序及其它結構的協作類型應用程序同樣有很大的影響。
象上面例子所顯示的一樣,你使用一個API如Muse或JabberBeans在少許幾行Java代碼中就能夠完成即時消息功能。記住我不能掩蓋一些Jabber其它重要的特征,如現場服務和登記表管理,這些在使用時都是相關的。另一個重要的特征是Jabber服務器的模塊性和可擴展性,它允許一個開發者創建新的服務直接整合進服務器。
作者:Jason Kitchen 著 劉建華 編譯