#import "Serverlistener.h"
#import "GCDAsyncSocket.h"
@interface Serverlistener ()<GCDAsyncSocketDelegate>
@property (nonatomic, strong) GCDAsyncSocket *server;
// 用于存储所有客户端的Socket对象 --
@property (nonatomic, strong) NSMutableArray *clientSockets;
@end
@implementation Serverlistener
- (NSMutableArray *)clientSockets{
if (!_clientSockets) {
_clientSockets = [NSMutableArray array];
}
return _clientSockets;
}
- (void)viewDidLoad {
[super viewDidLoad];
}
/**
1.服务器绑定端口
2.监听客户端的连接
3.允许客户端建立连接
4.读取客户端的请求数据
5.处理客户端的请求数据
6.响应客户端的请求数据
*/
// 1. 创建服务端的socket 并绑定服务器端口号
- (void)start{
// 1.创建服务器绑定端口
//1.1 创建一个Socket对像__代理__代理队列 (说明该代理在那个线程中调用)
self.server = [[GCDAsyncSocket alloc] initWithDelegate:self delegateQueue:dispatch_get_global_queue(0, 0)];
// 1.2绑定端口_监听客户端面的连接__5288端口号 端口号需大于1024 (因为1024的为系统所用)
NSError *error = nil;
[self.server acceptOnPort:5288 error:&error];
if (error) {
NSLog(@"服务器开启失败");
}else{
NSLog(@"服务器开启成功");
}
// 调用开启 __ 在main中调用就可以了 并开启
[[NSRunLoop mainRunLoop] run]; -- 在main中开启
}
// 2. 监听客户端的连接_有新的客户端连接就会调用该方法 newSocket 表示一个新的客户端
- (void)socket:(GCDAsyncSocket *)sock didAcceptNewSocket:(GCDAsyncSocket *)newSocket{
NSLog(@"有客户端请求连接");
// 3.允许客户端连接
// 3.1_我们要将新的客户端进行存储起来 否则连接到之后 出了该模块 就会断开
[self.clientSockets addObject:newSocket];
// 3.2 一旦连接成功 给予客户端数据相应__ 客户端连接成功之后就会看到这些
NSMutableString *dataStr = [NSMutableString string];
[dataStr appendString:@"欢迎来到10086在线服务,请输入下面的文字选择服务\n"];
[dataStr appendString:@"[0]在线充值\n"];
[dataStr appendString:@"[1]在线投诉\n"];
[dataStr appendString:@"[2]优惠信息\n"];
[dataStr appendString:@"[3]特殊服务\n"];
[dataStr appendString:@"[4]退出\n"];
[newSocket writeData:[dataStr dataUsingEncoding:NSUTF8StringEncoding] withTimeout:-1 tag:0];
// 3.3调用客户端读取数据的方法 选择读取数据的代理方法才会调用 __ 客户端选择相应的东东之后 为了服务端能够监测到 所以
// -1 :不超时 0 : 随便写 目前用不到
[newSocket readDataWithTimeout:-1 tag:0];
}
// 4.读取客户端请求数据 __ 监测客户端的 选择
#warning 使用这个代理方法之前 需要调用 [newSocket readDataWithTimeout:-1 tag:0]; 否则该方法不会调用
- (void)socket:(GCDAsyncSocket *)sock didReadData:(NSData *)data withTag:(long)tag{
NSString *readStr = [[NSString alloc] initWithData:data encoding:NSUTF8StringEncoding];
NSLog(@"%@",readStr);
#warning 下次还想继续监听 仍需再调用 [newSocket readDataWithTimeout:-1 tag:0];该方法
[sock readDataWithTimeout:-1 tag:0];
NSString *reulitStr = nil;
switch ([readStr integerValue]) {
case 0:
reulitStr = @"在线充值暂时不支持\n";
break;
case 1:
reulitStr = @"不要乱投诉\n";
break;
case 2:
reulitStr = @"冲一万送5千\n";
break;
case 3:
reulitStr = @"没有特殊服务\n";
break;
case 4:
reulitStr = @"退出\n";
break;
default:
break;
}
// 响应客户端的请求数据 __ 将客户端 选择的东西展示给客户端看
[sock writeData:[reulitStr dataUsingEncoding:NSUTF8StringEncoding] withTimeout:-1 tag:0];
// 断开连接
if ([readStr integerValue] == 4) {
[self.clientSockets removeObject:sock];
}
}
终端使用 :
$ telnet +IP地址
即可调用(测试)
