iOS socket


#import "ViewController.h"

@interface ViewController ()<NSStreamDelegate,UITextFieldDelegate,UITableViewDataSource,UITableViewDelegate>{
    NSInputStream *_inputStream;//     
    NSOutputStream *_outputStream;//     
}
@property (weak, nonatomic) IBOutlet NSLayoutConstraint *inputViewConstraint;
@property (weak, nonatomic) IBOutlet UITableView *tableView;
@property (nonatomic, strong) NSMutableArray *chatMsgs;//      
@end
@implementation ViewController
-(NSMutableArray *)chatMsgs{
    if (!_chatMsgs) {
        _chatMsgs = [NSMutableArray array];
    }
    return _chatMsgs;
}
- (void)viewDidLoad {
    [super viewDidLoad];
    // 2.    
    //      
    // 1.    
    // 2.    
    //     
    [[NSNotificationCenter defaultCenter] addObserver:self selector:@selector(kbFrmWillChange:) name:UIKeyboardWillChangeFrameNotification object:nil];
}
-(void)kbFrmWillChange:(NSNotification *)noti{
    //        
    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;
}

-(void)stream:(NSStream *)aStream handleEvent:(NSStreamEvent)eventCode{
    NSLog(@"%@",[NSThread currentThread]);
//    NSStreamEventOpenCompleted = 1UL << 0,//         
//    NSStreamEventHasBytesAvailable = 1UL << 1,//     
//    NSStreamEventHasSpaceAvailable = 1UL << 2,//      
//    NSStreamEventErrorOccurred = 1UL << 3,//       
//    NSStreamEventEndEncountered = 1UL << 4//     
    switch (eventCode) {
        case NSStreamEventOpenCompleted:
            NSLog(@"         ");
            break;
        case NSStreamEventHasBytesAvailable:
            NSLog(@"     ");
            [self readData];
            break;
        case NSStreamEventHasSpaceAvailable:
            NSLog(@"      ");
            break;
        case NSStreamEventErrorOccurred:
            NSLog(@"       ");
            break;
        case NSStreamEventEndEncountered:
             NSLog(@"    ");
            //        
            [_inputStream close];
            [_outputStream close];
            //         
            [_inputStream removeFromRunLoop:[NSRunLoop mainRunLoop] forMode:NSDefaultRunLoopMode];
            [_outputStream removeFromRunLoop:[NSRunLoop mainRunLoop] forMode:NSDefaultRunLoopMode];
            break;
        default:
            break;
    }
}
- (IBAction)connectToHost:(id)sender {
    // 1.    
    NSString *host = @"127.0.0.1";
    int port = 12345;
    //   C       
    CFReadStreamRef readStream;
    CFWriteStreamRef writeStream;
    CFStreamCreatePairWithSocketToHost(NULL, (__bridge CFStringRef)host, port, &readStream, &writeStream);
    //  C           OC  
    _inputStream = (__bridge NSInputStream *)(readStream);
    _outputStream = (__bridge NSOutputStream *)(writeStream);
    //     
    _inputStream.delegate = self;
    _outputStream.delegate = self;
    //               
    //                  
    [_inputStream scheduleInRunLoop:[NSRunLoop mainRunLoop] forMode:NSDefaultRunLoopMode];
    [_outputStream scheduleInRunLoop:[NSRunLoop mainRunLoop] forMode:NSDefaultRunLoopMode];
    //        
    [_inputStream open];
    [_outputStream open];
}
- (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];
}
#pragma mark           
-(void)readData{
    //           1024   
    uint8_t buf[1024];
    //          
    NSInteger len = [_inputStream read:buf maxLength:sizeof(buf)];
    //            
    NSData *data = [NSData dataWithBytes:buf length:len];
    //           
    NSString *recStr =  [[NSString alloc] initWithData:data encoding:NSUTF8StringEncoding];
    [self reloadDataWithText:recStr];
}
-(BOOL)textFieldShouldReturn:(UITextField *)textField{
    NSString *text = textField.text;
    //     
    NSString *msgStr = [NSString stringWithFormat:@"msg:%@",text];
    // Str  NSData
    NSData *data = [msgStr dataUsingEncoding:NSUTF8StringEncoding];
    //     
    [self reloadDataWithText:msgStr];
    //     
    [_outputStream write:data.bytes maxLength:data.length];
    //      ,  textField
    textField.text = nil;
    return YES;
}
-(void)reloadDataWithText:(NSString *)text{
    [self.chatMsgs addObject:text];
    
    [self.tableView reloadData];
    
    //    ,      
    NSIndexPath *lastPath = [NSIndexPath indexPathForRow:self.chatMsgs.count - 1 inSection:0];
    [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];
}
@end

サーバーはgithubで、自分でダウンロードして遊ぶことができます.本人javaは入門したばかりで、ここまでしかできません.このサーバーに基づいて他の機能を拡張することができます.