[譯]ios開發之從輸入流裡讀入資料
ios cocoa 程式設計,從NSInputStream中讀入資料包括幾個步驟:
1.從資料來源建立和初始化一個NSInputStream例項
2.將輸入流物件配置到一個run loop,open the stream
3. 通過流物件的delegate函式處理事件
4. 當所有資料讀完,進行流物件的記憶體處理
一,使用流物件的準備工作
在使用NSInputStream物件之前你必須有流的資料來源,資料來源的型別可以是檔案,NSData物件,或者一個網路套接字。
NSInputStream的初始化函式和工廠方法可以從NSData和檔案建立和初始化一個NSInputStream的例項。下面的例子是從檔案建立一個NSInputStream的例項:
- (void)setUpStreamForFile:(NSString *)path { // iStream is NSInputStream instance variable iStream = [[NSInputStream alloc] initWithFileAtPath:path]; [iStream setDelegate:self]; [iStream scheduleInRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode]; [iStream open]; }
上面的例子顯示,當你建立物件之後你應該設定其delegate。當把NSInputStream物件配置到一個run loop,並且有與流相關的事件(例如流中有可讀資料)發生時,該物件會收到stream:handleEvent:訊息。
在你open stream之前,給流物件傳送一個scheduleInRunLoop:forMode:訊息,來將該物件配置到一個run loop接收stream events。這樣,當流中沒有資料可讀時可以避免delegate阻塞。如果流是發生在另一個執行緒,你需要確認該流物件是配置在那個執行緒的run loop中。你不應該嘗試從一個除了包含該流物件的run loop的執行緒的其他執行緒中對流進行操作。最後,對NSInputStream物件傳送open訊息開始對輸入資料的流操作。
二,處理Stream Events
當你對一個流物件傳送open訊息之後,你可以查詢到它的當前狀態。通過下面的訊息可以知道流物件中是否有資料可讀,以及任何錯誤的屬性:
-
streamStatus
-
hasBytesAvailable
-
streamError
重要的是,一旦
open 流物件,流物件會一直向其delegate傳送stream:handleEvent:
訊息直到到達了流物件的末尾。這些訊息的引數中包含一個指示流事件型別的NSStreamEvent常量。對NSInputStream物件而言,最常用的事件型別是NSStreamEventOpenCompleted,NSStreamEventHasBytesAvailable,NSStreamEventEndEncountered。我們尤其感興趣的應該是NSStreamEventHasBytesAvailable事件。下面的例子就是一個處理NSStreamEventHasBytesAvailable事件的好的方法:
- (void)stream:(NSStream *)stream handleEvent:(NSStreamEvent)eventCode {
switch(eventCode) {
case NSStreamEventHasBytesAvailable:
{
if(!_data) {
_data = [[NSMutableData data] retain];
}
uint8_t buf[1024];
unsigned int len = 0;
len = [(NSInputStream *)stream read:buf maxLength:1024];
if(len) {
[_data appendBytes:(const void *)buf length:len];
// bytesRead is an instance variable of type NSNumber.
[bytesRead setIntValue:[bytesRead intValue]+len];
} else {
NSLog(@"no buffer!");
}
break;
}
// continued
}
stream:handleEvent: 函式使用switch語句來判別NSStreamEvent常量,當這個常量是MSStreamEventHasBytesAvailable的時候,delegate函式會lazy create 一個NSMutableData物件_data來接收讀取的資料。然後宣告一個大小為1024的uint8_t型別陣列buf,呼叫read:maxLength:函式從stream中讀取指定大小的資料到buf中,如果讀取成功,delegate將會將讀取到的資料新增到NSMutableData物件_data中,並且更新總的讀取到的資料bytesRead.
至於一次從stream中讀取多大的資料,一般來說,使用一些常用的資料大小規格,比如說512Bytes,1kB,4kB(一個頁面大小)。
三,處理stream object
當NSInputStream物件到達steam的末尾的時候,它會向stream:handleEvent:函式傳送一個NSStreamEventEndEncountered事件型別常量,delegate函式應該做出與準備使用流物件相反的操作,也就是說,需要關閉流物件,從run loop中移除,最終釋放流物件。如下面的程式碼所示:
- (void)stream:(NSStream *)stream handleEvent:(NSStreamEvent)eventCode
{
switch(eventCode) {
case NSStreamEventEndEncountered:
{
[stream close];
[stream removeFromRunLoop:[NSRunLoop currentRunLoop]
forMode:NSDefaultRunLoopMode];
[stream release];
stream = nil; // stream is ivar, so reinit it
break;
}
// continued ...
}
}
轉自:http://blog.csdn.net/caryaliu/article/details/7640197