//创建一个Command Line Tool 项目
//1、创建一个 GCDAsyncSocket 对象
GCDAsyncSocket *_serverSocketp = [[GCDAsyncSocket alloc] initWithDelegate:self delegateQueue:dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT,0)];
//2、打开监听端口
NSError *error = nil;
[_serverSocket acceptOnPort:54321 error:&error];
//3、开启主线程循环 让main不退出
[[NSRunLoop mainRunLoop] run];
//4、代理方法
didAcceptNewSocket 有新的客户端连接时会调用
这里我们用终端测试一下服务器
telnet 127.0.0.1 54321
这里我们会发现连接刚连上就断了
macdeMacBook-Air-3:~ mac$ telnet 127.0.0.1 54321
Trying 127.0.0.1...
Connected to localhost.
Escape character is '^]'.
Connection closed by foreign host.
macdeMacBook-Air-3:~ mac$
所以我们要在连接的地方将 客户端的连接 保存起来
@property(strong,nonatomic)NSMutableArray *clientSocket;
-(NSMutableArray *)clientSocket{
if (_clientSocket == nil) {
_clientSocket = [NSMutableArray array];
}
return _clientSocket;
}
#pragma mark 有客户端建立连接 sock 服务端 newSocket 客户端的
-(void)socket:(GCDAsyncSocket *)sock didAcceptNewSocket:(GCDAsyncSocket *)newSocket{
[_clientSocket addObject:newSocket];
}
这时候我们在测试下,发现连接不会断开了, 而且这个连接是一个长连接了,接下来我们就可以往服务端发送消息了, 只需要在 终端 直接输入内容 按下回车就可以
注: sock 服务端的socket 只负责客户端的连接,不负责数据的读取
//在代理方法中 didAcceptNewSocket 用客户端的 newSocket 来读取
[newSocket readDataWithTimeout:-1 tag:100];
//调用了这个方法后 会 执行 另一个代理方法 didReadData 在这个代理方法中我们可以自定义指令 好像 用别人写好的socket服务器时 消息开头 是 iam 就是登录指令 msg 就是消息指令
在didReadData中 获取数据
NSString *receiverStr = [[NSString alloc] initWithData:data encoding:NSUTF8StringEncoding];
// 把回车和换行字符去掉 \r 回车 \n 换行
[receiverStr stringByReplacingOccurrencesOfString:@"\r" withString:@""];
[receiverStr stringByReplacingOccurrencesOfString:@"\n" withString:@""];
//判断指令
if ([receiverStr hasPrefix:@"iam:"]) {
//获取指令后面的信息
NSString *user = [receiverStr componentsSeparatedByString:@":"][1];
//响应给客户数据
NSString *respStr = [user stringByAppendingString:@"has joined"];
[sock writeData:[respStr dataUsingEncoding:NSUTF8StringEncoding] withTimeout:-1 tag:101];
}else if([receiverStr hasPrefix:@"msg:"]){
//获取指令后面的信息
NSString *msg = [receiverStr componentsSeparatedByString:@":"][1];
[sock writeData:[msg dataUsingEncoding:NSUTF8StringEncoding] withTimeout:-1 tag:101];
}else if([receiverStr isEqualToString:@"quit"]){
[self.clientSocket removeObject:sock];
[sock disconnect];
}
// 在真正的服务器中还有很多其他的业务 消息保存到数据库中 等
在didWriteDataWithTag代理方法中, 没发送完一次消息都要读取(readDataWithTimeout)一次, 才能在继续进行读取
服务器实例代码:http://pan.baidu.com/s/1jIjgXvw 提取密码:uksj
网友评论