这样每一个session在打开时都会设置handler，而具体的handler由各个派生类创建返回。这里的StanzHandler就是Openfire里的数据包处理单元。和connection类型一样，包处理也是对应的几个类：
注：
Session模块
对于Openfire来说一个比较重要的功能就是管理session，因为要与客户端实时的进行数据通讯，所以必须保持着连接。在Openfire中对于Session的管理都集中在SessionManager模块。但在前面说到连接管理时已经知道了IoSession的创建过程，但并没有看到openfire是如何管理它的。接着ConnectionHandler和StanzaHandler就能知道其中有奥秘。
前面知道了ConnectionHandler是连接的处理者，这里会有连接的创建、关闭、数据收发的处理，回到ConnectionHandler这个抽象类中。对于创建时(sessionOpend)主要是创建了StanzaHandler，这样就把数据包的处理委托给了StzanzHandler（派生类）。但是这个时候并没有将session放入到openfire的session管理模块中，而是在客户端发送数据过来后才开始的。
先看看ConnectionHandler的messageReceived方法：
@Override public void messageReceived(IoSession session, Object message) throws Exception { // Get the stanza handler for this session StanzaHandler handler = (StanzaHandler) session.getAttribute(HANDLER); // Get the parser to use to process stanza. For optimization there is going // to be a parser for each running thread. Each Filter will be executed // by the Executor placed as the first Filter. So we can have a parser associated // to each Thread final XMPPPacketReader parser = PARSER_CACHE.get(); // Update counter of read btyes updateReadBytesCounter(session); //System.out.println("RCVD: " + message); // Let the stanza handler process the received stanza try { handler.process((String) message, parser); } catch (Exception e) { Log.error("Closing connection due to error while processing message: " + message, e); final Connection connection = (Connection) session.getAttribute(CONNECTION); if ( connection != null ) { connection.close(); } } }
在接收到数据包后获取到StanzaHandler，然后调用了它的process方法，也就是让实际的包处理者去处理数据。这样就回到了StanzeHanler，以ClientStanzaHandler为例子。只不过这个派生类中没有重写process方法，也就是说要看父类的实现：
public void process(String stanza, XMPPPacketReader reader) throws Exception { boolean initialStream = stanza.startsWith("<stream:stream") || stanza.startsWith("<flash:stream"); if (!sessionCreated || initialStream) { if (!initialStream) { .......... // Found an stream:stream tag... if (!sessionCreated) { sessionCreated = true; MXParser parser = reader.getXPPParser(); parser.setInput(new StringReader(stanza)); createSession(parser); } .......... return; } .......... }
由于代码较多，我省略了一些代码。看到这应该明白了吧，对于当前的连接没有创建Openfire的session对象时，会进行创建过程createSession，对于不同的StanzeHandler会有些不一样，这里ClientStanzaHandler的实现就是把创建好的session放到本地的LocalClientSession中：
@Override boolean createSession(String namespace, String serverName, XmlPullParser xpp, Connection connection) throws XmlPullParserException { if ("jabber:client".equals(namespace)) { // The connected client is a regular client so create a ClientSession session = LocalClientSession.createSession(serverName, xpp, connection); return true; } return false; }
到这一个session算是建立完成了。
集群下的session