`

Smack 体系结构

阅读更多

Smack 体系结构
Zhuam (zhuam... @gmail.com)
摘要:
本文从宏观上介绍Smack类库的基本架构以及源代码的组织方式,并不会涉及太多的代码细节,如果你想从整体了解Smack,有必要一读。

Smack
在我看来可以分为三个基本层面(通讯层、协议层、核心Wrapper层),注:软件分层的看法各不同,可能我认为这样划分比较好,你也可能觉得你的划分更贴切,但都没关系,随你的爱好吧,注:由于系统核心Wrapper层主要用到了Observer设计模式,如果对Observer模式不是很熟悉,请看我的一篇(Observer设计模式)文章,里面有比较清晰的阐述。
基本的通讯层采用Java
传统I/O机制来实现,用实现消息的收发。
协议层实现了基本的IQ、Presence、Message 等Jabber
Packet,同时他也提供了一个让您扩展自定义协议的Provider
机制。
核心Wrapper
层在我看来是逻辑最为复杂的一层,在这一层中有好几个亮点
Filter 和Observer机制。

总体结构概览:

参考:Smack Overview  、Getting Started With Smack (Smack
官方文档)。

核心Wrapper 层
Packet 的发送:

用Smack发送一个Packet ,是将Packet 分别加入到queue 和
sendPackets 队列中去,然后由 WriterThread
这个线程将queue中的Packet
发到Jabber服务器,而至于ListenerThread线程则是将sendPackets这个队列中的Packet
交给Listeners中的监听器来监听处理,keepAliveThread
这个线程看名字就知道,是用于发KeepAlive消息的,这里如果配置需要发送KeepAlive
消息的话,那这个消息将会是一个空格并被定时发送给Jabber
Server。

参考 :Messaging using Chat and GroupChat (Smack 官方文档)

Packet的接收:

PacketReader 中启动两个线程来监控并操作从Socket
中来的消息,一个是ReaderThread线程和一个ListenerThread
线程,当消息到达Socket缓冲区的时候,ReaderThread
会从Socket中解析这个消息,并将消息转换成适当的消息对象,并由这些特定Filter来过滤这些消息并保存到相应的收集器中(PacketCollector)中去,然后由ListenerThread
来将这些特定收集器中的Packet交由特定的Listener
来处理,至于Filter
我在这里没有细说,简单概况一下功能,过滤某一个或者某一些特定的Packet,如:AndFilter
就是可以组合多个PacketFilter为一个Filter
集合,当他们的过滤结果都为真的时候,才会截获这个Packet并将该Packet存储到PacketCollector中。

下面给出Filter部分设计类图:

参考:Processing Incoming Packets(Smack 官方文档)

协议层:
(1)     Packet 基本设计:
协议层是我感觉设计的最为灵活的一层,尤其他的Provider
Architecture非常到位,下面就先看一下org.jivesoftware.smack.packet

包中的设计类图,这个我不作解释,这个类图已经能够说明问题了。

另外一个org.jivesoftware.smackx.packet包都是Packet扩展。

(2)     Packet 高级设计:(Provider Architecture)
Provider
的设计目的就是方便协议的扩充,提供简易的扩展Packet
及扩展Packet
Provider(解析类),下面是org.jivesoftware.smack.provider
包类图:

ProviderManager 用于管理我们扩展的所有Provider
,且这些Packet
Provider声明都是被定义在外部的META-INF/smack.providers文件中,初始化必须由ProviderManager来加载所有Provider类,而至于扩展Packet的解析则是通过elementName
和 namespace 来确定Packet Provider类。

举例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实现,(注:
我所说的扩展Packet并不一定就代表这个Packet
是自创的,Jabber
发布的扩展协议,如果在这里用Provider
机制来实现,在我看来这就叫扩展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实现的扩展Packet解析或Packet本身。

请看org.jivesoftware.smackx.provider 中的类图:

Provider
Architecture的实现我只能讲到这里,其实关于Provider
Architecture说的最好的是官方文档,本想翻译出来,实在是怕本人的蹩脚英语,翻译出来的东西会伤害到您,所以大家伙就自己看英文吧!

参考:Provider Architecture: Packet Extensions and Custom IQ's

网络层:
至于网络层我的确不知道怎么说好,在我看了就是通过传统Java
I/O
来获取Socket缓冲区消息,并通过Socket发送消息,没什么可说的。

分享到:
评论
2 楼 z165153 2012-09-12  
想请问一下Message的packet是在哪个(provider)解析的?
1 楼 z165153 2012-09-12  
写的挺好的,学习了。

相关推荐

    Smack 文档

    #### 六、提供者体系结构 Smack 提供了一套灵活的提供者架构,用于处理不同类型的 XMPP 消息。这包括自定义消息类型的处理逻辑。 #### 七、Packet 属性 `Packet` 对象可以携带额外的信息,如状态、时间戳等,这些...

    android openfire xmpp smack即时通讯,包括:聊天发生文字,表情,图片,语音等.zip

    Openfire支持多用户聊天、群组管理、用户认证等功能,并具有可扩展的插件体系结构,可以方便地增加额外的功能。在本项目中,Openfire作为后端服务器,处理客户端发送的XMPP消息,实现用户之间的即时通信。 2. **...

    xmpp协议下载

    在"Smack+体系结构.doc"文件中,我们可能会找到关于Smack库的详细设计和架构信息。 XMPP协议的核心概念包括JID(Jabber Identifier),这是每个XMPP实体的唯一标识,类似于电子邮件地址;以及流(Stream),它是...

    基于xmpp的聊天程序(UI是QQ)服务器是apach的apollo服务器,绝对可用仅供参考。

    它支持多种特性,如多线程、事件驱动、插件体系结构,使得开发者可以方便地添加新的功能或定制服务。Apollo还提供了RESTful API和管理工具,便于服务器的管理和监控。 **客户端源码**: Xmpp客户端源码(模仿QQ)这...

    openfire插件开发(1)

    为了进行插件开发,你需要了解OpenFire的插件体系结构。OpenFire允许开发者通过实现特定接口的Java类来创建插件。这些类通常继承自`org.jivesoftware.openfire.plugin.Plugin`,并覆盖其中的方法,如`...

    openfire所有缺失的jar包

    Openfire通过插件体系结构扩展其功能,使得开发者可以轻松添加自定义功能。 2. **JAR包的重要性** JAR(Java Archive)文件是Java程序中的库文件,包含了一组类文件、资源文件和其他相关元数据。Openfire的运行和...

    openfire综合介绍

    这种选择使得XMPP具有极强的灵活性和可扩展性,因为XML本身就是一种结构化的数据交换格式,易于解析和生成。 即时通讯软件(Instant Messenger, IM),如我们常用的QQ、MSN Messenger以及Google Talk等,就是基于...

Global site tag (gtag.js) - Google Analytics