IOS关于AsyncSocket☞TCP粘包与断包的问题解决方案

一 .什么时候需要考虑粘包问题?

• 如果利用tcp每次发送数据，就与对方建立连接，然后双方发送完一段数据后，就关闭连接，这样就不会出现粘包问题（因为只有一种包结构,类似于http协议）。关闭连接主要要双方都发送close连接（参考tcp关闭协议）。如：A需要发送一段字符串给B，那么A与B建立连接，然后发送双方都默认好的协议字符如"hello give me sth abour yourself"，然后B收到报文后，就将缓冲区数据接收,然后关闭连接，这样粘包问题不用考虑到，因为大家都知道是发送一段字符。
• 如果发送数据无结构，如文件传输，这样发送方只管发送，接收方只管接收存储就ok，也不用考虑粘包
• 如果双方建立连接，需要在连接后一段时间内发送不同结构数据，如连接后，有好几种结构：
  1)"hello give me sth abour yourself"
  2)"Don't give me sth abour yourself"
  那这样的话，如果发送方连续发送这个两个包出去，接收方一次接收可能会是"hello give me sth abour yourselfDon't give me sth abour yourself" 这样接收方就傻了，到底是要干嘛？不知道，因为协议没有规定这么诡异的字符串，所以要处理把它分包，怎么分也需要双方组织一个比较好的包结构，所以一般可能会在头加一个数据长度之类的包，以确保接收。

二 .粘包出现原因

在流传输中出现，UDP不会出现粘包，因为它有消息边界(参考Windows 网络编程)
1 发送端需要等缓冲区满才发送出去，造成粘包
2 接收方不及时接收缓冲区的包，造成多个包接收

三 .解决办法

为了避免粘包现象，可采取以下几种措施。一是对于发送方引起的粘包现象，用户可通过编程设置来避免，TCP提供了强制数据立即传送的操作指令push，TCP软件收到该操作指令后，就立即将本段数据发送出去，而不必等待发送缓冲区满；二是对于接收方引起的粘包，则可通过优化程序设计、精简接收进程工作量、提高接收进程优先级等措施，使其及时接收数据，从而尽量避免出现粘包现象；三是由接收方控制，将一包数据按结构字段，人为控制分多次接收，然后合并，通过这种手段来避免粘包。

---

下面我们用一种简单而使用的方法来解决这个问题,而这种方法尤其适用于初学者,思路如下:

我们为了防止粘包与断包,将每一条TCP数据都已\n结尾,这样当我们拿到\n的时候,就说明这是一条完整的数据.
如果一次接受的数据中包含两个或两个以上的\n的时候,则以\n拆分成两条或两条以上的完整数据进行解析,即粘包处理.
如果一次接受的数据中没有\n,则将这条数据与下次接受的数据合并起来,知道接受到\n为止,即断包处理.

---

实现过程如下:
ReceiveDataControl.h:

#import <Foundation/Foundation.h>

typedef void(^SocketDataBlock)(NSMutableArray * receiveData);

@interface ReceiveDataControl : NSObject

+(ReceiveDataControl *) sharedInstance;

-(void)appendingData:(id)data newData:(SocketDataBlock)block;

@end

ReceiveDataControl.m:

#import "ReceiveDataControl.h"

@interface ReceiveDataControl ()
{
    //保存二级制文件数据
    NSMutableData *_currentData;
    //保存有用的字符串数据
    NSMutableArray *_lastMessages;
}

@end

@implementation ReceiveDataControl

+(ReceiveDataControl *) sharedInstance
{
    static ReceiveDataControl *sharedInstace = nil;
    static dispatch_once_t onceToken;
    dispatch_once(&onceToken, ^{
        sharedInstace = [[self alloc] init];
    });
    return sharedInstace;
}

-(instancetype)init{
    if (self = [super init]) {
        _currentData = [[NSMutableData alloc] init];
    }
    return self;
}

-(void)appendingData:(id)data newData:(SocketDataBlock)block
{
    //1、拼接二进制数据
    [_currentData appendData:data];
    //2、转化成字符串
    NSString *string = [[NSString alloc] initWithData:_currentData encoding:NSUTF8StringEncoding];
    NSLog(@"socket 收到的数据data = %@",string);
    
    //3、分割字符串
    NSArray *stringArr = [string componentsSeparatedByString:@"\n"];
    NSMutableArray *usefulStringArr = [NSMutableArray new];
    
    int count = 0;
    //4、获取有用的字符串
    for (NSString *str in stringArr) {
        if ([str hasPrefix:@"{"] && [str hasSuffix:@"}"]) {
            [usefulStringArr addObject:str];
        }else if (!IsStringEmpty(str)){
            NSData *strData = [str dataUsingEncoding:NSUTF8StringEncoding];
            _currentData = [strData mutableCopy];
            count ++;
        }
    }
    
    if (count == 0) {
        _currentData = [[NSMutableData alloc] init];
    }
    
    block(usefulStringArr);
    //5、判断有没有新的字符串
//    NSMutableArray *newStringArr = [NSMutableArray new];
//    for (NSString *str in usefulStringArr) {
//        if (![_lastMessages containsObject:str]) {
//            [newStringArr addObject:str];
//        }
//    }
    //6、返回新的字符串 保存老的数组
//    _lastMessages = usefulStringArr;
    
//    _currentData = data;
}

@end

注:喜欢的请关注一下我的简书:白纸上涂鸦