关于Socket 中粘包的处理

粘包:指发送方发送的若干包数据到接收方接收时粘成一包，从接收缓冲区看，后一包数据的头紧接着前一包数据的尾。
出现粘包现象的原因是多方面的，它既可能由发送方造成，也可能由接收方造成。

发送方引起的粘包是由TCP协议本身造成的，TCP为提高传输效率，发送方往往要收集到足够多的数据后才发送一包数据。若连续几次发送的数据都很少，通常TCP会根据优化算法把这些数据合成一包后一次发送出去，这样接收方就收到了粘包数据。

接收方引起的粘包是由于接收方用户进程不及时接收数据，从而导致粘包现象。这是因为接收方先把收到的数据放在系统接收缓冲区，用户进程从该缓冲区取数据，若下一包数据到达时前一包数据尚未被用户进程取走，则下一包数据放到系统接收缓冲区时就接到前一包数据之后，而用户进程根据预先设定的缓冲区大小从系统接收缓冲区取数据，这样就一次取到了多包数据。

既然有粘包,那我们要做的自然是要分包~我把分包的逻辑直接贴出来,当然需要大家对socket的数据包格式有一定的了解(整包的长度数+包体内容).

//BaseMsgPacket:解析后数据模型类
//data:socket接收到的数据
- (void)readResponseData:(NSData *)data completeBlock:(void(^)(BaseMsgPacket *packet))complete uncompleteBlock:(void(^)(void))uncompleteBlock
{
    //加锁
    @synchronized (self.lockObject)
    {
        NSMutableData *bufferData = [[NSMutableData alloc] initWithData:data];
        NSUInteger bufferLength = bufferData.length;
        //6这个数字,跟本人项目有关.2个字节长度记录数据包长度 + 4个字节长度代表消息的协议类型
        while (bufferLength >= 6)
        {  
           //创建一个记录包体长度的常量
            uint16_t currentPacketLength = 1;

           //从包体中取出前两个字节拿到包体长度
            NSUInteger length = 0;
            [bufferData getBytes:&length length:2];

           // 将多字节整数类型的数据，从主机的字节顺序转化为网络字节顺序
            currentPacketLength = ntohs(length) + 2;

            // 应该读取的数据长度,大于实际包体的长度(出现了包体丢数据的情况,不做解析)
            if (currentPacketLength > bufferLength)
            {
                break;
            }
            //截取数据,取出第一个包的长度的数据
            NSData *packetData = [bufferData subdataWithRange:NSMakeRange(0, currentPacketLength)];
            if(packetData.length)
            {
                if (complete)
                {
                    //自己处理数据的逻辑,当然处理的是packetData
                    complete(packet);
                }
                //数据处理完成后,将已数据清掉,并记录剩余数据长度
                [bufferData replaceBytesInRange:NSMakeRange(0, currentPacketLength) withBytes:nil length:0];
                bufferLength = bufferData.length;
            }
            else
            {
                NSLog(@"读取到未知类型消息");
            }
        }       
        //处理完了buffer的数据，读取下个消息包
        if (uncompleteBlock)
        {
            uncompleteBlock();
        }
    }
}

通过上面的加锁的While循环就可以处理正常包和粘包,半包的情况.有可能有思虑不周到的地方,希望各位同行多多指点.