处理TCP连包的一小段代码

　　学习网络编程也有一段时间了，一直听说TCP数据会连包，但一直不知道怎么测试好。最近测试了下：发送方使用对列，将发送的数据存入队列，然后开线程，专门发送。发送多包数据之间不延时。在接收方，他们确实连在一起了。花了点时间，写了一小段代码解决这个问题，其实一共也就4个函数：

#define FIND_NO_HEAD 1024

int MyTcpSock::GetPackageSetedLength(char *pHeader)
{
    XX_NETPACKET_HEADER *pNetHeader = (XX_NETPACKET_HEADER *)pHeader;

    return (sizeof(XX_NETPACKET_HEADER) + pNetHeader->packetsize);
}

int MyTcpSock::FindHeaderFlag(char *buf,int len)
{
    #define FLAGS_NUM 4

    int count = 0;
    char i=0;
    unsigned char Flags[FLAGS_NUM] = {XX_FLAG1,XX_FLAG2,XX_FLAG3,XX_FLAG4};
    XX_NETPACKET_HEADER *pHeader = (XX_NETPACKET_HEADER *)(buf+count);

    while(count < len)
    {
        for(i=0;i<FLAGS_NUM;i++)
        {
            if(pHeader->flag == Flags[i])
            {
                return ((char *)pHeader - buf);
            }
        }

        count ++;
        pHeader = (XX_NETPACKET_HEADER *)(buf+count);
    }

    return FIND_NO_HEAD;
}

void MyTcpSock::ResolveRecievedData(char *buf,int len)
{
    char *pUnreslovedData = (char *)buf;   //指向待解析的数据的开始
    int iUnreslovedDataLen = len;          //待解析的数据的长度
    int iHeaderPosition = 0;               //数据头的位置--相对于待解析的数据的起始位置
    int iPackageLen = 0;                   //解析出的命令的数据包长度

    while(iUnreslovedDataLen > 0)
    {
        iHeaderPosition = FindHeaderFlag(pUnreslovedData,iUnreslovedDataLen);
        if(iHeaderPosition == FIND_NO_HEAD)
        {
            TRACE("Find no Header!
");
            Printf(pUnreslovedData,iUnreslovedDataLen);
            return ;
        }
        iPackageLen = this->GetPackageSetedLength((char *)(pUnreslovedData+iHeaderPosition));
        if(iPackageLen > iUnreslovedDataLen)
        {
            TRACE("Package is not full!
");
            Printf(pUnreslovedData,iUnreslovedDataLen);
            return ;
        }

        ResolvePackageCmd((char *)(pUnreslovedData+iHeaderPosition),iPackageLen);

        pUnreslovedData = pUnreslovedData + iHeaderPosition + iPackageLen;  //调整指针
        iUnreslovedDataLen = iUnreslovedDataLen - iHeaderPosition - iPackageLen;
    }
}

void MyTcpSock::ResolvePackageCmd(char *buf,int len)
{
    XX_NETPACKET_HEADER *pNetHeader = (XX_NETPACKET_HEADER *)buf;

        //XXX后面就是命令的解析了
}

　　以上代码是C++，去掉类就是C。以上代码经过测试，可以解决如下问题：

　　数据连包的问题。

　　数据发送丢失，比如有包头却丢失了一些数据。后面解析这些命令时，如果以为数据存在，直接用将会出现不可预知的错误。

      命令包格式的设计，基本要遵守CLV的格式，C-code命令，L-Length命令长度，V-Value值。

　　这里的命令也基本上就是上面的Flag，因为不通命令可能带的值不一样，所以也就必须定义此命令的长度。这在连包处理上非常重要。