1. 程式人生 > >[譯]ios開發之從輸入流裡讀入資料

[譯]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

返回的狀態是一個NSStreamStatus常量,它可以指示流物件是處於opening,reading,或者at the end of the stream等等。返回的錯誤是一個NSError物件,它封裝了可能發生的所有錯誤資訊。

重要的是,一旦 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