服务器、客户端的Socket编程

  • 实现Socket服务端监听的两种做法:
  • 使用C语言实现
  • 使用第三方CocoaAsyncSocket，内部实质是对C语言的封装

    • 使用CocoaAsyncSocket遇到的问题:


      Snip20160902_257.png

    • 解决办法:


      Snip20160902_258.png

(一)售票:

  • main.m
#import <Foundation/Foundation.h>
#import "ServiceListener.h"
int main(int argc, const char * argv[]) {
    @autoreleasepool {
        ServiceListener *service = [[ServiceListener alloc] init];
        // 开启服务器
        [service start];
        // 开启主线程的运行循环,保证程序不被杀死,不停止.如果没有这句代码，就会打印Program ended with exit code: 0，表示程序被杀死了
        [[NSRunLoop mainRunLoop] run];
        
    }
    return 0;
}
  • ServiceListener.h
#import <Foundation/Foundation.h>

@interface ServiceListener : NSObject
/** 开始服务*/
-(void)start;
/** 停止服务*/
-(void)stop;
@end
  • ServiceListener.m
#import "ServiceListener.h"
#import "GCDAsyncSocket.h"

@interface ServiceListener()<GCDAsyncSocketDelegate>
// 服务端
@property(nonatomic,strong)GCDAsyncSocket *serverSocket;
// 客户端
@property(nonatomic,strong)NSMutableArray *clientSockets;
@end
@implementation ServiceListener

-(NSMutableArray *)clientSockets{
    if (_clientSockets == nil) {
        _clientSockets = [NSMutableArray array];
    }
    return _clientSockets;
}

-(void)start{
    NSLog(@"售票服务开启");
    
    
    // 创建服务端的Socket对象
    self.serverSocket = [[GCDAsyncSocket alloc] initWithDelegate:self delegateQueue:dispatch_get_global_queue(0, 0)];
    
    // 绑定接口并监听
    
    
    NSError *error = nil;

   // 端口随便写,大于1024以上
    [self.serverSocket acceptOnPort:5230 error:&error];
    if (error) {
        NSLog(@"端口号被占用%@",error);
    }else{
        NSLog(@"端口号绑定成功,服务开启");
    }
}

-(void)stop{
    
}
#pragma mark - 有客户端请求连接到服务器就会调用
-(void)socket:(GCDAsyncSocket *)serverSocket didAcceptNewSocket:(GCDAsyncSocket *)clientSocket{
    // 1.存储客户端的socket对象
    [self.clientSockets addObject:clientSocket];
    NSLog(@"当前有%ld个连接的客户端 %@",self.clientSockets.count,clientSocket);
    // 2.开启读取数据
    [clientSocket readDataWithTimeout:-1 tag:0];
    
    // 3.给客户端提供服务选项
    NSMutableString *options = [NSMutableString string];
    [options appendString:@"欢迎来到售票服务，请选择您的服务类型\n"];
    [options appendString:@"[0]买票\n"];
    [options appendString:@"[1]退票\n"];
    [options appendString:@"[2]充值\n"];
    [options appendString:@"[3]改签\n"];
    [options appendString:@"[4]退出\n"];
    [clientSocket writeData:[options dataUsingEncoding:NSUTF8StringEncoding] withTimeout:-1 tag:0];
    
}

/**
 *　读取数据之前，调用客户端Socket对象的readDataWithTimeout方法
 */
-(void)socket:(GCDAsyncSocket *)clientSocket didReadData:(NSData *)data withTag:(long)tag{
    NSString *readStr = [[NSString alloc]initWithData:data encoding:NSUTF8StringEncoding];
    // 读取在terminal输入的内容
    NSLog(@"%@",readStr);
    //开启读取数据，为了下次能接收到数据
    [clientSocket readDataWithTimeout:-1 tag:0];
    
    // 2.处理请求数据
    NSString *responseStr = nil;
    switch ([readStr intValue]) {
        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;
    }
    // 响应
    [clientSocket writeData:[responseStr dataUsingEncoding:NSUTF8StringEncoding] withTimeout:-1 tag:0];
    if ([readStr intValue] == 4) {
        // 退出
        [self.clientSockets removeObject:clientSocket];
    }
}

@end

效果

101.80.gif

(二)聊天服务器:

  • main.m
#import <Foundation/Foundation.h>
#import "ServiceListener.h"
int main(int argc, const char * argv[]) {
    @autoreleasepool {
        ServiceListener *service = [[ServiceListener alloc] init];
        // 开启服务器
        [service start];
        // 开启主线程的运行循环,保证程序不被杀死,不停止.如果没有这句代码，就会打印Program ended with exit code: 0，表示程序被杀死了
        [[NSRunLoop mainRunLoop] run];
        
    }
    return 0;
}
  • ServiceListener.h
#import <Foundation/Foundation.h>

@interface ServiceListener : NSObject
/** 开始服务*/
-(void)start;
/** 停止服务*/
-(void)stop;
@end
  • ServiceListener.m
#import "ServiceListener.h"
#import "GCDAsyncSocket.h"

@interface ServiceListener()<GCDAsyncSocketDelegate>
// 服务端
@property(nonatomic,strong)GCDAsyncSocket *serverSocket;
// 客户端
@property(nonatomic,strong)NSMutableArray *clientSockets;
@end
@implementation ServiceListener

-(NSMutableArray *)clientSockets{
    if (_clientSockets == nil) {
        _clientSockets = [NSMutableArray array];
    }
    return _clientSockets;
}

-(void)start{
    NSLog(@"聊天服务开启");
    
    
    // 创建服务端的Socket对象
    self.serverSocket = [[GCDAsyncSocket alloc] initWithDelegate:self delegateQueue:dispatch_get_global_queue(0, 0)];
    
    // 绑定接口并监听
    
    
    NSError *error = nil;
    // 端口随便写,大于1024以上
    [self.serverSocket acceptOnPort:5538 error:&error];
    if (error) {
        NSLog(@"端口号被占用%@",error);
    }else{
        NSLog(@"端口号绑定成功,服务开启");
    }
}

-(void)stop{
    
}
#pragma mark - 有客户端请求连接到服务器就会调用
-(void)socket:(GCDAsyncSocket *)serverSocket didAcceptNewSocket:(GCDAsyncSocket *)clientSocket{
    // 1.存储客户端的socket对象
    [self.clientSockets addObject:clientSocket];
    NSLog(@"当前有%ld个连接的客户端 %@",self.clientSockets.count,clientSocket);
    // 2.开启读取数据
    [clientSocket readDataWithTimeout:-1 tag:0];
    
    
}

/**
 *　读取数据之前，调用客户端Socket对象的readDataWithTimeout方法
 */
-(void)socket:(GCDAsyncSocket *)clientSocket didReadData:(NSData *)data withTag:(long)tag{
    NSString *readStr = [[NSString alloc]initWithData:data encoding:NSUTF8StringEncoding];
    // 读取在terminal输入的内容
    NSLog(@"%@",readStr);
    //开启读取数据，为了下次能接收到数据
    [clientSocket readDataWithTimeout:-1 tag:0];
    
    // 2.处理请求数据
    // 遍历所有的客户端连接对象cl
    for (GCDAsyncSocket *socket in self.clientSockets) {
        if(clientSocket != socket){// 这个判断的目的是过滤，防止自己发信息时，自己也能收到
            [socket writeData:data withTimeout:-1 tag:0];
        }
    }
    
}

@end
101.81.gif

(三)聊天客户端:(必须和服务端一起使用)

#import "ViewController.h"
#import "GCDAsyncSocket.h"
@interface ViewController ()<GCDAsyncSocketDelegate>

@property (weak, nonatomic) IBOutlet UITextField *TextField;
@property(nonatomic,strong)GCDAsyncSocket *clientSocket;

@property(nonatomic,strong)NSMutableArray *dataSources;//表格数据源
@end

@implementation ViewController
- (void)viewDidLoad {
    [super viewDidLoad];
    self.dataSources = [NSMutableArray array];
    
    // 1.与服务器建立连接
    
    // 2.发送聊天数据
    
    // 3.接收数据
    
}
// 1.与服务器建立连接
- (IBAction)ConnectToServer:(id)sender {
    // 1.1创建客户端Socket对象
    GCDAsyncSocket *clientSocket = [[GCDAsyncSocket alloc] initWithDelegate:self delegateQueue:dispatch_get_global_queue(0, 0)];
    
    // 1.2连接服务器
    NSError *err = nil;
    [clientSocket connectToHost:@"192.168.1.152" onPort:5538 error:&err];
    if (err) {
        NSLog(@"%@",err);
    }
    self.clientSocket = clientSocket;
    
}
//2.发送聊天数据
- (IBAction)SendInputData:(id)sender {
    //1.获取用户输入
    NSString *text = self.TextField.text;
    
    //2.发送
    [self.clientSocket writeData:[text dataUsingEncoding:NSUTF8StringEncoding] withTimeout:-1 tag:0];
    
    //3.刷新表格
    [self.dataSources addObject:text];
    [self.tableView reloadData];
}

#pragma mark - GCDAsyncSocketDelegate代理方法
-(void)socket:(GCDAsyncSocket *)sock didConnectToHost:(NSString *)host port:(uint16_t)port{
    NSLog(@"与服务器连接成功");
    
    // 连接成功，设置读取数据
    [self.clientSocket readDataWithTimeout:-1 tag:0];
}

-(void)socketDidDisconnect:(GCDAsyncSocket *)sock withError:(NSError *)err{
    NSLog(@"与服务器连接失败%@",err);
}

//3.接收聊天数据(终端输入聊天数据 按回车会调用这个方法)
-(void)socket:(GCDAsyncSocket *)sock didReadData:(NSData *)data withTag:(long)tag{
    NSLog(@"%@",[NSThread currentThread]);
    //1.data 转 string
    NSString *readStr = [[NSString alloc] initWithData:data encoding:NSUTF8StringEncoding];
    
    NSLog(@"接收到数据: %@",readStr);
    
    // 每次读取完数据，都要调用下面的方式
    [self.clientSocket readDataWithTimeout:-1 tag:0];
    
    // 刷新表格
    if(readStr == nil)return;// 没有这个判断，程序会崩掉
    
    [self.dataSources addObject:readStr];
    // 回到主线程刷新UI。因为通过打印可以当前线程可以知道当前是在子线程。
    dispatch_async(dispatch_get_main_queue(), ^{
        [self.tableView reloadData];
    });
    
}

#pragma mark - 表格数据源

- (NSInteger)tableView:(UITableView *)tableView numberOfRowsInSection:(NSInteger)section{
    return self.dataSources.count;
}

-(UITableViewCell *)tableView:(UITableView *)tableView cellForRowAtIndexPath:(NSIndexPath *)indexPath{
    static NSString  *ID = @"cell";
    UITableViewCell *cell = [tableView dequeueReusableCellWithIdentifier:ID];
    if(cell == nil){
        cell = [[UITableViewCell alloc]initWithStyle:UITableViewCellStyleDefault reuseIdentifier:ID];
    }
    
    cell.textLabel.text = self.dataSources[indexPath.row];
    
    return cell;
}

@end
  • 必须开启服务端，客户端才能进行连接，否则提示连接失败
101.82.gif
  • 客户端连接成功之后,客户端点击发送按钮，不仅能在客户端的cell中能看到自己发送的信息，而且在服务器的终端中也可以看到发送的信息。同样，服务器的终端不仅能看到自己发送的信息,而且还能把信息发送到客户端(标志是:客户端的cell上能显示服务器的终端发来的信息)，
101.83.gif

[LS](https://pan.baidu.com/s/1kVe0UhT 密码 hnw4)

最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
  • 人面猴
    序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
    沈念sama阅读 213,254评论 6赞 492
  • 死咒
    序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
    沈念sama阅读 90,875评论 3赞 387
  • 救了他两次的神仙让他今天三更去死
    文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
    开封第一讲书人阅读 158,682评论 0赞 348
  • 道士缉凶录：失踪的卖姜人
    文/不坏的土叔 我叫张陵，是天一观的道长。 经常有香客问我，道长，这世上最难降的妖魔是什么？ 我笑而不...
    开封第一讲书人阅读 56,896评论 1赞 285
  • 港岛之恋（遗憾婚礼）
    正文 为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
    茶点故事阅读 66,015评论 6赞 385
  • 恶毒庶女顶嫁案：这布局不是一般人想出来的
    文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
    开封第一讲书人阅读 50,152评论 1赞 291
  • 城市分裂传说
    那天，我揣着相机与录音，去河边找鬼。 笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。 我是一名探鬼主播，决...
    沈念sama阅读 39,208评论 3赞 412
  • 双鸳鸯连环套：你想象不到人心有多黑
    文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
    开封第一讲书人阅读 37,962评论 0赞 268
  • 万荣杀人案实录
    序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
    沈念sama阅读 44,388评论 1赞 304
  • 护林员之死
    正文 独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 36,700评论 2赞 327
  • 白月光启示录
    正文 我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,867评论 1赞 341
  • 活死人
    序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
    沈念sama阅读 34,551评论 4赞 335
  • 日本核电站爆炸内幕
    正文 年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
    茶点故事阅读 40,186评论 3赞 317
  • 男人毒药：我在死后第九天来索命
    文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,901评论 0赞 21
  • 一桩弑父案，背后竟有这般阴谋
    文/苍兰香墨 我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,142评论 1赞 267
  • 情欲美人皮
    我被黑心中介骗来泰国打工， 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。 一个月前我还...
    沈念sama阅读 46,689评论 2赞 362
  • 代替公主和亲
    正文 我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
    茶点故事阅读 43,757评论 2赞 351

推荐阅读更多精彩内容

  • 面向对象的用电信息数据交换协议
    国家电网公司企业标准（Q/GDW）- 面向对象的用电信息数据交换协议 - 报批稿：20170802 前言： 排版 ...
    庭说阅读 10,934评论 6赞 13
  • Spring Cloud
    Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具（例如配置管理，服务发现，断路器，智...
    卡卡罗2017阅读 134,644评论 18赞 139
  • 优秀第三方
    发现 关注 消息 iOS 第三方库、插件、知名博客总结 作者大灰狼的小绵羊哥哥关注 2017.06.26 09:4...
    肇东周阅读 12,068评论 4赞 62
  • 习惯的力量
    习惯 即很长时间养成的一种生活方式。所以很难被消除，好习惯当然要坚持下去，那么坏习惯呢？虽然难以被消除，但是可...
    小仙女69阅读 189评论 1赞 0
  • 打卡 Day2 <自控力>
    今天看完了《自控力》 看书名其实就觉得这本书应该不错，但是没想过最后给我的感觉还是鸡汤文。其实里面有很多实际操作的...
    煎鱼炒肉阅读 154评论 0赞 0