java中怎么實(shí)時(shí)監(jiān)控文件行尾內(nèi)容

本篇文章為大家展示了java中怎么實(shí)時(shí)監(jiān)控文件行尾內(nèi)容，內(nèi)容簡(jiǎn)明扼要并且容易理解，絕對(duì)能使你眼前一亮，通過(guò)這篇文章的詳細(xì)介紹希望你能有所收獲。

1.WatchService

首先介紹一下WatchService類，WatchService可以監(jiān)控某一個(gè)目錄下的文件的變動(dòng)(新增，修改，刪除)并以事件的形式通知文件的變更,這里我們可以實(shí)時(shí)的獲取到文件的修改事件，然后計(jì)算出追加的內(nèi)容，Talk is cheap,Show me the code.

Listener

簡(jiǎn)單的接口，只有一個(gè)fire方法，當(dāng)事件發(fā)生時(shí)處理事件。

public interface Listener {  /**   * 發(fā)生文件變動(dòng)事件時(shí)的處理邏輯   *    * @param event   */  void fire(FileChangeEvent event);}

FileChangeListener

Listener接口的實(shí)現(xiàn)類，處理文件變更事件。

public class FileChangeListener implements Listener {  /**   * 保存路徑跟文件包裝類的映射   */  private final Map<String, FileWrapper> map = new ConcurrentHashMap<>();  public void fire(FileChangeEvent event) {    switch (event.getKind().name()) {    case "ENTRY_MODIFY":      // 文件修改事件      modify(event.getPath());      break;    default:      throw new UnsupportedOperationException(          String.format("The kind [%s] is unsupport.", event.getKind().name()));    }  }  private void modify(Path path) {    // 根據(jù)全路徑獲取包裝類對(duì)象    FileWrapper wrapper = map.get(path.toString());    if (wrapper == null) {      wrapper = new FileWrapper(path.toFile());      map.put(path.toString(), wrapper);    }    try {      // 讀取追加的內(nèi)容      new ContentReader(wrapper).read();    } catch (IOException e) {      e.printStackTrace();    }  }}

FileWrapper

文件包裝類，包含文件和當(dāng)前讀取的行號(hào)

public class FileWrapper {  /**   * 當(dāng)前文件讀取的行數(shù)   */  private int currentLine;  /**   * 監(jiān)聽的文件   */  private final File file;  public FileWrapper(File file) {    this(file, 0);  }  public FileWrapper(File file, int currentLine) {    this.file = file;    this.currentLine = currentLine;  }  public int getCurrentLine() {    return currentLine;  }  public void setCurrentLine(int currentLine) {    this.currentLine = currentLine;  }  public File getFile() {    return file;  }}

FileChangeEvent

文件變更事件

public class FileChangeEvent {  /**   * 文件全路徑   */  private final Path path;  /**   * 事件類型   */  private final WatchEvent.Kind<?> kind;  public FileChangeEvent(Path path, Kind<?> kind) {    this.path = path;    this.kind = kind;  }  public Path getPath() {    return this.path;  }  public WatchEvent.Kind<?> getKind() {    return this.kind;  }}

ContentReader

內(nèi)容讀取類

public class ContentReader {  private final FileWrapper wrapper;  public ContentReader(FileWrapper wrapper) {    this.wrapper = wrapper;  }  public void read() throws FileNotFoundException, IOException {    try (LineNumberReader lineReader = new LineNumberReader(new FileReader(wrapper.getFile()))) {      List<String> contents = lineReader.lines().collect(Collectors.toList());      if (contents.size() > wrapper.getCurrentLine()) {        for (int i = wrapper.getCurrentLine(); i < contents.size(); i++) {          // 這里只是簡(jiǎn)單打印出新加的內(nèi)容到控制臺(tái)          System.out.println(contents.get(i));        }      }      // 保存當(dāng)前讀取到的行數(shù)      wrapper.setCurrentLine(contents.size());    }  }}

DirectoryTargetMonitor

目錄監(jiān)視器，監(jiān)控目錄下文件的變化

public class DirectoryTargetMonitor {  private WatchService watchService;  private final FileChangeListener listener;  private final Path path;  private volatile boolean start = false;  public DirectoryTargetMonitor(final FileChangeListener listener, final String targetPath) {    this(listener, targetPath, "");  }  public DirectoryTargetMonitor(final FileChangeListener listener, final String targetPath, final String... morePaths) {    this.listener = listener;    this.path = Paths.get(targetPath, morePaths);  }  public void startMonitor() throws IOException {    this.watchService = FileSystems.getDefault().newWatchService();    // 注冊(cè)變更事件到WatchService    this.path.register(watchService, StandardWatchEventKinds.ENTRY_MODIFY);    this.start = true;    while (start) {      WatchKey watchKey = null;      try {        // 阻塞直到有事件發(fā)生        watchKey = watchService.take();        watchKey.pollEvents().forEach(event -> {          WatchEvent.Kind<?> kind = event.kind();          Path path = (Path) event.context();          Path child = this.path.resolve(path);          listener.fire(new FileChangeEvent(child, kind));        });      } catch (Exception e) {        this.start = false;      } finally {        if (watchKey != null) {          watchKey.reset();        }      }    }  }  public void stopMonitor() throws IOException {    System.out.printf("The directory [%s] monitor will be stop ...\n", path);    Thread.currentThread().interrupt();    this.start = false;    this.watchService.close();    System.out.printf("The directory [%s] monitor will be stop done.\n", path);  }}

測(cè)試類

在D盤新建一個(gè)monitor文件夾, 新建一個(gè)test.txt文件,然后啟動(dòng)程序,程序啟動(dòng)完成后,我們嘗試往test.txt添加內(nèi)容然后保存，控制臺(tái)會(huì)實(shí)時(shí)的輸出我們追加的內(nèi)容,PS：追加的內(nèi)容要以新起一行的形式追加，如果只是在原來(lái)的尾行追加，本程序不會(huì)輸出到控制臺(tái)，有興趣的同學(xué)可以擴(kuò)展一下

public static void main(String[] args) throws IOException {    DirectoryTargetMonitor monitor = new DirectoryTargetMonitor(new FileChangeListener(), "D:\\monitor");    monitor.startMonitor();  }

上述內(nèi)容就是java中怎么實(shí)時(shí)監(jiān)控文件行尾內(nèi)容，你們學(xué)到知識(shí)或技能了嗎？如果還想學(xué)到更多技能或者豐富自己的知識(shí)儲(chǔ)備，歡迎關(guān)注億速云行業(yè)資訊頻道。