【轉】iphone 輸入/輸出流異步讀寫數據

時間  2019-11-12
標籤 iphone 輸入 輸出 異步 讀寫 數據 欄目 iPhone 简体版
原文   原文鏈接
 

原文：iphone 輸入/輸出流異步讀寫數據

分類： iphone2012-05-30 14:50 2484人閱讀 評論(1) 收藏 舉報
iphone attributes interface path stream file

一、首先是往文件裏寫入數據app

WriteFile.hiphone

 

[cpp]  view plain copy
  1. #import <Foundation/Foundation.h>  
  2. #import <UIKit/UIKit.h>  
  3. @class NoteDb;  
  4. @interface WriteFile : NSObject<NSStreamDelegate>{  
  5.     //文件地址  
  6.     NSString *parentDirectoryPath;  
  7.     //輸出流，寫數據  
  8.     NSOutputStream *asyncOutputStream;  
  9.     //寫數據的內容  
  10.     NSData *outputData;  
  11.     //位置及長度  
  12.     NSRange outputRange;  
  13.     //數據的來源  
  14.     NoteDb *aNoteDb;  
  15. }  
  16. @property (nonatomic,retain) NSData *outputData;  
  17. @property (nonatomic,retain) NoteDb *aNoteDb;  
  18. //寫數據  
  19. -(void)write;  
  20. @end  

實現文件WriteFile.m

 

 

[cpp]  view plain copy
  1. #import "WriteFile.h"  
  2. #import "NoteDb.h"  
  3. @implementation WriteFile  
  4. @synthesize outputData,aNoteDb;  
  5.   
  6. -(id)init{  
  7.     self=[super init];  
  8.     if (!self) {  
  9.         [self release];  
  10.         return nil;  
  11.     }  
  12.     outputData=[[NSData alloc]init];  
  13.     aNoteDb=[[NoteDb alloc]init];  
  14.     return self;  
  15. }  
  16. -(void)write{  
  17.     //NSLog(@"%@",self.aNoteDb);  
  18.     //沙盒路徑  
  19.     NSArray *paths= NSSearchPathForDirectoriesInDomains(NSDocumentDirectory, NSUserDomainMask, YES);  
  20.     NSString *documentsDirectory = [paths objectAtIndex:0];  
  21.     //文件名字是note.txt  
  22.     NSString *path = [documentsDirectory stringByAppendingPathComponent:@"note.txt"];  
  23.       
  24.     [asyncOutputStream release];  
  25.     parentDirectoryPath = path;  
  26.     //數據源  
  27.     NSData *tmpdata = [NSKeyedArchiver archivedDataWithRootObject:self.aNoteDb.noteList];  
  28.       
  29.     //self.outputData=[[NSData alloc]initWithData:tmpdata];  
  30.     self.outputData=tmpdata;  
  31.     //位置從哪開始  
  32.     outputRange.location=0;  
  33.     //建立文件  
  34.     [[NSFileManager defaultManager] createFileAtPath:parentDirectoryPath  
  35.                                             contents:nil attributes:nil];  
  36.     //初始化輸出流  
  37.     asyncOutputStream = [[NSOutputStream alloc] initToFileAtPath: parentDirectoryPath append: NO];  
  38.     //回調方法，  
  39.     [asyncOutputStream setDelegate: self];   
  40.     //異步處理，  
  41.     [asyncOutputStream scheduleInRunLoop:[NSRunLoop currentRunLoop]  forMode:NSDefaultRunLoopMode];  
  42.     //打開異步輸出流  
  43.     [asyncOutputStream open];   
  44.       
  45.       
  46. }  
  47. -(void)stream:(NSStream *)theStream handleEvent:(NSStreamEvent)streamEvent{  
  48.    // NSLog(@"as");  
  49.     NSOutputStream *outputStream = (NSOutputStream*) theStream;  
  50.     BOOL shouldClose = NO;  
  51.     switch (streamEvent)   
  52.     {  
  53.         case NSStreamEventHasSpaceAvailable://讀事件   
  54.         {  
  55.             //緩衝區  
  56.             uint8_t outputBuf [1];  
  57.             //長度  
  58.             outputRange.length = 1;  
  59.             //把數據放到緩衝區中  
  60.             [outputData getBytes:&outputBuf range:outputRange];   
  61.             //把緩衝區中的東西放到輸出流  
  62.             [outputStream write: outputBuf maxLength: 1];   
  63.             //判斷data數據是否讀完  
  64.             if (++outputRange.location == [outputData length])   
  65.             {    
  66.                 shouldClose = YES;  
  67.             }  
  68.             break;  
  69.         }  
  70.         case NSStreamEventErrorOccurred:  
  71.         {  
  72.             //出錯的時候  
  73.             NSError *error = [theStream streamError];  
  74.             if (error != NULL)   
  75.             {  
  76.                 UIAlertView *errorAlert = [[UIAlertView alloc]  
  77.                                            initWithTitle: [error localizedDescription]  
  78.                                            message: [error localizedFailureReason]  
  79.                                            delegate:nil  
  80.                                            cancelButtonTitle:@"OK"  
  81.                                            otherButtonTitles:nil];  
  82.                 [errorAlert show];  
  83.                 [errorAlert release];  
  84.             }  
  85.             shouldClose = YES;  
  86.             break;  
  87.         }  
  88.         case NSStreamEventEndEncountered:  
  89.             shouldClose = YES;  
  90.     }  
  91.     if (shouldClose)  
  92.     {  
  93.         //當出錯或者寫完數據，把線程移除  
  94.         [outputStream removeFromRunLoop: [NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode];  
  95.         //最後關掉輸出流  
  96.         [theStream close];   
  97.     }  
  98.   
  99. }  
  100. -(void)dealloc{  
  101.     [outputData release];  
  102.     [aNoteDb release];  
  103.     [super dealloc];  
  104. }  
  105. @end  

二、其次是從文件裏讀出數據

 

ReadFile.h異步

 

[cpp]  view plain copy
  1. #import <Foundation/Foundation.h>  
  2. @class NoteDb;  
  3. @interface ReadFile : NSObject<NSStreamDelegate>{  
  4.     //路徑  
  5.     NSString *parentDirectoryPath;  
  6.     //異步輸出流  
  7.     NSInputStream *asyncInputStream;  
  8.     //讀出來的數據  
  9.     NSMutableData *resultData;  
  10.     //返回去的數據  
  11.     NoteDb *aNoteDb;  
  12. }  
  13. @property(nonatomic,retain)NoteDb *aNoteDb;  
  14. @property (nonatomic, retain) NSMutableData *resultData;  
  15. //開始讀數據  
  16. -(void)read;  
  17. //讀出來的數據追加到resultData上  
  18. - (void)appendData:(NSData*)_data;  
  19. //  
  20. - (void)dataAtNoteDB;  
  21. //返回去的數據  
  22. - (NoteDb*)getNoteDb;  
  23. @end  

實現文件ReadFile.m

 

 

[cpp]  view plain copy
  1. #import "ReadFile.h"  
  2. #import "NoteDb.h"  
  3. #import "NoteList.h"  
  4. #import "WriteFile.h"  
  5. @implementation ReadFile  
  6. @synthesize aNoteDb,resultData;  
  7. -(id)init{  
  8.     self=[super init];  
  9.     //aNoteDb=[[NoteDb alloc]init];  
  10.     resultData=[[NSMutableData alloc]init];  
  11.     return self;  
  12. }  
  13. -(void)read{  
  14.     //沙盒路徑  
  15.     NSArray *paths= NSSearchPathForDirectoriesInDomains(NSDocumentDirectory, NSUserDomainMask, YES);  
  16.     NSString *documentsDirectory = [paths objectAtIndex:0];  
  17.     //文件名  
  18.     NSString *path = [documentsDirectory stringByAppendingPathComponent:@"note.txt"];  
  19.     /* 
  20.     if(![[NSFileManager defaultManager]fileExistsAtPath:path]){ 
  21.         //若是不存在，就新建 
  22.         WriteFile *file=[[WriteFile alloc]init]; 
  23.         [file write]; 
  24.         [file release];         
  25.     }else{ 
  26.         NSLog(@"有note.txt文件"); 
  27.     } 
  28.     */  
  29.     [asyncInputStream release];  
  30.     parentDirectoryPath = path;  
  31.     //異步輸入流初始化，並把賦於地址  
  32.     asyncInputStream =  
  33.     [[NSInputStream alloc] initWithFileAtPath: parentDirectoryPath];  
  34.     //設置代理（回調方法、委託）  
  35.     [asyncInputStream setDelegate: self];  
  36.     //設置線程，添加線程，建立線程：Runloop顧名思義就是一個不停的循環，不斷的去check輸入  
  37.     [asyncInputStream scheduleInRunLoop:[NSRunLoop currentRunLoop]  
  38.                                 forMode:NSDefaultRunLoopMode];  
  39.     //打開線程  
  40.     [asyncInputStream open];  
  41.   
  42. }  
  43. //追加數據  
  44. - (void)appendData:(NSData*)_data{  
  45.     [resultData appendData:_data];  
  46. }  
  47. //回調方法，不停的執行  
  48. -(void)stream:(NSStream *)theStream handleEvent:(NSStreamEvent)streamEvent{  
  49.     BOOL shouldClose = NO;  
  50.     NSInputStream *inputStream = (NSInputStream*) theStream;  
  51.      //NSLog(@"as");  
  52.     switch (streamEvent)   
  53.     {  
  54.         case NSStreamEventHasBytesAvailable:   
  55.         {         
  56.             //讀數據  
  57.             //讀取的字節長度  
  58.             NSInteger maxLength = 128;   
  59.             //緩衝區  
  60.             uint8_t readBuffer [maxLength];   
  61.             //從輸出流中讀取數據，讀到緩衝區中  
  62.             NSInteger bytesRead = [inputStream read: readBuffer   
  63.                                           maxLength:maxLength];  
  64.             //若是長度大於0就追加數據  
  65.             if (bytesRead > 0)   
  66.             {  
  67.                 //把緩衝區中的數據讀成data數據   
  68.                 NSData *bufferData = [[NSData alloc]  
  69.                                       initWithBytesNoCopy:readBuffer   
  70.                                       length:bytesRead   
  71.                                       freeWhenDone:NO];  
  72.                 //追加數據  
  73.                 [self appendData:bufferData];  
  74.                 //release掉data  
  75.                 [bufferData release];  
  76.             }  
  77.             break;  
  78.         }   
  79.         case NSStreamEventErrorOccurred:   
  80.         {  
  81.             //讀的時候出錯了  
  82.             NSError *error = [theStream streamError];  
  83.             if (error != NULL)   
  84.             {  
  85.                 UIAlertView *errorAlert = [[UIAlertView alloc]  
  86.                                            initWithTitle: [error localizedDescription]  
  87.                                            message: [error localizedFailureReason]  
  88.                                            delegate:nil  
  89.                                            cancelButtonTitle:@"OK"  
  90.                                            otherButtonTitles:nil];  
  91.                 [errorAlert show];  
  92.                 [errorAlert release];  
  93.             }  
  94.             shouldClose = YES;  
  95.             break;  
  96.         }  
  97.         case NSStreamEventEndEncountered:   
  98.         {  
  99.             shouldClose = YES;  
  100.             //數據讀完就返回數據  
  101.             [self dataAtNoteDB];              
  102.             [theStream close];  
  103.         }break;  
  104.     }  
  105.     if (shouldClose)  
  106.     {  
  107.         //當文件讀完或者是讀到出錯時，把線程移除  
  108.         [inputStream removeFromRunLoop: [NSRunLoop currentRunLoop]   
  109.                                forMode:NSDefaultRunLoopMode];  
  110.         //並關閉流  
  111.         [theStream close];   
  112.     }  
  113. }  
  114. -(void) dataAtNoteDB{  
  115.     aNoteDb=nil;  
  116.     aNoteDb=[[NoteDb alloc]init];  
  117.     aNoteDb.noteList = [NSKeyedUnarchiver unarchiveObjectWithData:resultData];  
  118.     //NSLog(@"%@",aNoteDb);  
  119.     /* 
  120.     for (id tmp in  aNoteDb.noteList.noteArray)  
  121.     { 
  122.         NSLog(@"tmp = %@",tmp); 
  123.     } 
  124.      */  
  125. }  
  126. - (NoteDb*)getNoteDb{  
  127.     return self.aNoteDb;  
  128. }  
  129. -(void)dealloc{  
  130.     [aNoteDb release];  
  131.     [resultData release];  
  132.     [super dealloc];  
  133. }  
  134. @end  
相關文章
相關標籤/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公眾號
   歡迎關注本站公眾號,獲取更多信息
聯繫我們 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程