iOS監控/監測/監聽文件/文件夾的變化 檢測文件變化

ruje7454 8年前發布 | 11K 次閱讀 Kqueue iOS開發 移動開發

我們有些時候,需要監測一個文件/文件夾的變化,例如在某個文件被修改的時候,可以獲取到通知,或者我們有個播放列表是掃描某個文件夾下的所有文件,那么當這個目錄新添或者刪除一些文件后,我們的播放列表要同步更新,這種情況下,我們都需要監聽文件/文件夾的變化

碰到這樣的一個需求,首先你的反應肯定是,這還不簡單,我直接開一個定時器,每隔5s就重新掃描一下指定的文件夾/文件,這不就結了..... 其實這樣也沒有錯,只是多開了一個定時器,效率低一些而已.但還是解決了問題的,對這種方式,假如文件夾中文件很多,效率就更低了,每次重新拿到列表后,還得做字符串的匹配等等...,這種方式,我就不多說了,任何一個開發者分分鐘都可以寫出這個低效的代碼.

這是一個常見的需求,官方其實提供了兩種思路來解決這個問題

方法一

官方給出的示例demo Classes_DirectoryWatcher 大體上的思路是:

1. 根據文件/文件夾的路徑,調用open函數打開文件夾,得到文件句柄。

2. 通過kqueue()函數創建一個kqueue隊列來處理系統事件(文件創建或者刪除),得到queueId

3. 創建一個kevent結構體,設置相關屬性,連同kqueue的ID一起傳給kevent()函數,完成系統對kevent的關聯。

4. 調用CFFileDescriptorCreateRunloopSouce創建一個接收系統事件的runloop source,同時設置文件描述符的回調函數(回調函數采用C語言標準的回調函數格式), 并加到默認的runloopMode中。

5. 啟用回調函數。

6. 關閉kqueue,關閉文件夾

這樣操作后,當文件/文件夾有變化,系統會觸發相應的回調,你收到回調了,就可以進行各種處理了

其核心代碼如下:

- (void)kqueueFired
{
  int             kq;
  struct kevent   event;
  struct timespec timeout = { 0, 0 };
  int             eventCount;

  kq = CFFileDescriptorGetNativeDescriptor(self->kqref);
  assert(kq >= 0);

  eventCount = kevent(kq, NULL, 0, &event, 1, &timeout);
  assert( (eventCount >= 0) && (eventCount < 2) );

  if (self.fileChangeBlock) {
    self.fileChangeBlock(eventCount);
  }

  CFFileDescriptorEnableCallBacks(self->kqref, kCFFileDescriptorReadCallBack);
}

static void KQCallback(CFFileDescriptorRef kqRef, CFOptionFlags callBackTypes, void *info)  
{
  MonitorFileChangeUtils *helper = (MonitorFileChangeUtils *)(__bridge id)(CFTypeRef) info;
  [helper kqueueFired];
}

- (void) beginGeneratingDocumentNotificationsInPath: (NSString *) docPath
{
  int                     dirFD;
  int                     kq;
  int                     retVal;
  struct kevent           eventToAdd;
  CFFileDescriptorContext context = { 0, (void *)(__bridge CFTypeRef) self, NULL, NULL, NULL };

  dirFD = open([docPath fileSystemRepresentation], O_EVTONLY);
  assert(dirFD >= 0);

  kq = kqueue();
  assert(kq >= 0);

  eventToAdd.ident  = dirFD;
  eventToAdd.filter = EVFILT_VNODE;
  eventToAdd.flags  = EV_ADD | EV_CLEAR;
  eventToAdd.fflags = NOTE_WRITE;
  eventToAdd.data   = 0;
  eventToAdd.udata  = NULL;

  retVal = kevent(kq, &eventToAdd, 1, NULL, 0, NULL);
  assert(retVal == 0);

  self->kqref = CFFileDescriptorCreate(NULL, kq, true, KQCallback, &context);
  rls = CFFileDescriptorCreateRunLoopSource(NULL, self->kqref, 0);
  assert(rls != NULL);

  CFRunLoopAddSource(CFRunLoopGetCurrent(), rls, kCFRunLoopDefaultMode);
  CFRelease(rls);
  CFFileDescriptorEnableCallBacks(self->kqref, kCFFileDescriptorReadCallBack);
}

方法二:GCD方式

大體思路是: 首先是使用O EVTONLY模式打開文件/文件夾,然后創建一個GCD的source,當然了,其unsigned long mask參數要選VNODE系列的,例如要檢測文件的些人,可以用DISPATCH VNODE_WRITE

核心代碼:

- (void)__beginMonitoringFile
{

  _fileDescriptor = open([[_fileURL path] fileSystemRepresentation],
                         O_EVTONLY);
  dispatch_queue_t defaultQueue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);
  _source = dispatch_source_create(DISPATCH_SOURCE_TYPE_VNODE,
                                   _fileDescriptor,
                                   DISPATCH_VNODE_ATTRIB | DISPATCH_VNODE_DELETE | DISPATCH_VNODE_EXTEND | DISPATCH_VNODE_LINK | DISPATCH_VNODE_RENAME | DISPATCH_VNODE_REVOKE | DISPATCH_VNODE_WRITE,
                                   defaultQueue);        
  dispatch_source_set_event_handler(_source, ^ {
    unsigned long eventTypes = dispatch_source_get_data(_source);
    [self __alertDelegateOfEvents:eventTypes];
  });

  dispatch_source_set_cancel_handler(_source, ^{
    close(_fileDescriptor);
    _fileDescriptor = 0;
    _source = nil;

    // If this dispatch source was canceled because of a rename or delete notification, recreate it
    if (_keepMonitoringFile) {
        _keepMonitoringFile = NO;
        [self __beginMonitoringFile];
    }
  });
  dispatch_resume(_source);
}

參考文檔

handling-filesystem-events-with-gcd Monitoring-Files-With-GCD-Being-Edited-With-A-Text-Editor gcd-zhi-jian-ting-wen-jian GCDWorkQueues iMonitorMyFiles

 

 

 本文由用戶 ruje7454 自行上傳分享,僅供網友學習交流。所有權歸原作者,若您的權利被侵害,請聯系管理員。
 轉載本站原創文章,請注明出處,并保留原始鏈接、圖片水印。
 本站是一個以用戶分享為主的開源技術平臺,歡迎各類分享!