iOS socket 浅析与简单实现
(原创, 请勿转载)
有好多童鞋面对socket大有无从下手之感, 我就随便说说
socket 翻译过来叫套接字, 你可以理解他为长连接, 所谓长连接, 就让你的服务器与手机端保持着连续性的联系(心跳), 从而实现手机端实时接收数据
我在群里看到有的童鞋讨论socket时, 在网上找到的文章都是学术性太强(其实就是懒得看的借口), 就想找一个告诉我该怎么做就完了, 现在我写这个就告诉你该怎么做, 至于原理, 自己查去吧~~~网上有的是
socket 有自己的一套函数库, 他有他自己的一堆函数, 只不过用着很难受, 现在有个大神跳出来, 把socket封装的又好又棒, 方便简洁, 简单易用, 为什么不用呢?
GCDAsyncSocket
GCDAsyncUdpSocket
这两个类封装的非常好, 我今天就简单的讲一下怎么新建个socket, 怎么发数据接数据就完了,
第一步, 新建个工程
第二步, 导入一个包, CFNetwork.framework, 导入GCDAsyncSocket.h GCDAsyncSocket.m GCDAsyncUdpSocket.h GCDAsyncUdpSocket.m 这4个文件, Demo链接在下边, 里面有这些文件
第三步, 新建个单例 开始上代码了
+ (Singleton *)sharedInstance{
static Singleton *singleton = nil;
static dispatch_once_t oneToken;
dispatch_once(&oneToken, ^{
singleton = [[Singleton alloc]init];
});
return singleton;
}
import类 并声明属性与方法 还有协议GCDAsyncSocketDelegate
#import "GCDAsyncSocket.h"
#import "GCDAsyncUdpSocket.h"
///socket对象
@property (nonatomic, strong)GCDAsyncSocket *socket;
//主机
@property (nonatomic, copy)NSString *socketHost;
//端口
@property (nonatomic, assign)UInt16 socketPort;
///向服务器发送的数据
@property (nonatomic, copy)NSString *sendData;
///心跳 计时器
@property (nonatomic, retain) NSTimer *connectTimer;
- (void)socketConnectHost;// socket启动连接
- (void)cutOffSocket; // 断开socket连接
///服务器反馈回调
- (void)readData:(void(^)(NSData *data))block;
方法一 : socket启动连接
-(void)socketConnectHost{
dispatch_queue_t queue;
self.socket = [[GCDAsyncSocket alloc]initWithSocketQueue:queue];
NSError *error = nil;
[self.socket connectToHost:self.socketHost onPort:self.socketPort withTimeout:3 error:&error];
}
方法二 : 断开socket连接
// 切断socket
-(void)cutOffSocket{
[self.connectTimer invalidate];
[self.socket disconnect];
}
接下来是几个有用的代理的介绍
#pragma mark -GCDAsyncSocketDelegate 代理 连接成功回调
- (void)socket:(GCDAsyncSocket *)sock didConnectToHost:(NSString *)host port:(uint16_t)port;
#pragma mark -GCDAsyncSocketDelegate 代理 断线回调
- (void)socketDidDisconnect:(GCDAsyncSocket *)sock withError:(nullable NSError *)err;
#pragma mark -GCDAsyncSocketDelegate 代理 服务器反馈回调
- (void)socket:(GCDAsyncSocket *)sock didReadData:(NSData *)data withTag:(long)tag;
具体实现看下边
// 心跳方法
-(void)longConnectToSocket{
//每个心跳向服务器发送的数据
NSData *dataStream = [self.sendData.copy dataUsingEncoding:NSUTF8StringEncoding];
[self.socket writeData:dataStream withTimeout:1 tag:1];
}
#pragma mark -GCDAsyncSocketDelegate 代理 连接成功回调
- (void)socket:(GCDAsyncSocket *)sock didConnectToHost:(NSString *)host port:(uint16_t)port{
NSLog(@"socket连接成功");
// 每隔30s像服务器发送心跳包
self.connectTimer = [NSTimer scheduledTimerWithTimeInterval:30 target:self selector:@selector(longConnectToSocket) userInfo:nil repeats:YES];// 在longConnectToSocket方法中进行长连接需要向服务器发送的讯息
[self.connectTimer fire];
}
#pragma mark -GCDAsyncSocketDelegate 代理 断线回调
- (void)socketDidDisconnect:(GCDAsyncSocket *)sock withError:(nullable NSError *)err{
// 判断是不是掉线，是服务器掉线还是用户手动链接, 要是掉线就重连
// [self socketConnectHost];
}
#pragma mark -GCDAsyncSocketDelegate 代理 服务器反馈回调
- (void)socket:(GCDAsyncSocket *)sock didReadData:(NSData *)data withTag:(long)tag{
ReadBlock(data);
}
在声明个block做服务器回调
{
void (^ReadBlock)(NSData *data);
}
- (void)readData:(void(^)(NSData *data))block{
ReadBlock = block;
}
单例的具体使用
[Singleton sharedInstance].socketHost = @"192.186.111.11";// host设定
[Singleton sharedInstance].socketPort = 10086;// port设定
///你心跳发送给服务器的数据, 可以即时修改
[Singleton sharedInstance].sendData = @"我要铁马长戈腰带";
// 在连接前一定先进行断开, 如果对一个正处于连接状态的socket进行连接，会崩溃
[[Singleton sharedInstance] cutOffSocket];
[[Singleton sharedInstance] socketConnectHost];
//服务器回调反馈
[[Singleton sharedInstance] readData:^(NSData *data) {
}];
Demo链接
https://pan.baidu.com/s/1bppaZ19
mkrw
参考文章: https://my.oschina.net/joanfen/blog/287238
