public class FileWatchDemo {
?
 /**
  * 上次更新時間
  */
 public static long LAST_TIME = 0L;
?
 public static void main(String[] args) throws IOException {
?
  String fileName = "/Users/zzs/temp/1.txt";
  // 創(chuàng)建文件，僅為實例，實踐中由其他程序觸發(fā)文件的變更
  createFile(fileName);
?
  // 執(zhí)行2次
  for (int i = 0; i < 2; i++) {
   long timestamp = readLastModified(fileName);
   if (timestamp != LAST_TIME) {
    System.out.println("文件已被更新：" + timestamp);
    LAST_TIME = timestamp;
    // 重新加載，文件內(nèi)容
   } else {
    System.out.println("文件未更新");
   }
  }
 }
?
 public static void createFile(String fileName) throws IOException {
  File file = new File(fileName);
  if (!file.exists()) {
   boolean result = file.createNewFile();
   System.out.println("創(chuàng)建文件：" + result);
  }
 }
?
 public static long readLastModified(String fileName) {
  File file = new File(fileName);
  return file.lastModified();
 }
}

public class WatchServiceDemo {
  public static void main(String[] args) throws IOException {
    // 這里的監(jiān)聽必須是目錄
    Path path = Paths.get("/Users/zzs/temp/");
    // 創(chuàng)建WatchService，它是對操作系統(tǒng)的文件監(jiān)視器的封裝，相對之前，不需要遍歷文件目錄，效率要高很多
    WatchService watcher = FileSystems.getDefault().newWatchService();
    // 注冊指定目錄使用的監(jiān)聽器，監(jiān)視目錄下文件的變化；
    // PS：Path必須是目錄，不能是文件；
    // StandardWatchEventKinds.ENTRY_MODIFY，表示監(jiān)視文件的修改事件
    path.register(watcher, StandardWatchEventKinds.ENTRY_MODIFY);
?
    // 創(chuàng)建一個線程，等待目錄下的文件發(fā)生變化
    try {
      while (true) {
        // 獲取目錄的變化:
        // take()是一個阻塞方法，會等待監(jiān)視器發(fā)出的信號才返回。
        // 還可以使用watcher.poll()方法，非阻塞方法，會立即返回當(dāng)時監(jiān)視器中是否有信號。
        // 返回結(jié)果WatchKey，是一個單例對象，與前面的register方法返回的實例是同一個；
        WatchKey key = watcher.take();
        // 處理文件變化事件：
        // key.pollEvents()用于獲取文件變化事件，只能獲取一次，不能重復(fù)獲取，類似隊列的形式。
        for (WatchEvent<?> event : key.pollEvents()) {
          // event.kind()：事件類型
          if (event.kind() == StandardWatchEventKinds.OVERFLOW) {
            //事件可能lost or discarded
            continue;
          }
          // 返回觸發(fā)事件的文件或目錄的路徑（相對路徑）
          Path fileName = (Path) event.context();
          System.out.println("文件更新: " + fileName);
        }
        // 每次調(diào)用WatchService的take()或poll()方法時需要通過本方法重置
        if (!key.reset()) {
          break;
        }
      }
    } catch (Exception e) {
      e.printStackTrace();
    }
  }
}
復(fù)制代碼

PollingWatchService() {
 ? ? ?  // TBD: Make the number of threads configurable
 ? ? ?  scheduledExecutor = Executors
 ? ? ? ? ?  .newSingleThreadScheduledExecutor(new ThreadFactory() {
 ? ? ? ? ? ? ? ? @Override
 ? ? ? ? ? ? ? ? public Thread newThread(Runnable r) {
 ? ? ? ? ? ? ? ? ? ? Thread t = new Thread(null, r, "FileSystemWatcher", 0, false);
 ? ? ? ? ? ? ? ? ? ? t.setDaemon(true);
 ? ? ? ? ? ? ? ? ? ? return t;
 ? ? ? ? ? ? ? ? }});
 ?  }

void enable(Set<? extends Kind<?>> var1, long var2) {
 ? ? ? ? ?  synchronized(this) {
 ? ? ? ? ? ? ?  this.events = var1;
 ? ? ? ? ? ? ?  Runnable var5 = new Runnable() {
 ? ? ? ? ? ? ? ? ?  public void run() {
 ? ? ? ? ? ? ? ? ? ? ?  PollingWatchKey.this.poll();
 ? ? ? ? ? ? ? ? ?  }
 ? ? ? ? ? ? ?  };
 ? ? ? ? ? ? ?  this.poller = PollingWatchService.this.scheduledExecutor.scheduleAtFixedRate(var5, var2, var2, TimeUnit.SECONDS);
 ? ? ? ? ?  }
 ? ? ?  }

public enum SensitivityWatchEventModifier implements Modifier {
 ?  HIGH(2),
 ?  MEDIUM(10),
 ?  LOW(30);
    // ...
}

path.register(watcher, new WatchEvent.Kind[]{StandardWatchEventKinds.ENTRY_MODIFY},
        SensitivityWatchEventModifier.HIGH);

<dependency>
  <groupId>commons-io</groupId>
  <artifactId>commons-io</artifactId>
  <version>2.7</version>
</dependency>

public class FileListener extends FileAlterationListenerAdaptor {
?
  @Override
  public void onStart(FileAlterationObserver observer) {
    super.onStart(observer);
    System.out.println("onStart");
  }
?
  @Override
  public void onDirectoryCreate(File directory) {
    System.out.println("新建：" + directory.getAbsolutePath());
  }
?
  @Override
  public void onDirectoryChange(File directory) {
    System.out.println("修改：" + directory.getAbsolutePath());
  }
?
  @Override
  public void onDirectoryDelete(File directory) {
    System.out.println("刪除：" + directory.getAbsolutePath());
  }
?
  @Override
  public void onFileCreate(File file) {
    String compressedPath = file.getAbsolutePath();
    System.out.println("新建：" + compressedPath);
    if (file.canRead()) {
      // TODO 讀取或重新加載文件內(nèi)容
      System.out.println("文件變更，進(jìn)行處理");
    }
  }
?
  @Override
  public void onFileChange(File file) {
    String compressedPath = file.getAbsolutePath();
    System.out.println("修改：" + compressedPath);
  }
?
  @Override
  public void onFileDelete(File file) {
    System.out.println("刪除：" + file.getAbsolutePath());
  }
?
  @Override
  public void onStop(FileAlterationObserver observer) {
    super.onStop(observer);
    System.out.println("onStop");
  }
}

public class FileMonitor {
  private FileAlterationMonitor monitor;
?
  public FileMonitor(long interval) {
    monitor = new FileAlterationMonitor(interval);
  }
  /**
   * 給文件添加監(jiān)聽
   *
   * @param path ? ? 文件路徑
   * @param listener 文件監(jiān)聽器
   */
  public void monitor(String path, FileAlterationListener listener) {
    FileAlterationObserver observer = new FileAlterationObserver(new File(path));
    monitor.addObserver(observer);
    observer.addListener(listener);
  }
?
  public void stop() throws Exception {
    monitor.stop();
  }
?
  public void start() throws Exception {
    monitor.start();
?
  }
}

public class FileRunner {
?
  public static void main(String[] args) throws Exception {
    FileMonitor fileMonitor = new FileMonitor(1000);
    fileMonitor.monitor("/Users/zzs/temp/", new FileListener());
    fileMonitor.start();
  }
}

public FileAlterationObserver(String directoryName, FileFilter fileFilter, IOCase caseSensitivity) {
 ?  this(new File(directoryName), fileFilter, caseSensitivity);
}