在构造SessionManagerTask对象时，我们必须要实现XmppTaskParentInterface特例。以下为XmppTaskParentInterface抽象接口说明：

    class XmppTaskParentInterface : public talk_base::Task {

XmppReturnStatus eyouim_XmppEngineImpl::AddStanzaHandler(XmppStanzaHandler* handler, HandlerLevel level /*= HL_PEEK*/)

{

stanza_handlers_[level]->push_back(handler);

return XMPP_RETURN_OK;

}

处理socket接收到的数据，会遍历stanza_handlers_ 容器中的处理器，如果匹配就将数据给相关的处理处理

XmppReturnStatus eyouim_XmppEngineImpl::HandleInput(const char * bytes, size_t len)

{

buzz::XmlBuilder builder;

buzz::XmlParser::ParseXml(&builder, bytes);

buzz::XmlElement *stanza = builder.BuiltElement();

for (size_t i = 0; i < stanza_handlers_[HL_PEEK]->size(); i += 1) {

(*stanza_handlers_[HL_PEEK])[i]->HandleStanza(stanza);

}

// give other handlers a shot in precedence order, stopping after handled

for (int level = HL_SINGLE; level <= HL_ALL; level += 1) {

for (size_t i = 0; i < stanza_handlers_[level]->size(); i += 1) {

if ((*stanza_handlers_[level])[i]->HandleStanza(stanza))

return XMPP_RETURN_OK;

}

}

// If nobody wants to handle a stanza then send back an error.

// Only do this for IQ stanzas as messages should probably just be dropped

// and presence stanzas should certainly be dropped.

std::string type = stanza->Attr(QN_TYPE);

if (stanza->Name() == QN_IQ &&

!(type == "error" || type == "result")) {

SendStanzaError(stanza, XSE_FEATURE_NOT_IMPLEMENTED, STR_EMPTY);

return XMPP_RETURN_UNEXPECTED;

}

return XMPP_RETURN_OK;

}

       移除相关的处理器

XmppReturnStatus eyouim_XmppEngineImpl::RemoveStanzaHandler(XmppStanzaHandler* handler)

{

bool found = false;

for (int level = 0; level < HL_COUNT; level += 1) {

StanzaHandlerVector::iterator new_end =

std::remove(stanza_handlers_[level]->begin(),

stanza_handlers_[level]->end(),

handler);

if (new_end != stanza_handlers_[level]->end()) {

stanza_handlers_[level]->erase(new_end, stanza_handlers_[level]->end());

found = true;

}

}

if (!found)

return XMPP_RETURN_BADARGUMENT;

return XMPP_RETURN_OK;

}

    笔者同样也实现了 XmppTaskParentInterface 和 XmppClientInterface 特例，以下为部分代码和说明：

    XmppClient.h头文件

    class XmppClient : public buzz::XmppTaskParentInterface

, public buzz::XmppClientInterface

, public sigslot::has_slots<>

{

public:

XmppClient(talk_base::TaskParent * parent);

~XmppClient();

                //设置输出处理器，这样的好处是应用层可以定义具体的实现

void set_XmppOutputHandler(buzz::XmppOutputHandler *pXmppOutputHandler)

{

m_engine->SetOutputHandler(pXmppOutputHandler);

}

                

                //处理socket接收到的数据

XmppReturnStatus HandleInput(const char * bytes, size_t len)

{

return m_engine->HandleInput(bytes,len);

}

XmppReturnStatus Disconnect();

//XmppTaskParentInterface

virtual XmppClientInterface* GetClient();

//XmppClientInterface

virtual buzz::XmppEngine::State GetState() const;

virtual const buzz::Jid& jid() const;

virtual std::string NextId();

virtual XmppReturnStatus SendStanza(const buzz::XmlElement* stanza);

virtual XmppReturnStatus SendStanzaError(const buzz::XmlElement* original_stanza,

XmppStanzaError error_code,

const std::string& message);

virtual void AddXmppTask(buzz::XmppTask* task, buzz::XmppEngine::HandlerLevel level);

virtual void RemoveXmppTask(buzz::XmppTask* task);

//task

virtual int ProcessStart();

protected:

private:

talk_base::scoped_ptr<XmppEngine> m_engine;

};

  

    XmppClient.cpp实现

    XmppClient::XmppClient(talk_base::TaskParent * parent)

       XmppPump *m_pXmppPump = new XmppPump(NULL);