iOS开发中可以使用开源库CocoaAsyncSocket
简化socket
开发
**1.连接socket **
//创建一个TCP服务 连接到服务器
- (void)createTcpSocket {
if (self.asyncSocket==nil) {
self.asyncSocket = [[GCDAsyncSocket alloc] initWithDelegate:self delegateQueue:dispatch_get_main_queue()];
}
if (self.asyncSocket.isConnected) {
} else {
NSError *error;
[self.asyncSocket connectToHost:_socketHost onPort:_socketPort withTimeout:-1 error:&error];
if (error) {
NSLog(@"%@",error);
}
}
}
2.实现socket代理方法
//已经连接到服务器
- (void)socket:(GCDAsyncSocket *)sock didConnectToHost:(NSString *)host port:(uint16_t)port {
NSLog(@"连接成功");
}
// 连接断开
- (void)socketDidDisconnect:(GCDAsyncSocket *)sock withError:(NSError *)err {
NSLog(@"连接断开");
}
//消息发送成功 代理函数 向服务器 发送消息
- (void)socket:(GCDAsyncSocket *)sock didWriteDataWithTag:(long)tag {
NSLog(@"消息发送成功");
}
//已经接收服务器返回来的数据
- (void)socket:(GCDAsyncSocket *)sock didReadData:(NSData *)data withTag:(long)tag {
NSLog(@"接收到服务器返回的数据");
}
3.向服务器发送消息
[self.asyncSocket writeData:self.message withTimeout:-1 tag:0];
以上只是简单的介绍CocoaAsyncSocket
的使用,下面结合实际开发中的需求来讲解开发中的关键点,比如 tag
用来干嘛???
在开发中前端和后端会约定一个固定的数据(消息)格式,按照这个格式来读取数据,就能把每组数据划分出来,也就较好的解决了
粘包
掉包
的问题,数据不完整时也能获知数据的缺失。
举个栗子,如下表格是规定好的消息格式
起始符 | 目标地址 | 原地址 | 数据长度 | 发送/接收 的数据 | 检验符 |
---|---|---|---|---|---|
0x02(1Byte) | dest(2Byte) | src(2Byte) | dataLength(2Byte) | data (数据) | CRC校验 (1Byte) |
注:以上的消息格式分成3块,数据和校验符在这里称为身体部分
1.消息头部:起始符 + 目标地址 + 原地址 + 数据长度 = 7Byte,(头部包含了那么多信息,并且长度是固定的,所以我们接收消息的时候,要先从头部开始入手)
2.消息体:要发送或者接收到的数据,长度为dataLength
3.校验符:用来检验接收的数据是否完整一致(开发中可能没有)
** 为了能够在收到消息时,先获取到头部信息 ,我们需要用到 tag
**
//固定的头部长度
//起始符(1Byte) + 目标地址(2byte) + 源地址(2byte) + 应用层数据长度(2byte) = 7Byte
#define KPacketHeaderLength 7
typedef NS_ENUM(NSInteger ,KReadDataType){
TAG_FIXED_LENGTH_HEADER = 10,//消息头部tag
TAG_RESPONSE_BODY = 11//消息体tag
};
** 所以在socket连接成功之后应该这样写 **
//已经连接到服务器
- (void)socket:(GCDAsyncSocket *)sock didConnectToHost:(NSString *)host port:(uint16_t)port {
NSLog(@"连接成功");
// -1不超时一直读取 等待数据,先读取头部信息长度为 KPacketHeaderLength
// tag为头部消息tag,这个在接收到数据时,用来区分此次读取的是头部数据还是消息体数据
[self.asyncSocket readDataToLength:KPacketHeaderLength withTimeout:-1 tag:TAG_FIXED_LENGTH_HEADER];
}
** 在接受到服务器的数据时 **
//已经接收服务器返回来的数据
- (void)socket:(GCDAsyncSocket *)sock didReadData:(NSData *)data withTag:(long)tag {
NSLog(@"接收到服务器返回的数据");
// 根据tag来做不同的操作
switch (tag) {
case TAG_FIXED_LENGTH_HEADER:
{
self.headData = data;
Byte *bytes = (Byte *)[data bytes];
//身体长度 = 消息体 + 1Byte的校验码
self.bodyLength = [self readShort:bytes location:5] + 1;
// 从数据缓冲区读取完整的身体部分数据,此时tag变成了TAG_RESPONSE_BODY
[self.asyncSocket readDataToLength:self.bodyLength withTimeout:-1 tag:TAG_RESPONSE_BODY];
}
break;
case TAG_RESPONSE_BODY:{
//如果当前读取出来的数据长度没有达到完整包身体的长度,则包不完整(则根据当前接收的数据长度,和身体长度比较,继续读取两者相差的数据长度)
//读取完身体数据,开始校验,校验成功,则展示数据并且,开始等待下一次读取数据,tag变成TAG_FIXED_LENGTH_HEADER
[self.asyncSocket readDataToLength:KPacketHeaderLength withTimeout:-1 tag:TAG_FIXED_LENGTH_HEADER];
}
break;
default:
break;
}
}
- (short)readShort:(Byte *)bytes location:(int)location {
return OSReadLittleInt16(bytes, location);
}
这些只是开发中可能会遇到的点,实际中还有很多细节要处理