摘要: 本文從宏觀上介紹Smack類庫的基本架構(gòu)以及源代碼的組織方式,并不會涉及太多的代碼細(xì)節(jié),如果你想從整體了解Smack,有必要一讀。
Smack 在我看來可以分為三個基本層面(通訊層、協(xié)議層、核心Wrapper層),注:軟件分層的看法各不同,可能我認(rèn)為這樣劃分比較好,你也可能覺得你的劃分更貼切, 但都沒關(guān)系,隨你的愛好吧,注:由于系統(tǒng)核心Wrapper層主要用到了Observer設(shè)計模式,如果對Observer模式不是很熟悉,請看我的一篇(Ob server設(shè)計模式)文章,里面有比較清晰的闡述。 基本的通訊層采用Java 傳統(tǒng)I/O機(jī)制來實現(xiàn),用實現(xiàn)消息的收發(fā)。 協(xié)議層實現(xiàn)了基本的IQ、Presence、Message 等Jabber Packet,同時他也提供了一個讓您擴(kuò)展自定義協(xié)議的Provider 機(jī)制。 核心Wrapper 層在我看來是邏輯最為復(fù)雜的一層,在這一層中有好幾個亮點 Filter 和Observer機(jī)制。
總體結(jié)構(gòu)概覽:
參考:Smack Overview 、Getting Started With Smack (Smack 官方文檔)。
核心Wrapper 層 Packet 的發(fā)送:
用Smack發(fā)送一個Packet ,是將Packet 分別加入到queue 和 sendPackets 隊列中去,然后由 WriterThread 這個線程將queue中的Packet 發(fā)到Jabber服務(wù)器,而至于ListenerThread線程則是將sendPackets這個隊列中的Packet 交給Listeners中的監(jiān)聽器來監(jiān)聽處理,keepAliveThread 這個線程看名字就知道,是用于發(fā)KeepAlive消息的,這里如果配置需要發(fā)送KeepAlive 消息的話,那這個消息將會是一個空格并被定時發(fā)送給Jabber Server。
參考 :Messaging using Chat and GroupChat (Smack 官方文檔)
Packet的接收:
PacketReader 中啟動兩個線程來監(jiān)控并操作從Socket 中來的消息,一個是ReaderThread線程和一個ListenerThread 線程,當(dāng)消息到達(dá)Socket緩沖區(qū)的時候,ReaderThread 會從Socket中解析這個消息,并將消息轉(zhuǎn)換成適當(dāng)?shù)南ο螅⒂蛇@些特定Filter來過濾這些消息并保存到相應(yīng)的收集器中(PacketCollect or)中去,然后由ListenerThread 來將這些特定收集器中的Packet交由特定的Listener 來處理,至于Filter 我在這里沒有細(xì)說,簡單概況一下功能,過濾某一個或者某一些特定的Packet,如:AndFilter 就是可以組合多個PacketFilter為一個Filter 集合,當(dāng)他們的過濾結(jié)果都為真的時候,才會截獲這個Packet并將該Packet存儲到PacketCollector中。
下面給出Filter部分設(shè)計類圖:
參考:Processing Incoming Packets(Smack 官方文檔)
協(xié)議層: (1) Packet 基本設(shè)計: 協(xié)議層是我感覺設(shè)計的最為靈活的一層,尤其他的Provider Architecture非常到位,下面就先看一下org.jivesoftware.smack.packet
包中的設(shè)計類圖,這個我不作解釋,這個類圖已經(jīng)能夠說明問題了。
另外一個org.jivesoftware.smackx.packet包都是Packet擴(kuò)展。
(2) Packet 高級設(shè)計:(Provider Architecture) Provider 的設(shè)計目的就是方便協(xié)議的擴(kuò)充,提供簡易的擴(kuò)展Packet 及擴(kuò)展Packet Provider(解析類),下面是org.jivesoftware.smack.provider 包類圖:
ProviderManager 用于管理我們擴(kuò)展的所有Provider ,且這些Packet Provider聲明都是被定義在外部的META-INF/smack.providers文件中,初始化必須由ProviderManager來加載所有Pr ovider類,而至于擴(kuò)展Packet的解析則是通過elementName 和 namespace 來確定Packet Provider類。
舉例Jabber:iq:time Packet擴(kuò)展(節(jié)選自smack.providers文件): <!-- Time --> <iqProvider> <elementName>query</elementName> <namespace>jabber:iq:time</namespace> <className>org.jivesoftware.smackx.packet.Time</className> </iqProvider> 在org.jivesoftware.smackx.provider 包中都是擴(kuò)展Packet Provider實現(xiàn),(注: 我所說的擴(kuò)展Packet并不一定就代表這個Packet 是自創(chuàng)的,Jabber 發(fā)布的擴(kuò)展協(xié)議,如果在這里用Provider 機(jī)制來實現(xiàn),在我看來這就叫擴(kuò)展Packet)ProviderManager管理兩種類型的Provider:一種是IQProvider -解析IQ請求,另一種則是PacketExtensionProvider -解析附加在Packet 中的XML子文檔 。
因為Smack 默認(rèn)僅僅知道怎樣處理IQ Packets 以及下面這些擴(kuò)展Packet,他們的namespaces如下: jabber:iq:auth jabber:iq:roster jabber:iq:register 所以我們會看到org.jivesoftware.smackx.provider 包中都是用provider Architecture實現(xiàn)的擴(kuò)展Packet解析或Packet本身。
請看org.jivesoftware.smackx.provider 中的類圖:
Provider Architecture的實現(xiàn)我只能講到這里,其實關(guān)于Provider Architecture說的最好的是官方文檔,本想翻譯出來,實在是怕本人的蹩腳英語,翻譯出來的東西會傷害到您,所以大家伙就自己看英文吧!
參考:Provider Architecture: Packet Extensions and Custom IQ's
網(wǎng)絡(luò)層: 至于網(wǎng)絡(luò)層我的確不知道怎么說好,在我看了就是通過傳統(tǒng)Java I/O 來獲取Socket緩沖區(qū)消息,并通過Socket發(fā)送消息,沒什么可說的。
|