openfire 源码分析 session & connection

今天学习openfire的 connect, session,  sessionManager, routingtable

创建连接的入口在 org.jivesoftware.openfire.nio.ConnectionHandler.sessionOpened中

sessionOpened 做的事情有 生成一个xmlParser、NIOConnection, StanzaHandler

1.connect

    NIOConnection 类实现org.jivesoftware.openfire.Connection接口

    Connection 接口负责发送报文，获取hostAddress,hostName,开始tls连接，一些判断等。

    发送报文使用的ioSession 实现的。

 

 

2.session

    每一个stanzaHandler 中都含有一个session, 下图是整个client session的结构图

    LocalClientSession 构造参数有 serverName, xmlParser, connector

    

 

    ChannelHandler, RoutableChannelHandler, Session, ClientSession 都是接口，他们之间的关系如下

        ChannelHandler 

            动作是处理报文

 

        RoutableChannelHandler extends ChanneHandler   

            RoutableChannelHandler 的主要动作是获取JID

 

        Session extends RoutableChannelHandler 

            Session 主要动作是发送字符串，处理报文，获取连接信息和一些连接是否正常的判断

 

        ClientSession extends Session  

            ClientSession 主要动作是设置用户聊天是设置和使用的策略，获取用户名，获取和设置用户当前状态Presence，当前用户是否为匿名用户

 

    LocalSession implements Session   

        LocalSession 是一个抽象类，主要扩展了发送和接收数据包数量的统计功能，保存和获取会话一些的数据，获取connection

 

    LocalClientSession extends LocalSession implements ClientSession 

        LocalClientSession 是LocalSession 实现类

        构造方法需要的参数有serverName， connection，streamId

        LocalClientSession 增加了AuthToken 属性，即验证类

        在session验证以后，设置AuthToken 的处理逻辑如下

            设置jid，设置authToken，设置session已经验证过的状态，设置默认聊天策略列表，调用sessionManager.addSession(this)方法

            addSession(Session) 方法中从PreAuthenticatedSessions 中删除session， 向路由表中增加session， 发送session创建成功通知

 

 

3.routingtable

    RoutingTable是一个接口，提供主要方法是jid和session 键值对的增删查， 发送广播消息，获取服务器的名称，获取服务器session个数。判断是否含有session，路由发包。

    接口主要对三类session进行操作， clientRoute， componentRoute， serverRoute

    routingtable的主要方法如图所示：

    实现类 RoutingTableImpl extends BasicModule implements RoutingTable, ClusterEventListener

 

4.sessionManager

    主要实现的功能有 创建、获取、删除 clientSession, componentSession, serverSession, 发送广播消息，加入集群