@interfaceViewController (){

NSInputStream *_inputStream;//對應輸入流

NSOutputStream *_outputStream;//對應輸出流

}

@property (weak, nonatomic) IBOutlet NSLayoutConstraint *inputViewConstraint;

@property (weak, nonatomic) IBOutlet UITableView *tableView;

@property (nonatomic, strong) NSMutableArray *chatMsgs;//聊天消息數(shù)組

@end
懶加載這個消息數(shù)組

-(NSMutableArray *)chatMsgs{

if(!_chatMsgs) {

_chatMsgs =[NSMutableArray array];

}

return_chatMsgs;

}

-(void)stream:(NSStream *)aStream handleEvent:(NSStreamEvent)eventCode{

NSLog(@"%@",[NSThread currentThread]);

//NSStreamEventOpenCompleted = 1UL << 0,//輸入輸出流打開完成//NSStreamEventHasBytesAvailable = 1UL << 1,//有字節(jié)可讀//NSStreamEventHasSpaceAvailable = 1UL << 2,//可以發(fā)放字節(jié)//NSStreamEventErrorOccurred = 1UL << 3,//連接出現(xiàn)錯誤//NSStreamEventEndEncountered = 1UL << 4//連接結(jié)束

switch(eventCode) {

caseNSStreamEventOpenCompleted:

NSLog(@"輸入輸出流打開完成");

break;

caseNSStreamEventHasBytesAvailable:

NSLog(@"有字節(jié)可讀");

[self readData];

break;

caseNSStreamEventHasSpaceAvailable:

NSLog(@"可以發(fā)送字節(jié)");

break;

caseNSStreamEventErrorOccurred:

NSLog(@"連接出現(xiàn)錯誤");

break;

caseNSStreamEventEndEncountered:

NSLog(@"連接結(jié)束");

//關閉輸入輸出流

[_inputStream close];

[_outputStream close];

//從主運行循環(huán)移除

[_inputStream removeFromRunLoop:[NSRunLoop mainRunLoop] forMode:NSDefaultRunLoopMode];

[_outputStream removeFromRunLoop:[NSRunLoop mainRunLoop] forMode:NSDefaultRunLoopMode];

break;

default:

break;

}

}

1- (IBAction)connectToHost:(id)sender {

//1.建立連接

NSString *host =@"127.0.0.1";

intport =12345;

//定義C語言輸入輸出流

CFReadStreamRef readStream;

CFWriteStreamRef writeStream;

CFStreamCreatePairWithSocketToHost(NULL, (__bridge CFStringRef)host, port, &readStream, &writeStream);

//把C語言的輸入輸出流轉(zhuǎn)化成OC對象

_inputStream = (__bridge NSInputStream *)(readStream);

_outputStream = (__bridge NSOutputStream *)(writeStream);

//設置代理

_inputStream.delegate=self;

_outputStream.delegate=self;

//把輸入輸入流添加到主運行循環(huán)

//不添加主運行循環(huán) 代理有可能不工作

[_inputStream scheduleInRunLoop:[NSRunLoop mainRunLoop] forMode:NSDefaultRunLoopMode];

[_outputStream scheduleInRunLoop:[NSRunLoop mainRunLoop] forMode:NSDefaultRunLoopMode];

//打開輸入輸出流

[_inputStream open];

[_outputStream open];

}

- (IBAction)loginBtnClick:(id)sender {

//登錄

//發(fā)送用戶名和密碼

//在這里做的時候，只發(fā)用戶名，密碼就不用發(fā)送

//如果要登錄，發(fā)送的數(shù)據(jù)格式為 "iam:zhangsan";

//如果要發(fā)送聊天消息，數(shù)據(jù)格式為 "msg:did you have dinner";

//登錄的指令11NSString *loginStr =@"iam:zhangsan";

//把Str轉(zhuǎn)成NSData

NSData *data =[loginStr dataUsingEncoding:NSUTF8StringEncoding];

[_outputStream write:data.bytes maxLength:data.length];

}

#pragmamark 讀了服務器返回的數(shù)據(jù)

-(void)readData{

//建立一個緩沖區(qū) 可以放1024個字節(jié)

uint8_t buf[1024];

//返回實際裝的字節(jié)數(shù)

NSInteger len = [_inputStream read:buf maxLength:sizeof(buf)];

//把字節(jié)數(shù)組轉(zhuǎn)化成字符串

NSData *data =[NSData dataWithBytes:buf length:len];

//從服務器接收到的數(shù)據(jù)

NSString *recStr =[[NSString alloc] initWithData:data encoding:NSUTF8StringEncoding];

NSLog(@"%@",recStr);

[self reloadDataWithText:recStr];

}

-(BOOL)textFieldShouldReturn:(UITextField *)textField{

NSString *text =textField.text;

NSLog(@"%@",text);

//聊天信息

NSString *msgStr = [NSString stringWithFormat:@"msg:%@",text];

//把Str轉(zhuǎn)成NSData10NSData *data =[msgStr dataUsingEncoding:NSUTF8StringEncoding];

//刷新表格

[self reloadDataWithText:msgStr];

//發(fā)送數(shù)據(jù)

[_outputStream write:data.bytes maxLength:data.length];

//發(fā)送完數(shù)據(jù)，清空textField

textField.text =nil;

returnYES;

}

-(void)reloadDataWithText:(NSString *)text{

[self.chatMsgs addObject:text];

[self.tableView reloadData];

//數(shù)據(jù)多，應該往上滾動

NSIndexPath *lastPath = [NSIndexPath indexPathForRow:self.chatMsgs.count -1inSection:0];

[self.tableView scrollToRowAtIndexPath:lastPath atScrollPosition:UITableViewScrollPositionBottom animated:YES];

}

#pragmamark 表格的數(shù)據(jù)源

-(NSInteger)tableView:(UITableView *)tableView numberOfRowsInSection:(NSInteger)section{

returnself.chatMsgs.count;

}

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

{

staticNSString *ID =@"Cell";

UITableViewCell *cell =[tableView dequeueReusableCellWithIdentifier:ID];

cell.textLabel.text =self.chatMsgs[indexPath.row];

returncell;

}

-(void)scrollViewWillBeginDragging:(UIScrollView *)scrollView{

[self.view endEditing:YES];

}

//監(jiān)聽鍵盤

[[NSNotificationCenter defaultCenter] addObserver:self selector:@selector(kbFrmWillChange:) name:UIKeyboardWillChangeFrameNotificationobject:nil];

}

-(void)kbFrmWillChange:(NSNotification *)noti{

NSLog(@"%@",noti.userInfo);

//獲取窗口的高度

CGFloat windowH =[UIScreen mainScreen].bounds.size.height;

//鍵盤結(jié)束的Frm

CGRect kbEndFrm =[noti.userInfo[UIKeyboardFrameEndUserInfoKey] CGRectValue];

//獲取鍵盤結(jié)束的y值

CGFloat kbEndY =kbEndFrm.origin.y;

self.inputViewConstraint.constant = windowH -kbEndY;

}