最近项目中用到了即时通讯,之前用到是腾讯的即时通讯SDK,但是这次技术老大想让我们自己用
socket
实现,于是就研究了下CocoaAsyncSocket
,目前已经在项目中实现了即时通讯功能,特此在这里记录一下。
开始正文之前先说下CocoaAsyncSocket
的文件组成。
GCDAsyncSocket
是用GCD搭建的基于TCP/IP协议的socket网络库。
GCDAsyncUdpSocket
是用GCD搭建的基于UDP/IP协议的socket网络库。
1.导入pod库
pod 'CocoaAsyncSocket','7.6.0'
2.引入头文件,并设置代理
#import <GCDAsyncSocket.h>
<GCDAsyncSocketDelegate>
3.初始化socket对象,代理队列必须为主队列,同时创建定时器,保持心跳
@property(nonatomic,strong)GCDAsyncSocket *clientSocket;
@property (nonatomic, strong) NSTimer *connectTimer;
self.clientSocket = [[GCDAsyncSocket alloc]initWithDelegate:self delegateQueue:dispatch_get_main_queue()];
//设置主机ip和端口号
[self.clientSocket connectToHost:@"主机ip" onPort:8080 error:nil];
//加心跳
[netWork addTimer];
// 添加定时器
- (void)addTimer{
// 长连接定时器
self.connectTimer = [NSTimer scheduledTimerWithTimeInterval:15.0 target:self selector:@selector(longConnectToSocket) userInfo:nil repeats:YES];
// 把定时器添加到当前运行循环,并且调为通用模式
[[NSRunLoop currentRunLoop] addTimer:self.connectTimer forMode:NSRunLoopCommonModes];
}
4.实现代理方法
#pragma mark - 成功连接服务器
-(void)socket:(GCDAsyncSocket *)sock didConnectToHost:(NSString *)host port:(uint16_t)port{
NSLog(@"成功连接服务器");
//第一次连接服务器,发送个人信息,代表登录
[self loginService];
}
#pragma mark - 读取数据回调
- (void)socket:(GCDAsyncSocket*)sock didReadData:(NSData*)data withTag:(long)tag{
}
#pragma mark - 断开连接服务器
- (void)socketDidDisconnect:(GCDAsyncSocket*)sock withError:(NSError*)err{
//断开重连
[self.clientSocket connectToHost:@"主机ip" onPort:8080 error:nil];
NSLog(@"断开连接服务器,重新连接");
}
这里需要注意。如果断开服务器不需要重新连接,那么不需要调用connectToHost
方法,并且需要清空代理和客户端本身的socket.
self.clientSocket.delegate = nil;
self.clientSocket = nil;
5.建立心跳连接
- (void)longConnectToSocket{
[self loginService];
}
6.调用发送方法
//发送
[self.clientSocket writeData:data withTimeout:-1 tag:0];
这里需要注意
心跳连接中发送给服务端的数据是验证用户身份的代码,可以根据公司需求,或者和后台商定好心跳包的数据以及发送心跳的时间间隔.客户端发送心跳包,服务端也需要有对应的心跳检测,以此检测客户端是否在线.
这里还可以用GCDAsyncSocketDelegate
模拟服务端功能,但是因为公司已经有后台同事用socket实现功能了, 这里我就没有进行模拟。
网友评论