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