摘要
Jabber對于即時(shí)消息是一個(gè)開放的、基于XML的數(shù)據(jù)模型和協(xié)議。聯(lián)系不斷增加的基于Jabber開放資源和商業(yè)產(chǎn)品的數(shù)目,這種協(xié)議提供了擺脫即時(shí)消息服務(wù)器所有權(quán)束縛的一種方法。多種多樣的開放資源Java APIs能夠幫助你建立基于Jabber的服務(wù)器并將即時(shí)消息整合到你的應(yīng)用程序中去。在這篇文章中專門闡述了這一點(diǎn)。
當(dāng)討論Jabber標(biāo)準(zhǔn)的益處時(shí),我應(yīng)該提及IETF IM標(biāo)準(zhǔn)的工作。在寫這篇文章時(shí),其IMPPWG(即時(shí)消息和現(xiàn)場協(xié)議工作組)已有多個(gè)RFC有效,其中最重要的是:
·RFC 2778:現(xiàn)場和即時(shí)消息模型
·RFC 2779:即時(shí)消息/現(xiàn)場協(xié)議要求
IMPPWG已經(jīng)起草了一個(gè)名叫CPIM(公共現(xiàn)場和即時(shí)消息)協(xié)議的因特網(wǎng)標(biāo)準(zhǔn)。Jabber協(xié)議也是一個(gè)草擬的因特網(wǎng)標(biāo)準(zhǔn),但不是IMPPWG工作的部份。
Jabber在哪兒適合這一標(biāo)準(zhǔn)工作呢?依照J(rèn)abber網(wǎng)站,Jabber是“承諾完全支持任何開放實(shí)時(shí)消息協(xié)議,包括IETF協(xié)議”。如果當(dāng)對于這個(gè)IETF協(xié)議的支持增長時(shí),Jabber打算將自己定位為IETF協(xié)議的領(lǐng)導(dǎo)開放資源的平臺。到目前為止,IETF的工作更多地主要集中在收集要求上而不是執(zhí)行。暫時(shí),Jabber僅是一個(gè)帶有重要開放資源支持的開放即時(shí)消息和現(xiàn)場服務(wù)協(xié)議。結(jié)果,它成為開放即時(shí)消息事實(shí)上的標(biāo)準(zhǔn)。
另一個(gè)值得密切注意的競爭對手是Sun微系統(tǒng)的Jxta協(xié)議,另一個(gè)基于XML針對peer-to-peer(P2P)應(yīng)用程序開發(fā)者的協(xié)議。各種各樣的Jxta實(shí)施在今天已經(jīng)能夠被提供。但是,由于其起源相對較近,Jxta比起Jabber只有很少的牽引力。
下載并安裝
要開始使用Jabber,你首先需要下載必要的工具:你需要一個(gè)Jabber服務(wù)器,一個(gè)Jabber客戶端,一個(gè)幫助管理和隱藏一些復(fù)雜socket處理的API,XML語法分析,消息創(chuàng)建等等。
Jabber服務(wù)器
為了運(yùn)行Jabber,你選擇的Jabber服務(wù)器不能有問題,自從他們都接受了標(biāo)準(zhǔn)Jabber XML及與終端應(yīng)用程序通迅以釋放負(fù)荷,其也是標(biāo)準(zhǔn)Jabber XML。Jabberd,最初的Jabber服務(wù)器,是開放資源(但不是基于Java),安裝配置簡單并在多數(shù)平臺上都有效,包括Unix、Linux、Windows和Mac OS X。JabaServer開放資源方案也值得提及,但現(xiàn)在,這些基于Java的方案仍不如Jabberd成熟。同時(shí),JabaServer安裝不怎么簡單易懂,因?yàn)槟惚仨毾螺d、安裝并配置一個(gè)第三方數(shù)據(jù)庫,加上創(chuàng)建必需的數(shù)據(jù)庫規(guī)劃。
對于這篇文章的例子,我選擇Jabberd。當(dāng)二進(jìn)制及源下載對于jabberd都有效時(shí),我就不在這兒描述怎樣建立一個(gè)源發(fā)布。除非你真想自己編譯,可以從jabberd 主頁下載二進(jìn)制發(fā)布。在Windows平臺上安裝是相對容易的。發(fā)布是一個(gè).exe程序,按照安裝向?qū)б徊揭徊綀?zhí)行。
安裝完成后,你無需配置。在Windows2000,不要求配置。只要雙擊二進(jìn)制程序就可啟動服務(wù)器。
用戶代理/客戶
我決定使用Exodus客戶端,對于這個(gè)方案這是另一個(gè)開放資源技術(shù)。我尤其喜歡Exodus的調(diào)試標(biāo)簽,可以允許你正確地查看客戶發(fā)送和接收的XML。另外你能夠作為純粹的XML鍵入Jabber消息并將它們發(fā)送給服務(wù)器。所有這些都證明用Jabber協(xié)議和服務(wù)器測試的有用性。
Exodus的安裝簡單易懂。下載Exodus 壓縮文件(我在文章中使用的是0.6版本)。將文件直接解壓到你想要安裝客戶端的目錄。在這個(gè)版本中,文件是些簡單的二進(jìn)制文件和一個(gè).dll文件。你可以從Muse 主頁下載Muse API。
發(fā)送你的第一個(gè)Jabber消息
要發(fā)送一個(gè)Jabber即時(shí)消息,你必須初始化Muse Jabber API。通過創(chuàng)建一個(gè)JabberContext 類的實(shí)例來完成,接下來使用內(nèi)容作為一個(gè)參數(shù)到Jabber session factory類的createSession()方法:
1 //初始化Jabber context
2 JabberContext jabberContext = new JabberContext("user", "pass", "localhost");
4 //創(chuàng)建一個(gè)Jabber session factory的實(shí)例
5 Jabber jabber = new Jabber();
6 //創(chuàng)建新會話
7 JabberSession jabberSession = jabber.createSession(jabberContext);
上面的例子在第2行顯示了一個(gè)新context的創(chuàng)建。JabberContext存儲了指定的用戶相關(guān)信息(用戶名、密碼、用戶地址)以及稍后要使用context建立session時(shí)包含的一個(gè)唯一的會話標(biāo)識。為了闡述意圖,我直接使用了username、password和server。
在第5行,一個(gè)Jabber session factory被創(chuàng)建,我們在第7行使用它創(chuàng)建了一個(gè)新的JabberSession,Muse進(jìn)入由Jabber服務(wù)器提供的服務(wù)的主要接口。服務(wù)器的主要服務(wù)是:
·連接服務(wù): 從Jabber服務(wù)器連接和斷開
·用戶服務(wù): 針對用戶鑒定及注冊
·現(xiàn)場服務(wù): 接收從其它用戶/服務(wù)來的及你自己廣播的現(xiàn)場信息
·登記表服務(wù): 密友列表或地址薄
·聊天服務(wù): 發(fā)送多種類型的消息—組聊、私聊、標(biāo)題等等
·服務(wù)器服務(wù): 獲得與由這個(gè)Jabber服務(wù)器提供的服務(wù)相關(guān)的信息
·客戶服務(wù): 獲得關(guān)于其他用戶的信息,比如用戶登錄的最后時(shí)間
現(xiàn)在我們已經(jīng)有了一個(gè)已經(jīng)初始化的Jabber session,我們能夠用它在我們才創(chuàng)建的JabberSession對象中使用connect()方法去連接到Jabber 服務(wù)器:
8 //連接到服務(wù)器
9 jabberSession.connect("localhost", 5222);
要連接到一個(gè)Jabber服務(wù)器,我們指定地址及在指定服務(wù)器上的機(jī)器端口號。標(biāo)準(zhǔn)來說,缺省Jabber端口是5222。
現(xiàn)在JabberSession已經(jīng)連接到服務(wù)器,我們能夠在我們的服務(wù)中用login()方法登錄:
10 //登錄到Jabber服務(wù)器
11 jabberSession.getUserService().login();
在第11行,我們使用JabberSession獲得一個(gè)到UserService的引用,接下來在我們服務(wù)中調(diào)用login()方法。注意方法自身不指定任何用戶信息。當(dāng)在上面第7行JabberSession被創(chuàng)建時(shí)login()從與JabberSession相關(guān)的JabberContext中獲得這些信息。
現(xiàn)在我們已經(jīng)成功登錄到Jabber服務(wù)器,我們能夠開始發(fā)送和接收消息。下面代碼段顯示了如何構(gòu)造一個(gè)簡單的標(biāo)題風(fēng)格的消息:
12 //構(gòu)造測試消息
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行,我們創(chuàng)建了一個(gè)JabberChatMessage實(shí)例。單個(gè)參數(shù)指定了我們要求的消息類型:TYPE_HEADLINE。JabberChatMessage類的名字容易引起誤解,實(shí)際上,它可以用來包含在Jabber協(xié)議中定義的消息的任何四種類型—普通、聊天、標(biāo)題及錯誤。在第15行,setSubject()和setBody()分別指定主題和內(nèi)容。最后,setTo()在第17行設(shè)置消息接收器的JID。
在封裝下,JabberChatMessage將所有這些信息轉(zhuǎn)換成一個(gè)內(nèi)在的DOM(文檔對象模型)樹,這樣當(dāng)我們已經(jīng)準(zhǔn)備好發(fā)送消息給Jabber服務(wù)器時(shí)能夠輕松產(chǎn)生XML。
最后步驟:用sendMessage()方法發(fā)送消息:
18 //發(fā)送消息
19 jabberSession.sendMessage(msg);
在封裝下
依據(jù)上面例子所得的事實(shí),Muse API有效地隱藏了與連接管理和XML語法分析有關(guān)的所有細(xì)節(jié),因此允許你集中精力在手邊的任務(wù)上:創(chuàng)建一個(gè)消息服務(wù)。然而,理解一些基礎(chǔ)協(xié)議交換證明是有用的。讓我們關(guān)注一下當(dāng)我們連接到服務(wù)器時(shí)發(fā)生的XML交換,登錄,并象上面代碼描述的一樣發(fā)送消息。在下面的XML交換中,被客戶接收的消息(我們例子代碼)帶了RECV前綴,送到服務(wù)器的消息帶有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交換都發(fā)生在一個(gè)XML流的上下文。在我們客戶與Jabber服務(wù)器之間連接的生命期間,兩個(gè)完全的XML文檔在一個(gè)時(shí)間傳輸一個(gè)片段。上面顯示的最初交換允許客戶開始發(fā)送XML流文檔到服務(wù)器并且服務(wù)器開始發(fā)送XML流文檔到客戶。
下面,一個(gè)要求鑒定的信息被發(fā)送給服務(wù)器:
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>
在用戶鑒定程序前述那段顯示了第一次交換。開始,客戶向服務(wù)器詢問哪種鑒定方式對于給定用戶是有效的。服務(wù)器段用下面的鑒定方法回答:
·Plain 文本:<password />標(biāo)簽
·零知識鑒定:使用<sequence>和<token>標(biāo)簽
·<digest/>:象plain文本,但密碼是SHA-1 (安全無序運(yùn)算法則)-用用戶的plain文本密碼進(jìn)行編碼
我們實(shí)際上使用<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>
在這一點(diǎn),用戶連接到服務(wù)器并能夠開始發(fā)送和接收消息:
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>
上面片段顯示了我們發(fā)送給接收者user2@localhost的測試標(biāo)題消息。
你可能已經(jīng)注意到在前述協(xié)議段有一個(gè)重復(fù)出現(xiàn)元素:ID標(biāo)簽。因?yàn)閟ession能夠由多個(gè)異步會話組成,ID標(biāo)簽匹配查詢并響應(yīng)。
接收消息
自從這篇文章的主要方向是向你顯示如何開發(fā)一個(gè)報(bào)警系統(tǒng),我就很少注意消息接收。然而,為了完整性的利益,我應(yīng)該討論在Muse API中處理接收消息的一些有用特性。另外,因?yàn)閳?bào)警服務(wù)是被登錄到Jabber服務(wù)器的用戶執(zhí)行的,你能夠適當(dāng)?shù)仄谕恍┫⒔邮照咴噲D與發(fā)送者通信。
Muse使用一個(gè)listener附在session上以接收進(jìn)入消息的提示。下面代碼顯示了如何創(chuàng)建一個(gè)listener并將其附到session——listener實(shí)際上附加到連接上,但自從我們的接口是在session級別并且JabberSession類有一個(gè)便利的方法添加一個(gè)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 //發(fā)送消息
15 jabberSession.sendMessage(reply);
16 }
17 }
18 }
19 );
客戶能夠添加幾個(gè)消息listeners,每次一個(gè)消息被接收它們都要被調(diào)用。典型的,你為要處理的每一個(gè)類型的消息添加一個(gè)listener。另一個(gè)選擇:為同一種消息類型但在那些消息中的每一種不同的行為添加多個(gè)listeners。然而另一種選擇將添加一個(gè)要處理所有消息類型的listener。選擇依賴于你想完成什么。
在上面的例子中,一個(gè)單獨(dú)的listener被附加。Listener必須是實(shí)現(xiàn)JabberMessageListener接口的類的一個(gè)實(shí)例。這個(gè)接口要求一個(gè)要被執(zhí)行的單個(gè)方法: void messageReceived(JabberMessageEvent)。當(dāng)一個(gè)消息從服務(wù)器被接收時(shí)這個(gè)方法將被調(diào)用。在例子代碼中,messageReceived()方法首先檢查在第4行接收的消息類型。自從Jabber用戶代理使用了MSG_CHAT類型發(fā)送消息,就只對這種類型消息才感興趣。在第5行,Jabber消息從JabberMessageEvent 提取。在第9行通過設(shè)置收件人接收消息被用來構(gòu)成一個(gè)給消息發(fā)送者的回復(fù)并且在第10行拷貝接收消息的主題。一個(gè)缺省錯誤文本被作為消息體在第11行被設(shè)置,并且,在第15行,消息使用前面例子同樣的方法利用JabberSession對象的sendMessage()方法傳輸。
試試Jabber
這篇文章提供了一個(gè)對于Jabber協(xié)議及少量你能夠?qū)⑦@一技術(shù)應(yīng)用到你的應(yīng)用程序中去的開放資源方案的基本介紹。對這個(gè)協(xié)議有用的應(yīng)用程序多種多樣,并不限于傳統(tǒng)P2P感覺的即時(shí)消息領(lǐng)域。例如,jogger.jabber.org提供的Jogger,一個(gè)允許你通過發(fā)送一個(gè)消息給Weblog應(yīng)用程序(blog)就能更新個(gè)人網(wǎng)絡(luò)雜志的有趣服務(wù)。Jabber在用戶服務(wù)應(yīng)用程序及其它結(jié)構(gòu)的協(xié)作類型應(yīng)用程序同樣有很大的影響。
象上面例子所顯示的一樣,你使用一個(gè)API如Muse或JabberBeans在少許幾行Java代碼中就能夠完成即時(shí)消息功能。記住我不能掩蓋一些Jabber其它重要的特征,如現(xiàn)場服務(wù)和登記表管理,這些在使用時(shí)都是相關(guān)的。另一個(gè)重要的特征是Jabber服務(wù)器的模塊性和可擴(kuò)展性,它允許一個(gè)開發(fā)者創(chuàng)建新的服務(wù)直接整合進(jìn)服務(wù)器。