前言
- 上一章我们主要讲述了如何利用服务器实现群聊.本章主要学习是从客户端的角度简单实现群聊功能.
步骤:
- 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, 全局队列是异步函数的,执行耗时操作是在子线程, 刷新表格需要回到主线程上去进行刷新操作.
