模拟群聊的简单实现

前言

• 上一章我们主要讲述了如何利用服务器实现群聊.本章主要学习是从客户端的角度简单实现群聊功能.

步骤:

• 1, 导入框架并且描述storyboard.设置"dataSource"监听几个控件等.见下图 1.

Snip20160309_2.png

• 2, 创建客户端的Socket对象,连接QQ服务器

#import "ViewController.h"
#import "GCDAsyncSocket.h"


@interface ViewController ()<GCDAsyncSocketDelegate, UITableViewDataSource>

/** 消息编辑框 */
@property (weak, nonatomic) IBOutlet UITextField *textField;

/** 显示聊天内容的tableView */
@property (weak, nonatomic) IBOutlet UITableView *chatTableView;

/** 发送消息 */
- (IBAction)sendMessage:(UIButton *)sender;

/** 客户端的Socket对象 */
@property(nonatomic, strong) GCDAsyncSocket *clientSocket;

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

@end

@implementation ViewController

#pragma mark - 懒加载
- (NSMutableArray *)dataSources
{
    if (_dataSources == nil) {
        _dataSources = [NSMutableArray array];
    }
    return _dataSources;
}

- (void)viewDidLoad {
    [super viewDidLoad];
    
    // 创建客户端的Socket对象
    GCDAsyncSocket *clientSocket = [[GCDAsyncSocket alloc] initWithDelegate:self delegateQueue:dispatch_get_global_queue(0, 0)];
    
    // 发送连接请求
    NSError *error = nil;
    [clientSocket connectToHost:@"192.168.1.100" onPort:1886 error:&error];
    
    // 判断是否连接成功,但是真正的连接不是在这儿,而是在代理方法中连接或者断开.
    if (!error) {
        NSLog(@"连接成功");
    } else
    {
        NSLog(@"连接失败啦%@",error);
    }
    
    // 保存创建好的客户端的Socket对象
    self.clientSocket = clientSocket;
}

• 注意点 :

  • 1, clientSocket是一个局部变量,所以需要定义一个属性强引用,这样在后面的的方法中才能拿到该对象.

• 2, 定义一个可变的数组,用于保存客户端发送的消息(客户端每发送一次消息就需要将消息保存到数组中),而且这个可变数组需要懒加载,用到时再创建.

• 3, 请求连接之后,真正的连接或者断开连接都是在代理方法中可以验证的.

#pragma mark - GCDAsyncSocketDelegate
/**
 *  只要客户端和服务器连接成功就会调该方法,第一个参数是客户端,clientSocket是一个局部变量,所以需要定义成
 *  一个属性强引用着.
 */
- (void)socket:(GCDAsyncSocket *)clientSocket didConnectToHost:(NSString *)host port:(uint16_t)port
{
    NSLog(@"连接成功");
    // 连接成功,接收客户端发送的数据
    [clientSocket readDataWithTimeout:-1 tag:0];

}

/**
 *  只要断开连接就一定会来到这个方法
 */
- (void)socketDidDisconnect:(GCDAsyncSocket *)sock withError:(NSError *)err
{
    NSLog(@"断开连接");
}

• 4, 客户端接收消息

/**
 *  监听客户端是否发送了消息,只要发送了消息就会来到这个方法, 读取信息
 */
- (void)socket:(GCDAsyncSocket *)clientSocket didReadData:(NSData *)data withTag:(long)tag
{

    // 将发送的数据转化为字符串
    NSString *messageStr = [[NSString alloc] initWithData:data encoding:NSUTF8StringEncoding];
    
    // 判断客户端是否发送了消息,如果发送了消息,将消息保存至数据源中
    if (messageStr) {
        
        // 保存消息
        [self.dataSources addObject:messageStr];
    }
    
    // 刷新UI,必须要回到主线程,否则数据显示不出来
    [[NSOperationQueue mainQueue]addOperationWithBlock:^{
        // 刷新表格
        [self.chatTableView reloadData];
    }];
    
    // 读取(接收)数据
    [clientSocket readDataWithTimeout:-1 tag:0];
}

• 注意点 :

  • 1, 将NSData转为字符串后,需要判断是否为空,如果不为空需要将字符串保存到dataSources数组中.

• 2, 接收到数据之后需要展示数据,所以需要刷新表格,但是,当前线程是在全局线程上执行的,也就是说当前是一个异步函数,属于子线程,所以需要回到主线程上执行刷新操作.

• 3, 当刷新表格后都要监听读取数据,否则显示一次数据之后,就不会再接收任何数据了.

• 4, 数据源方法,用于展示数据到tableView上

#pragma mark - UITableViewDataSource

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

- (UITableViewCell *)tableView:(UITableView *)tableView cellForRowAtIndexPath:(NSIndexPath *)indexPath
{

    // 定义一个标识和Storyboard中定义的ID一致
    NSString * const ID = @"Cell";
    
    UITableViewCell *cell = [tableView dequeueReusableCellWithIdentifier:ID];
    
    cell.textLabel.text = self.dataSources[indexPath.row];
    
    return cell;
}

• 5, 监听发送按钮

- (IBAction)sendMessage:(UIButton *)sender {
    
    NSString *str = self.textField.text;
    
    if (str == 0) {   //  说明没有消息发送
        return;
    }
    
    // 来到这里表示有发送消息
    
    // 将消息保存到数据源中
    [self.dataSources addObject:str];
    
    // 刷新表格
    [self.chatTableView reloadData];
    
    // 发送消息
    [self.clientSocket writeData:[str dataUsingEncoding:NSUTF8StringEncoding] withTimeout:-1 tag:0];
}

• 注意 :

  • 1, 需要判断消息编辑框中是否有数据,如果没有,直接返回,如果有,那么将数据保存到数组中, 刷新表格,最后发送消息.

• 知识拓展

  • 1, 客户端有没有连接或者是有没有断开都是是通过代理方法来检验的.
  • 2, 全局队列是异步函数的,执行耗时操作是在子线程, 刷新表格需要回到主线程上去进行刷新操作.