实现10086服务功能

实现Socket监听的方法
（1）使用C语言实现
（2）使用CocaoAsyncSocket（第三方框架），内部是对C语言的封装
Telent命令：Telnet命令 telnet host port/telnet 192.168.10.10 5288(终端输入)
1.telnet命令是连接服务器上的某个端口对应的服务

第一步：实现服务器的监听
使用命令行

image.png

创建一个继承于NSObject的类。下载好CocaoAsyncSocket之后，把GCDAsyncSocket导入（TCP）。

//  FWLServiceListener.h
//开启服务
- (void)start;

//  FWLServiceListener.m
#import "GCDAsyncSocket.h"

@interface FWLServiceListener ()<GCDAsyncSocketDelegate>

@property(nonatomic,strong)GCDAsyncSocket * serverSocket;

@end

@implementation FWLServiceListener


-(void)start
{
    //开启10096服务:5288
    //1.创建一个socket对象
    //服务端的Socket只监听 有无客户端请求连接
    //serverSocket是局部变量，方法执行后就会被释放掉，做个属性
    GCDAsyncSocket * serverSocket = [[GCDAsyncSocket alloc] initWithDelegate:self delegateQueue:dispatch_get_global_queue(0, 0)];
    
    //2.绑定端口 && 开启监听,代表10086服务已经开启 5288有可能被占用
    NSError * error = nil;
    [serverSocket acceptOnPort:5288 error:&error];
    if (!error) {
        NSLog(@"10086服务开启成功");
    }else{
        NSLog(@"10086服务开启失败，%@",error);

    }
    self.serverSocket = serverSocket;
}
#pragma mark == 有客户端的Socket连接到服务器
-(void)socket:(GCDAsyncSocket *)serverSocket didAcceptNewSocket:(GCDAsyncSocket *)clientSocket
{
    NSLog(@"serverSocket == %@ -- clientSocket == %@",serverSocket,clientSocket);  
}

打开网络偏好设置，查看IP地址

image.png

终端输入

image.png

此时，提示Connection closed by foreign host.连接被远程关闭。是因为连接已经建立了，但是还未走客户端的read，write流程就被关闭了，因为客户端socket是局部变量，方法结束后就被释放了，所以连接断开。
所以写一个属性,设置一个数组来接收所有的用户socket

//客户端的所有Socket对象
@property(nonatomic,strong)NSMutableArray * clientSockets;
-(NSMutableArray *)clientSockets
{
    if (!_clientSockets) {
        _clientSockets = [NSMutableArray array];
    }
    return _clientSockets;
}
-(void)socket:(GCDAsyncSocket *)serverSocket didAcceptNewSocket:(GCDAsyncSocket *)clientSocket
{
    NSLog(@"serverSocket == %@ -- clientSocket == %@",serverSocket,clientSocket);
    //1.保存客户端Socket
    [self.clientSockets addObject:clientSocket];  
}

再次运行

image.png

连接建立之后，客户端写入数据，发送到服务器。在服务器输入数据（客户端）发送给服务端。
需要写入如下方法：

#pragma mark == 读取客户端请求数据
-(void)socket:(GCDAsyncSocket *)clientSocket didReadData:(NSData *)data withTag:(long)tag
{
    NSLog(@"读取数据 clientSocket == %@",clientSocket);
}

但是并没有输出，是因为缺少一行内部实现的代码，在socket：didAcceptNewSocket方法中添加

   //2.监听客户端有没有数据上传(timeout：-1代表不超时，tag：标识，暂时不用)
    [clientSocket readDataWithTimeout:-1 tag:0];

image.png

此时发现地址与上一个clientSocket的地址是相同的。
目前只是打印了Socket的地址，现在转码打印具体的对象

//把NSData转成NSString
    NSString * str = [[NSString alloc] initWithData:data encoding:NSUTF8StringEncoding];
    NSLog(@"读取数据 clientSocket == %@",str);

屏幕快照 2016-07-05 下午5.28.56.png

但是，再次输入时没有打印。是因为框架的原因，每次读完数据都要调用监听方法，即方法

#warning 每次读取完数据后，都要调用一次监听数据的方法
    [clientSocket readDataWithTimeout:-1 tag:0];

返回数据给客户端(输入什么返回什么)

    //2.处理请求，返回数据给客户端
    [clientSocket writeData:data withTimeout:-1 tag:0];

image·.png

现在附上全部代码

//  FWLServiceListener.h
//开启服务
- (void)start;

//  FWLServiceListener.m
#import "GCDAsyncSocket.h"

@interface FWLServiceListener ()<GCDAsyncSocketDelegate>

@property(nonatomic,strong)GCDAsyncSocket * serverSocket;
//客户端的所有Socket对象
@property(nonatomic,strong)NSMutableArray * clientSockets;

@end

@implementation FWLServiceListener

-(NSMutableArray *)clientSockets
{
    if (!_clientSockets) {
        _clientSockets = [NSMutableArray array];
    }
    return _clientSockets;
}
-(void)start
{
    //开启10096服务:5288
    //1.创建一个socket对象
    //服务端的Socket只监听 有无客户端请求连接
    //serverSocket是局部变量，方法执行后就会被释放掉，做个属性
    GCDAsyncSocket * serverSocket = [[GCDAsyncSocket alloc] initWithDelegate:self delegateQueue:dispatch_get_global_queue(0, 0)];
    
    //2.绑定端口 && 开启监听,代表10086服务已经开启 5288有可能被占用
    NSError * error = nil;
    [serverSocket acceptOnPort:5288 error:&error];
    if (!error) {
        NSLog(@"10086服务开启成功");
    }else{
        NSLog(@"10086服务开启失败，%@",error);

    }
    self.serverSocket = serverSocket;
}
#pragma mark == 有客户端的Socket连接到服务器
-(void)socket:(GCDAsyncSocket *)serverSocket didAcceptNewSocket:(GCDAsyncSocket *)clientSocket
{
    NSLog(@"serverSocket == %@ -- clientSocket == %@",serverSocket,clientSocket);
    //1.保存客户端Socket
    //服务端是Socket只监听 有没有客户端的请求
    [self.clientSockets addObject:clientSocket];
    
    //客户端连接上来，提供服务
    NSMutableString * serverStr = [NSMutableString string];
    [serverStr appendString:@"欢迎来到10086在线服务，请输入下面的数字选择服务\n"];
    [serverStr appendString:@"[0]在线充值\n"];
    [serverStr appendString:@"[1]在线投诉\n"];
    [serverStr appendString:@"[2]优惠信息\n"];
    [serverStr appendString:@"[3]特殊服务\n"];
    [serverStr appendString:@"[4]退出\n"];
    
    
    [clientSocket writeData:[serverStr dataUsingEncoding: NSUTF8StringEncoding] withTimeout:-1 tag:0];
    
    
    //2.监听客户端有没有数据上传(timeout：-1代表不超时，tag：标识，暂时不用)
    [clientSocket readDataWithTimeout:-1 tag:0];
    
}
#pragma mark == 读取客户端请求数据
-(void)socket:(GCDAsyncSocket *)clientSocket didReadData:(NSData *)data withTag:(long)tag
{
    //1.把NSData转成NSString
    NSString * str = [[NSString alloc] initWithData:data encoding:NSUTF8StringEncoding];
    
    //2.字符串转数字
    NSInteger code = [str integerValue];
    NSString * responseStr = nil;
    switch (code) {
        case 0:
            
            responseStr = @"充值服务暂停中\n";
            break;
        case 1:
            responseStr = @"投诉服务暂停中\n";
            break;
        case 2:
            responseStr = @"暂无优惠信息\n";
            
            break;
        case 3:
            responseStr = @"没有特殊服务\n";
            
            break;
        case 4:
            responseStr = @"退出成功\n";
            
            break;
        default:
            break;
    }
    
    
    NSLog(@"接受到客户端上传数据:%@",str);
    //3.处理请求，返回数据给客户端
    [clientSocket writeData:[responseStr dataUsingEncoding:NSUTF8StringEncoding] withTimeout:-1 tag:0];
    
    if (code == 4) {
        //移除客户端
        [self.clientSockets removeObject:clientSocket];
    }
    
#warning 每次读取完数据后，都要调用一次监听数据的方法
    [clientSocket readDataWithTimeout:-1 tag:0];
    
    
    
}