以前实现简单 Server 程序,服务端通过 void WriteStreamClientCallBack(CFWriteStreamRef stream, CFStreamEventType eventType, void* clientCallBackInfo) 函数向client发送“你好。client!”的消息,假设client接收成功的话就会显示“你好。client!
”。须要显示服务端发送过来的消息。那么就须要定义一个UILabel输出口(IBOutlet)来显示消息;client还须要加入两个button,一个用来接收服务端消息的动作事件方法
receiveData:和发送client“收到啦,服务端”消息的动作事件方法 sendData:;加入关联就能够了,比較简单,以下来看一下详细实现的代码:
ViewController.h
#import <UIKit/UIKit.h> #import <CoreFoundation/CoreFoundation.h> #include <sys/socket.h> #include <netinet/in.h> #define PORT 8734 //将端口设置为8734。能够依据详细情况改变 @interface ViewController : UIViewController<NSStreamDelegate> { int flag ; //操作标志 0为发送 1为接收 } @property (nonatomic, retain) NSInputStream *inputStream; @property (nonatomic, retain) NSOutputStream *outputStream; @property (weak, nonatomic) IBOutlet UILabel *message; //在client显示来自服务端的消息 - (IBAction)sendData:(id)sender; //发送client的消息 - (IBAction)receiveData:(id)sender; //接收来自服务端的消息 @end
ViewController.m
#import "ViewController.h" @interface ViewController () @end @implementation ViewController - (void)viewDidLoad { [super viewDidLoad]; } - (void)didReceiveMemoryWarning { [super didReceiveMemoryWarning]; } //初始化client网络连接 - (void)initNetworkCommunication { CFReadStreamRef readStream; CFWriteStreamRef writeStream; //这里须要填写 IP 地址,依据自己路由能够用的 IP来定,这里是192.168.1.103,假设不知道能够下载 IP 扫描器 CFStreamCreatePairWithSocketToHost(NULL, (CFStringRef)@"192.168.1.103", PORT, &readStream, &writeStream); self.inputStream = (__bridge_transfer NSInputStream *)readStream; //将CFStream对象转化为NSStream对象 self.outputStream = (__bridge_transfer NSOutputStream *)writeStream; //将CFStream对象转化为NSStream对象 [self.inputStream setDelegate:self]; [self.outputStream setDelegate:self]; [self.inputStream scheduleInRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode]; //NSStream 方法 scheduleInRunLoop: 设置 Run Loop [self.outputStream scheduleInRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode]; [self.inputStream open]; //NSStream 的 open 方法来打开数据流对象 [self.outputStream open]; } //关闭数据流操作 -(void)close { [self.outputStream close]; [self.outputStream removeFromRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode]; [self.outputStream setDelegate:nil]; [self.inputStream close]; [self.inputStream removeFromRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode]; [self.inputStream setDelegate:nil]; } //从client发送数据事件方法 - (IBAction)sendData:(id)sender { flag = 0; //表示发送 [self initNetworkCommunication]; } //从服务端接收数据事件方法 - (IBAction)receiveData:(id)sender { flag = 1; //表示接收 [self initNetworkCommunication]; } -(void)stream:(NSStream *)theStream handleEvent:(NSStreamEvent)streamEvent { NSString *event; switch (streamEvent) { case NSStreamEventNone: //没有事件发生 event = @"NSStreamEventNone"; break; case NSStreamEventOpenCompleted: //成功打开流 event = @"NSStreamEventOpenCompleted"; break; case NSStreamEventHasBytesAvailable: //这个流有数据能够读,在读取数据时使用 event = @"NSStreamEventHasBytesAvailable"; if (flag ==1 && theStream == _inputStream) { NSMutableData *input = [[NSMutableData alloc] init]; uint8_t buffer[2048]; //读取数据准备缓冲区,本例中设置的是2048字节,这个大小会对流的读取有非常大影响 int len; while([self.inputStream hasBytesAvailable]) { len = [self.inputStream read:buffer maxLength:sizeof(buffer)]; //读取数据到缓冲区 if (len > 0) { [input appendBytes:buffer length:len]; } } NSString *resultstring = [[NSString alloc] initWithData:input encoding:NSUTF8StringEncoding]; NSLog(@"接收:%@",resultstring); self.message.text = resultstring; } break; case NSStreamEventHasSpaceAvailable: //这个流能够接收数据的写入,在写数据时使用 event = @"NSStreamEventHasSpaceAvailable"; if (flag ==0 && theStream == _outputStream) { //输出 UInt8 buff[] = "收到啦,服务端。"; //向服务端发送的消息 [self.outputStream write:buff maxLength: strlen((const char*)buff)+1]; //向服务端写入数据方法 //必须关闭输出流否则,server端一直读取不会停止。 [self.outputStream close]; } break; case NSStreamEventErrorOccurred: //数据流错误发生 event = @"NSStreamEventErrorOccurred"; [self close]; break; case NSStreamEventEndEncountered: //数据流结束 event = @"NSStreamEventEndEncountered"; NSLog(@"Error:%d:%@",[[theStream streamError] code], [[theStream streamError] localizedDescription]); break; default: [self close]; event = @"Unknown"; break; } } @end
从代码能够知道。client採用的是 APPLE 自家的 NSStream 来实现的,都是比較简单的基本数据流操作。
如有哪些不正确的地方,欢迎指出!
版权声明:本文博主原创文章,博客,未经同意不得转载。
时间: 2024-11-13 09:29:25