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