GCDAsyncSocket编程
同上一篇文章一样,这里也是使用Socket实现一个聊天室,但是这里使用的是一个常用的框架实现的:GCDAsyncSocket
一:导入这个框架
二:声明这个Socket的成员变量,定义一个消息数组
@interface ViewController ()<UITextFieldDelegate,UITableViewDataSource,UITableViewDelegate,GCDAsyncSocketDelegate>{ GCDAsyncSocket *_socket; } @property (weak, nonatomic) IBOutlet NSLayoutConstraint *inputViewConstraint; @property (weak, nonatomic) IBOutlet UITableView *tableView; @property (nonatomic, strong) NSMutableArray *chatMsgs;//聊天消息数组 @end
懒加载消息数组
-(NSMutableArray *)chatMsgs{ if (!_chatMsgs) { _chatMsgs = [NSMutableArray array]; } return _chatMsgs; }
三:链接服务器
- (IBAction)connectToHost:(id)sender { // 1.建立连接 NSString *host = @"127.0.0.1"; ; // 创建一个Socket对象 _socket = [[GCDAsyncSocket alloc] initWithDelegate:self delegateQueue:dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, )]; // 连接 NSError *error = nil; [_socket connectToHost:host onPort:port error:&error]; if (error) { NSLog(@"%@",error); } }
链接与断开连接的代理方法
#pragma mark -AsyncSocket的代理 #pragma mark 连接主机成功 -(void)socket:(GCDAsyncSocket *)sock didConnectToHost:(NSString *)host port:(uint16_t)port{ NSLog(@"连接主机成功"); } #pragma mark 与主机断开连接 -(void)socketDidDisconnect:(GCDAsyncSocket *)sock withError:(NSError *)err{ if(err){ NSLog(@"断开连接 %@",err); } }
四:登陆
- (IBAction)loginBtnClick:(id)sender { // 登录 // 发送用户名和密码 // 在这里做的时候,只发用户名,密码就不用发送 // 如果要登录,发送的数据格式为 "iam:zhangsan"; // 如果要发送聊天消息,数据格式为 "msg:did you have dinner"; //登录的指令 NSString *loginStr = @"iam:zhangsan"; //把Str转成NSData NSData *data = [loginStr dataUsingEncoding:NSUTF8StringEncoding]; //[_outputStream write:data.bytes maxLength:data.length]; // 发送登录指令给服务 [_socket writeData:data withTimeout:- tag:]; }
五:发送数据
-(BOOL)textFieldShouldReturn:(UITextField *)textField{ NSString *text = textField.text; NSLog(@"%@",text); // 聊天信息 NSString *msgStr = [NSString stringWithFormat:@"msg:%@",text]; //把Str转成NSData NSData *data = [msgStr dataUsingEncoding:NSUTF8StringEncoding]; // 刷新表格 [self reloadDataWithText:msgStr]; // 发送数据 [_socket writeData:data withTimeout:- tag:]; // 发送完数据,清空textField textField.text = nil; return YES; } #pragma mark 数据成功发送到服务器 -(void)socket:(GCDAsyncSocket *)sock didWriteDataWithTag:(long)tag{ NSLog(@"数据成功发送到服务器"); //数据发送成功后,自己调用一下读取数据的方法,接着_socket才会调用下面的代理方法 [_socket readDataWithTimeout:- tag:tag]; } #pragma mark 服务器有数据,会调用这个方法 -(void)socket:(GCDAsyncSocket *)sock didReadData:(NSData *)data withTag:(long)tag{ // 从服务器接收到的数据 NSString *recStr = [[NSString alloc] initWithData:data encoding:NSUTF8StringEncoding]; NSLog(@"%@ %ld %@",[NSThread currentThread],tag, recStr); ) {//聊天返回的数据 // 刷新表格 [self reloadDataWithText:recStr]; } // }else if(tag == 101 ){//登录返回数据,不应该把数据添加到表格里 // // // } }
六:加载聊天数据到界面,并且实现滚动到对应的位置,键盘的键盘
-(void)reloadDataWithText:(NSString *)text{ [self.chatMsgs addObject:text]; // UI刷新要主线程 dispatch_async(dispatch_get_main_queue(), ^{ [self.tableView reloadData]; // 数据多,应该往上滚动 NSIndexPath *lastPath = [NSIndexPath indexPathForRow:self.chatMsgs.count - inSection:]; [self.tableView scrollToRowAtIndexPath:lastPath atScrollPosition:UITableViewScrollPositionBottom animated:YES]; }); } #pragma mark 表格的数据源 -(NSInteger)tableView:(UITableView *)tableView numberOfRowsInSection:(NSInteger)section{ return self.chatMsgs.count; } - (UITableViewCell *)tableView:(UITableView *)tableView cellForRowAtIndexPath:(NSIndexPath *)indexPath { static NSString *ID = @"Cell"; UITableViewCell *cell = [tableView dequeueReusableCellWithIdentifier:ID]; cell.textLabel.text = self.chatMsgs[indexPath.row]; return cell; } -(void)scrollViewWillBeginDragging:(UIScrollView *)scrollView{ [self.view endEditing:YES]; }
键盘处理
// 监听键盘 [[NSNotificationCenter defaultCenter] addObserver:self selector:@selector(kbFrmWillChange:) name:UIKeyboardWillChangeFrameNotification object:nil]; } -(void)kbFrmWillChange:(NSNotification *)noti{ NSLog(@"%@",noti.userInfo); // 获取窗口的高度 CGFloat windowH = [UIScreen mainScreen].bounds.size.height; // 键盘结束的Frm CGRect kbEndFrm = [noti.userInfo[UIKeyboardFrameEndUserInfoKey] CGRectValue]; // 获取键盘结束的y值 CGFloat kbEndY = kbEndFrm.origin.y; self.inputViewConstraint.constant = windowH - kbEndY; }