gloox消息发送与接受剖析

解析的很好，赞个！原文地址：http://blog.csdn.net/qiuhong101/article/details/3514784

当你连接至服务器之后，你会获得一个客户端实例对象（Client），如果一直要保持连接的话，该实例对象应该一直存在。Client这个对象提供了一个recv()的该方法，通过该方法，就可以接收来自远端的消息了（recv文法默认是阻塞的方式的，如果不需要阻塞，可以通过其参数设置就可以了）。

Gloox在接收远端发来的消息时，会调用一个接口的实现类，该接口为：MessageSessionHandler，这个接口里面提供了一个handleMessageSession( MessageSession *session ) = 0方法，当远端有文本消息发来时，Socket接收数据中会创建一个MessageSession实例对象，表明有一个会话产生（一个无端与本地的会话就有一个对应的MessageSession对象），这时如果你注册了实现MessageSessionHandler接口的实现类，则客户端Client会自动调用你的实现类中的handleMessageSession（处理消息会话）接口。HandMessageSession的函数表现形式为：

virtual void handleMessageSession( MessageSession *session )

传入的参数MessageSession里面含有会话的相关信息，此时，如果你希望能获得里面的相关信息，则应该注册一个接口实现类，则程序将会自动调用你的接口实现类，这个接口类名为：MessageHandler，从字面意思可以看出，注册的这个接口类应该是关于收到的消息的处理接口，也就是说如果你实现了这个接口，并注册至MessageSession对象中，则你将会得到你所需要的消息，注册MessageHandler接口实现类的方法是调用MessageSession参数传入的session->registerMessageHandler( this );方式，示例代码中的this指的是接收消息类，该类实现了MessageHandler中的handleMessage方法。MessageHandler中的virtual void handleMessage( Stanza *stanza, MessageSession *session = 0 )方法就是你需要实现的，同时可以在该方法内得到你所需要的文本信息。下面是得到这样的文本信息的示例代码：

std::string msg =  stanza->body();//也即通过stanza参数传入的变量，通过得到其中的//body就可以得到无端给你发来的文本消息了。

而stanza->from()可以获得发送给你的远端的一个完整的JID号，这个很有用，因为你得区分是谁给你发来的消息。当然你可以获得一些其他的可能对你有用的信息，我这里暂且只举这两个通常都要用到的。

如果你得到了所想要的信息，并且也知道了是谁发给你的，这时你就可以在你的表现层里面进行进一步的处理了，当然应该是在你实现的MessageHandler中的handleMessage方法里面，比如你用MFC来做显示的话，这里就可以先通过获得MFC中相关的显示文本内容的地方的句柄，然后再将获得的文本信息写入即可。

说到接收的文本信息，通常还有一个问题，就是关于文本字体，颜色等相关的属性问题，这在XMPP标准协议中并没有这方面的文档，主要原因我觉得是因为在文本样式显示上的表现标准不相同，比如在WEB的文本显示和C/S模式下的文本显示等。不过关于XMPP协议有一个扩展的协议提到了这个问题，这个扩展协议扩展了一个叫做XHTML的扩展，从名字上看，应该是和WEB方面的文本样式表现差不多。由于这个不是标准使用的，而是建议使用的，在我的了解中，很多都是根据自己的需求，做了自己的扩展，而并没有参考XHTML进行扩展。

那么如何进行文本样式的扩展呢，其实从接收文本消息的那个接口实现类的方法中可以看出，当我们通过stanza->body()时，就可以获得一个std::string的文本内容，试想一下，如果这个字符串型的文本内容是这样的表现，它应该是什么意思呢？

<style size=’12px’ color=’red’>您好，世界</style>

从上面的示例来看，它应试表达的是传输的文本内容是“您好，世界”，而这句文本内容大小应该是12象素，显示的颜色应该是红色显示。可是我们通过stanza->body()之后，得到的是除了文本内容之外，还含有其对应的样式表现。那么应该怎么来分离内容与表现呢？

你可以通过字符串关键字来截取上面收到的文本信息，这样可以获得文本内容和样式，不过这个方法并不是很好的方式，虽然可以做得到。gloox内部提供了一个方法来处理这样的表现，这也是为了考虑自行扩展的原因出现的。使用Parser类就可以实现将字符串内容转换为面向对象的方式来操作，你就可以通过获得属性和值的方式来获得你想要的表现与内容了。Parser类的构造函数要求是一个继承了接口实现类的函数，该接口类是：TagHandler，从字面意思可以看出，是要求用户实现这个处理Tag值的接口，这个接口里面含有一个抽象方法，是void handleTag( Tag *tag ) ;这样就可以解析你所收到的那样的字符串了，Tag标识的使用，可以参考gloox示例中的test里面的相关使用方法，这里只做一个使用的示例：

Parser pp(this);    //我这里的this是指的接收消息的类，其中实现了TagHandler接口中的//handleTag方法。

       pp.feed(stanza->body());//当调用这个语句时，就会调用handleTag方法了。

下面是我的handleTag的处理方法实现

void MyRecvMessage::handleTag( Tag *tag )

{

       std::cout<<tag->xml()<<std::endl;

       string fontSize = tag->findAttribute("size");//得到文本大小

       std::cout<<fontSize<<std::endl;    

      

       string msgtt = tag->cdata();//得到文本内容

}

另外还有一个地方需要注意，就是关于handleMessageSession( MessageSession *session )方法的实现类中，session对象是在gloox内部创建的，需要你将其删除掉，如果你不需要了，删除方法是调用Client对象中的disposeMessageSession方法，即可删除掉session对象了，示例代码：client->disposeMessageSession( m_session );如果不删除这个，则有内存泄露的危险。

那么这个session是个什么东东呢？它的意思是当你和远端，或者远端和你有消息发送或者接收时，就会创建一个Session对象，用这个对象来存储交互的信息，所以当你处理这个对象里面的信息之后，就可以将其删除掉了。具体的使用情况可以参考gloox中的示例程序中的相应地方。至于示例程序中的处理消息事件和聊天状态的句柄的使用，则可以通常查看相关的源文件的注释，可以看出来大概是如何使用和在什么情况下使用了。

如果远端继续给你发消息的话，因为你已经删除了对应的Session对象，所以gloox后台又会创建一个MessageSession对象的，所以对于MessageSession对象的管理是一个值得好好考虑的问题了，同样对于向远端发送文本消息也一样存在着这个MessageSession对象的管理问题。因为一个很明显的现象，就是你和远端的某一个JID进行通话，至于是你结束你们之间的通话，还是远端结束你们之间的通话这个是并不明确的，也是不定时的，比如远端在某一个时刻给你发了消息，他有可能就只发送了这一个消息，就不再发送了，这时你可以将MessageSession删除掉（调用Client对象中的disposeMessageSession方法），但是你完全也有可能还会和你继续通信，所以你可以不用删除这个MessageSession对象。这样只要这个MessageSession对象一直保留着，你就可以随时和远端进行通讯了。但是如果有很多远端都要和你通讯，而你不删除这个MessageSession对象的话，则内存中将会有很多的这样的对象，而实际中，可能有些对象应该已经过期了，所以应该删除之。

删还是不删，是个问题，因为删的话，可能这个会话还在继续，而频繁的创建删除对象，是会带来一定的开销的，如果不删的话，则可能这个会话已经不存在了。所以这里有个策略的东西存在。你得根据你的需求和所考虑的情况来做决策，以更好的管理这些MessageSession对象。

     Gloox发消息很简单，通过前面的接消息的描述，当需要与远端进行通话时，建立一个MessageSession会话，一旦你拥有这样的一个会话对象了，就可以调用其中的send方法来向远端发送消息了。那么这个MessageSession如何获得呢？

通过前面接消息的描述，如果是远端先给你发了消息，此时gloox后台就会创建一个MessageSession对象出来，而如果你收到这个MessageSession传来的消息之后，如果不将其删除，并且通过某种数据结构，如STL中的map，其关键字是远端的JID号，而value值就是这个MessageSession，那么，如果你需要向远端发消息时，从该map中通过远端的JID号，查找对应的MessageSession指针，就可以调用其中的send方法向远端发消息了。

现在有一个问题是，如果远端没有主动向你发消息呢？其实也很简单，自己创建一个MessageSession对象，也是可以发的，当然，如果你需要保存创建的MessageSession对象的话，也是需要通过自己的数据结构进行保存的。创建一个MessageSession对象很简单，示例代码如下：

JID jid( remoteId);

MessageSession *mess = new MessageSession(client,jidd);

mess->send(“您好”);

client->disposeMessageSession(mess);

对上面的代码做一个解释：

第一行主要是创建一个JID，里面的remoteId用来指明要向远端发送消息的标识，应该是这样的一个std::string型的字符串，示例如：remoteId = test@xppserver/test，第一行中构造了一个JID对象，用来表示向哪一个远端发消息的标识。

第二行中就是创建一个MessageSession对象，构造函数中的第一个参数，是一个Client型的指针，在和XMPP服务建立连接的一文中，已经说明了如果获得这样一个连接，现在构造这样一个MessageSession，其第一个参数就是这样的连接指针，而第二个参数很简单了，就是在第一行创建的JID对象。

第三行就是调用MessageSession对象中的send方法，向远端发送消息，其参数是一个STL中的string型字符串。当你调用这个send方法后，就可以发远端发消息了，远端也可以接收你所发送的消息。

第四行并不是必须的，如果你需要保存这个MessageSession对象，以希望下次能够继续通过该对象向远端发送消息，则不用调用该方法，那么这个方法是用来干嘛的呢？就是删除你所创建的MessageSession对象，在gloox内部会delete掉你所new的这个MessageSession对象，不用你去手动地delete，这个是需要注意的地方，之前我也在这里犯了一个错误，因为是自己动态的new出一个MessageSession对象，当我调用其中的send方法向远端发送消息后，就手动地在下面调用delete mess，后来发现有问题，因为如果你发送的数据可能过长，而还没有发送完成时，你执行了下面的delete mess，则会出问题。后来我想创建一个局部变量，而不用new出一个来，这样应该没问题了吧？但是仍然是有问题的，因为可能你的局部变量生命周期过期了，而你的消息仍没有被发送完，这样自然也是有问题的。所以只能是new一个MessageSession对象出来，如果你需要删除这个对象的话（当然你总应该在某个地方将你new的对象删除），则应该调用你的连接对象中的disposeMessageSession方法将其删除掉。因为gloox内部会处理在删除之前，如果还没发送完消息，会等其发送完之后，再将其删除的。当然从某种程度来说，你自己new的对象，需要别人来删除，是一种不好的编程习惯的，但是却可以使结构清楚，并且不用使用者去关心底层的东西，即不用担心文本是否发送完了而删除的问题，也是一个不错的选择。