#import "ServiceListen.h"
//引入头文件
#import "GCDAsyncSocket.h"
@interface ServiceListen()<GCDAsyncSocketDelegate>
//服务端对象
@property(nonatomic,strong)GCDAsyncSocket *serverSocket;
//保存客户端对象
@property(nonatomic,strong)NSMutableArray *NewSockets;//客户端socket对象

@end
@implementation ServiceListen
/**
 *  懒加载
 */
-(NSMutableArray *)NewSockets
{
    if (_NewSockets==nil) {
        _NewSockets=[NSMutableArray new];
    }
    return _NewSockets;
}
/**
 *  开启服务方法的实现
 */
-(void)start{
    //开启10086服务
    //服务端的socket只监听 有没客户端请求链接
    GCDAsyncSocket *serverSocket = [[GCDAsyncSocket alloc] initWithDelegate:self delegateQueue:dispatch_get_global_queue(0, 0)];
       //绑定端口,并开启监听,代表10086服务已经开启
    NSError *error=nil;
    [serverSocket acceptOnPort:5288 error:&error];
    if (!error) {
        NSLog(@"10086服务开启成功");
    }
    else
    {
        NSLog(@"开启失败%@",error);
    }
    self.serverSocket=serverSocket;

}

#pragma mark  有客户端socket链接到服务器
/**
 *  有客户端socket链接到服务器调用
 *
 *  @param sock      服务端
 *  @param newSocket 客户端
 */
-(void)socket:(GCDAsyncSocket *)sock didAcceptNewSocket:(GCDAsyncSocket *)newSocket
{
    NSLog(@"服务端serverSocket  %@",sock);
    NSLog(@"客户端newSocket   %@",newSocket);
    //保存客户端的socket
    [self.NewSockets addObject:newSocket];
    //提供服务
    NSMutableString *serverStr = [NSMutableString string];
    [serverStr appendString:@"欢迎光临!!!请输入下面的数字选择服务!\n"];
    [serverStr appendString:@"[0]在线充值\n"];
    [serverStr appendString:@"[1]在线投诉\n"];
    [serverStr appendString:@"[2]优惠信息\n"];
    [serverStr appendString:@"[3]特殊服务\n"];
    [serverStr appendString:@"[4]退出\n"];
    [newSocket writeData:[serverStr dataUsingEncoding:NSUTF8StringEncoding] withTimeout:-1 tag:0];
    
    //监听客户端有没有数据上传
    //Timeout:-1 代表不超时
    //tag:标识作用,现在不用
    [newSocket readDataWithTimeout:-1 tag:0];
}
#pragma mark 读取客户端的请求的数据
/**
 *  读取客户端的请求的数据
 *
 *  @param sock 客户端
 *  @param data 数据
 *  @param tag  标记
 */
-(void)socket:(GCDAsyncSocket *)sock didReadData:(NSData *)data withTag:(long)tag
{
    //1:NSData转成NSString
    NSString *str=[[NSString alloc]initWithData:data encoding:NSUTF8StringEncoding];
    NSLog(@"读取数据 sock:  %@  %@",sock,str);
    //获取客户端返回的数据
    NSInteger code = [str integerValue];
    //默认给客户端的数据
    NSString *reponseStr=nil;
    switch (code) {
        case 0:
            reponseStr = @"没有充值服务....\n";
            break;
        case 1:
             reponseStr = @"当前没有员工....\n";
            break;
        case 2:
             reponseStr = @"打折优惠5折....\n";
            break;
        case 3:
             reponseStr = @"特殊服务一个....\n";
            break;
        case 4:
             reponseStr = @"退出成功....\n";
            break;
            
        default:
            break;
    }
   
    //2.处理请求,返回数据给客户端
    [sock writeData:[reponseStr dataUsingEncoding:NSUTF8StringEncoding] withTimeout:-1 tag:0];
    if (code==4) {
        //移除客户端
        [self.NewSockets removeObject:sock];
    }
#warning 每次读完数据后,都要调用一次监听数据的方法
    [sock readDataWithTimeout:-1 tag:0];
}

#import <Foundation/Foundation.h>
#import "ServiceListen.h"
int main(int argc, const char * argv[]) {
    @autoreleasepool {
        // insert code here...
        NSLog(@"Hello, World!");
        //创建一个服务监听对象
        ServiceListen *listen=[[ServiceListen alloc] init];
        //开始监听
        [listen start];
        //开启主运行循环,让服务不能停
        [[NSRunLoop mainRunLoop]run];
        
    }
    return 0;
}