博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
AsyncSocket长连接粘包问题解决方案
阅读量:2345 次
发布时间:2019-05-10

本文共 2374 字,大约阅读时间需要 7 分钟。

工程中使用长连接来和服务器进行通讯,因此,我们的协议通过指定前两个字节为数据长度来区分数据包

app这边数据有两种传输形式:

1.app主动请求所需要的数据;

2.app异步接收来自服务端的推送消息,也就是app这边没有请求,服务端主动发送数据到app客户端;

整个app运行期间,它们都是在同一个连接上完成的数据传输,因此会出现以下的问题:

1.服务器数据传输过快,出现粘包的问题,例如

    1.1服务端一次发来多个推送消息;

    1.2网络不稳定,客户端连续发送多个请求客户端一次接收到全部答复;

2.客户端的一个请求报文,服务端的应答报文数据过大,到IP层需要进行分片,因此客户端这边就会出现几次才接收到完整的数据的情况;

首先有以下4个方法需要介绍

/**

 **实例方法

 **调用此方法以后,当套接字接收缓冲区有可用字节的时候,会触发onSocket:didReadData:withTag:委托方法,此时接收到的数据会出现上面说到的问题

 */

- (void)readDataWithTimeout:(NSTimeInterval)timeout tag:(long)tag;

/**

 **实例方法

 **调用此方法以后,当套接字接收缓冲区有length长度的可用字节的时候,会触发onSocket:didReadData:withTag:委托方法,此时接收到固定长度的数据,这个固定长度就是length给出的值,当length的长度大于接收缓冲区数据的长度的时候,就会等待,直到接收到length长度的数据的时候才会触发以上委托方法的调用

 */

- (void)readDataToLength:(NSUInteger)length withTimeout:(NSTimeInterval)timeout tag:(long)tag;

/**

 **实例方法

 **此方法功能同上,只是多了几个参数,buffer是你将接收的数据写到的地方,offset是写到buffer中的偏移位置

 */

- (void)readDataToLength:(NSUInteger)length

             withTimeout:(NSTimeInterval)timeout

                  buffer:(NSMutableData *)buffer

            bufferOffset:(NSUInteger)offset

                     tag:(long)tag;

/**

 **委托方法

 **此方法上面已经说到

 */

- (void)onSocket:(AsyncSocket *)sock didReadData:(NSData *)_data withTag:(long)tag;

解决方法:

客户端每次发送请求以后,首先只接收两个字节的长度字节,如下:

[objc] 
  1. [sendSocket readDataToLength:2 withTimeout:set.timeout tag:tag];  
  2. [sendSocket writeData:data withTimeout:set.timeout tag:tag];  

然后当有可用字节到达套接字接收缓冲区的时候触发以下委托方法,我们在里面做如下处理,这样既解决了粘包的问题,也解决了数据过大,多次接收完整的问题;

[objc] 
  1. - (void)onSocket:(AsyncSocket *)sock didReadData:(NSData *)_data withTag:(long)tag  
  2. {  
  3.     SettingData* set = [SettingData shareSettingData];  
  4.       
  5.     if (respondData == nil) {  
  6.         respondData = [[NSMutableData alloc]init];  
  7.         respondDataLen = [RequestUnit respondMessageLengthWithData:_data];  
  8.         [sock readDataToLength:respondDataLen withTimeout:set.timeout tag:tag];  
  9.         return;  
  10.     }  
  11.     [respondData appendData:[RequestUnit respondBytesToUTF8Data:_data]];  
  12.     [self parserData:respondData withTag:tag];  
  13. }  

- (void)socket:(GCDAsyncSocket *)sock didReadData:(NSData *)data withTag:(long)tag

{

    NSLog(@"tag:%ld didReadData length is %d..............",tag,data.length);

    if (DataBuf == nil) {

        

        DataBuf = [[NSMutableData alloc] init];

        [data getBytes:&lengthD length:4];

        [asyncSocket readDataToLength:lengthD withTimeout:-1 tag:tag];

        return;

    }

    

    [DataBuf appendData:data];

    [self parserData:DataBuf withTag:tag];

    DataBuf = nil;

    lengthD = 0;

//    [asyncSocket readDataToLength:4 withTimeout:-1 tag:tag];

}

- (void) parserData:(NSMutableData *)data withTag:(long)tag

转载地址:http://iznvb.baihongyu.com/

你可能感兴趣的文章
C/C++题目--拷贝构造函数概念
查看>>
C/C++题目--深复制与浅复制
查看>>
数据结构教程--李春葆版(总结)之线性表-顺序存储结构练习题
查看>>
C++虚函数底层机制
查看>>
linux gdb的详细用法 运行与断点
查看>>
删除vector中重复元素
查看>>
和为s的连续正数序列
查看>>
什么是Redis?什么是nosql?NoSQL数据库的四大分类
查看>>
为什么说Redis是单线程的以及Redis为什么这么快!
查看>>
redis的过期健删除策略以及内存淘汰机制
查看>>
map 如何使用结构体作为自定义键值
查看>>
Mysql几种索引类型的区别及适用情况
查看>>
Redis持久化的两种方式
查看>>
判断一个数组,是否可以分成两个数组之和相等的数组
查看>>
背包问题
查看>>
结构体变量之间的比较和赋值原理
查看>>
C++ const修饰函数、函数参数、函数返回值
查看>>
将单链表的每k个节点之间逆序
查看>>
删除链表中重复的节点——重复节点不保留
查看>>
2018腾讯校招编程题——最重要的城市
查看>>