主要是方法和思路，在最后會(huì)附上全部代碼
目的：怎么通過socke對(duì)象在服務(wù)器里怎么接受/返回?cái)?shù)據(jù)
實(shí)現(xiàn)10086服務(wù)功能
- 實(shí)現(xiàn)Socket監(jiān)聽的方法
（1）使用C語言實(shí)現(xiàn)
（2）使用CocaoAsyncSocket（第三方框架），內(nèi)部是對(duì)C語言的封裝 - Telent命令：Telnet命令 telnet host port/telnet 192.168.10.10 5288(終端輸入)
1.telnet命令是連接服務(wù)器上的某個(gè)端口對(duì)應(yīng)的服務(wù)
第一步：實(shí)現(xiàn)服務(wù)器的監(jiān)聽
使用命令行
image.png
創(chuàng)建一個(gè)繼承于NSObject的類祸轮。下載好CocaoAsyncSocket之后纵柿，把GCDAsyncSocket導(dǎo)入（TCP）菠秒。
// FWLServiceListener.h
//開啟服務(wù)
- (void)start;
// FWLServiceListener.m
#import "GCDAsyncSocket.h"
@interface FWLServiceListener ()<GCDAsyncSocketDelegate>
@property(nonatomic,strong)GCDAsyncSocket * serverSocket;
@end
@implementation FWLServiceListener
-(void)start
{
//開啟10096服務(wù):5288
//1.創(chuàng)建一個(gè)socket對(duì)象
//服務(wù)端的Socket只監(jiān)聽 有無客戶端請(qǐng)求連接
//serverSocket是局部變量恶阴，方法執(zhí)行后就會(huì)被釋放掉淌山，做個(gè)屬性
GCDAsyncSocket * serverSocket = [[GCDAsyncSocket alloc] initWithDelegate:self delegateQueue:dispatch_get_global_queue(0, 0)];
//2.綁定端口 && 開啟監(jiān)聽,代表10086服務(wù)已經(jīng)開啟 5288有可能被占用
NSError * error = nil;
[serverSocket acceptOnPort:5288 error:&error];
if (!error) {
NSLog(@"10086服務(wù)開啟成功");
}else{
NSLog(@"10086服務(wù)開啟失敗拯勉，%@",error);
}
self.serverSocket = serverSocket;
}
#pragma mark == 有客戶端的Socket連接到服務(wù)器
-(void)socket:(GCDAsyncSocket *)serverSocket didAcceptNewSocket:(GCDAsyncSocket *)clientSocket
{
NSLog(@"serverSocket == %@ -- clientSocket == %@",serverSocket,clientSocket);
}
打開網(wǎng)絡(luò)偏好設(shè)置竟趾，查看IP地址
image.png
終端輸入
image.png
此時(shí)，提示Connection closed by foreign host.連接被遠(yuǎn)程關(guān)閉宫峦。是因?yàn)檫B接已經(jīng)建立了岔帽，但是還未走客戶端的read，write流程就被關(guān)閉了导绷，因?yàn)榭蛻舳藄ocket是局部變量犀勒，方法結(jié)束后就被釋放了，所以連接斷開妥曲。
所以寫一個(gè)屬性,設(shè)置一個(gè)數(shù)組來接收所有的用戶socket
//客戶端的所有Socket對(duì)象
@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];
}
再次運(yùn)行
image.png
連接建立之后贾费，客戶端寫入數(shù)據(jù)，發(fā)送到服務(wù)器檐盟。在服務(wù)器輸入數(shù)據(jù)（客戶端）發(fā)送給服務(wù)端褂萧。
需要寫入如下方法：
#pragma mark == 讀取客戶端請(qǐng)求數(shù)據(jù)
-(void)socket:(GCDAsyncSocket *)clientSocket didReadData:(NSData *)data withTag:(long)tag
{
NSLog(@"讀取數(shù)據(jù) clientSocket == %@",clientSocket);
}
但是并沒有輸出，是因?yàn)槿鄙僖恍袃?nèi)部實(shí)現(xiàn)的代碼葵萎，在socket：didAcceptNewSocket方法中添加
//2.監(jiān)聽客戶端有沒有數(shù)據(jù)上傳(timeout：-1代表不超時(shí)导犹，tag：標(biāo)識(shí)，暫時(shí)不用)
[clientSocket readDataWithTimeout:-1 tag:0];
image.png
此時(shí)發(fā)現(xiàn)地址與上一個(gè)clientSocket的地址是相同的陌宿。
目前只是打印了Socket的地址锡足，現(xiàn)在轉(zhuǎn)碼打印具體的對(duì)象
//把NSData轉(zhuǎn)成NSString
NSString * str = [[NSString alloc] initWithData:data encoding:NSUTF8StringEncoding];
NSLog(@"讀取數(shù)據(jù) clientSocket == %@",str);
屏幕快照 2016-07-05 下午5.28.56.png
但是，再次輸入時(shí)沒有打印壳坪。是因?yàn)榭蚣艿脑虿暗茫看巫x完數(shù)據(jù)都要調(diào)用監(jiān)聽方法，即方法
#warning 每次讀取完數(shù)據(jù)后爽蝴，都要調(diào)用一次監(jiān)聽數(shù)據(jù)的方法
[clientSocket readDataWithTimeout:-1 tag:0];
返回?cái)?shù)據(jù)給客戶端(輸入什么返回什么)
//2.處理請(qǐng)求沐批，返回?cái)?shù)據(jù)給客戶端
[clientSocket writeData:data withTimeout:-1 tag:0];
image·.png
現(xiàn)在附上全部代碼
// FWLServiceListener.h
//開啟服務(wù)
- (void)start;
// FWLServiceListener.m
#import "GCDAsyncSocket.h"
@interface FWLServiceListener ()<GCDAsyncSocketDelegate>
@property(nonatomic,strong)GCDAsyncSocket * serverSocket;
//客戶端的所有Socket對(duì)象
@property(nonatomic,strong)NSMutableArray * clientSockets;
@end
@implementation FWLServiceListener
-(NSMutableArray *)clientSockets
{
if (!_clientSockets) {
_clientSockets = [NSMutableArray array];
}
return _clientSockets;
}
-(void)start
{
//開啟10096服務(wù):5288
//1.創(chuàng)建一個(gè)socket對(duì)象
//服務(wù)端的Socket只監(jiān)聽 有無客戶端請(qǐng)求連接
//serverSocket是局部變量纫骑，方法執(zhí)行后就會(huì)被釋放掉，做個(gè)屬性
GCDAsyncSocket * serverSocket = [[GCDAsyncSocket alloc] initWithDelegate:self delegateQueue:dispatch_get_global_queue(0, 0)];
//2.綁定端口 && 開啟監(jiān)聽,代表10086服務(wù)已經(jīng)開啟 5288有可能被占用
NSError * error = nil;
[serverSocket acceptOnPort:5288 error:&error];
if (!error) {
NSLog(@"10086服務(wù)開啟成功");
}else{
NSLog(@"10086服務(wù)開啟失敗九孩，%@",error);
}
self.serverSocket = serverSocket;
}
#pragma mark == 有客戶端的Socket連接到服務(wù)器
-(void)socket:(GCDAsyncSocket *)serverSocket didAcceptNewSocket:(GCDAsyncSocket *)clientSocket
{
NSLog(@"serverSocket == %@ -- clientSocket == %@",serverSocket,clientSocket);
//1.保存客戶端Socket
//服務(wù)端是Socket只監(jiān)聽 有沒有客戶端的請(qǐng)求
[self.clientSockets addObject:clientSocket];
//客戶端連接上來先馆，提供服務(wù)
NSMutableString * serverStr = [NSMutableString string];
[serverStr appendString:@"歡迎來到10086在線服務(wù)，請(qǐng)輸入下面的數(shù)字選擇服務(wù)\n"];
[serverStr appendString:@"[0]在線充值\n"];
[serverStr appendString:@"[1]在線投訴\n"];
[serverStr appendString:@"[2]優(yōu)惠信息\n"];
[serverStr appendString:@"[3]特殊服務(wù)\n"];
[serverStr appendString:@"[4]退出\n"];
[clientSocket writeData:[serverStr dataUsingEncoding: NSUTF8StringEncoding] withTimeout:-1 tag:0];
//2.監(jiān)聽客戶端有沒有數(shù)據(jù)上傳(timeout：-1代表不超時(shí)躺彬，tag：標(biāo)識(shí)煤墙，暫時(shí)不用)
[clientSocket readDataWithTimeout:-1 tag:0];
}
#pragma mark == 讀取客戶端請(qǐng)求數(shù)據(jù)
-(void)socket:(GCDAsyncSocket *)clientSocket didReadData:(NSData *)data withTag:(long)tag
{
//1.把NSData轉(zhuǎn)成NSString
NSString * str = [[NSString alloc] initWithData:data encoding:NSUTF8StringEncoding];
//2.字符串轉(zhuǎn)數(shù)字
NSInteger code = [str integerValue];
NSString * responseStr = nil;
switch (code) {
case 0:
responseStr = @"充值服務(wù)暫停中\(zhòng)n";
break;
case 1:
responseStr = @"投訴服務(wù)暫停中\(zhòng)n";
break;
case 2:
responseStr = @"暫無優(yōu)惠信息\n";
break;
case 3:
responseStr = @"沒有特殊服務(wù)\n";
break;
case 4:
responseStr = @"退出成功\n";
break;
default:
break;
}
NSLog(@"接受到客戶端上傳數(shù)據(jù):%@",str);
//3.處理請(qǐng)求，返回?cái)?shù)據(jù)給客戶端
[clientSocket writeData:[responseStr dataUsingEncoding:NSUTF8StringEncoding] withTimeout:-1 tag:0];
if (code == 4) {
//移除客戶端
[self.clientSockets removeObject:clientSocket];
}
#warning 每次讀取完數(shù)據(jù)后宪拥，都要調(diào)用一次監(jiān)聽數(shù)據(jù)的方法
[clientSocket readDataWithTimeout:-1 tag:0];
}
