ace 之 ACE_Message_Block

这里已经说的比较详细了

CE_Message_Block
http://www.cnblogs.com/TianFang/archive/2006/12/30/607960.html http://blog.csdn.net/ydogg/article/details/1818949
前摄器
http://www.cnblogs.com/TianFang/archive/2006/12/31/608952.html
我想补充一下的是这个结构使用上一些巧妙的地方。

我在用ACE_Message_Block时，有把它当做一个简单的缓冲区buffer,只是在ace的框架中,需要用这个,所以才用他的。

这其实就是简单的拿来主义了,都没有好好理解,了解这个类的功能，及怎么使用他，说的牛逼点，如何巧妙，高效的用它。

首先，它有一个rd_prt , 和一个 wr_ptr , 那么，其实，它已经有了作为循环缓冲区的潜力了。

再次，在网络收法数据的过程中，通常，我们并不能一次性将数据发出去，或者不能一次性完整的接收到我们需要的整个数据包的数据

那么，在接收数据的过程中，handle_read_stream

(const ACE_Asynch_Read_Stream::Result
&result)

{

ACE_Message_Block
&mb = result.message_block ();

result.bytes_transferred();
可以知道当前读取了多少数据

if( mb.space() )

{

mb.space(); 可以知道当前block还有多少没有接收完

那么可以这样调用

mb.wr_ptr(
result.bytes_transferred() ); //移动写指针

this->reader_.read
(*nmb, nmb->space ()); //将后续读到的数据接在写指针后面

读取当前block没有读完的数据,且自动放到block的末尾

这样,如果block初始的时候，是设置成了需要接收的包的大小的,那么，最终 mg.space()为0时，这个包就读完了

}

else

{

ProcessPacket(
mb.rd_ptr() , mb.length() );

}

}

在发送数据的时候

virtual void handle_write_stream

(const ACE_Asynch_Write_Stream::Result
&result)

{

ACE_Message_Block &mb
= result.message_block ();

result.bytes_transferred();
可以知道当前已经发送了多少数据

mb.rd_ptr( result.bytes_transfered();
//移动读指针

if( mb.wr_ptr() - mb.rd_ptr() > 0 )

{

当前block还有数据没有写完

this->write_.write
(*nmb,
mb.wr_ptr() - mb.rd_ptr() );//继续从未读的数据开始发送

这样,如果block初始的时候，是设置成了需要发送的包的大小的,那么，最终mb.wr_ptr() - mb.rd_ptr()为0时，这个包就写完了

}

}

可以很方便的实现拼包以及续发，不需要使用者去维护