这篇文章给大家介绍使用java怎么实时监控文件的行尾内容,内容非常详细,感兴趣的小伙伴们可以参考借鉴,希望对大家能有所帮助。
耿马网站建设公司创新互联建站,耿马网站设计制作,有大型网站制作公司丰富经验。已为耿马近千家提供企业网站建设服务。企业网站搭建\外贸网站制作要多少钱,请找那个售后服务好的耿马做网站的公司定做!
1.WatchService
首先介绍一下WatchService类,WatchService可以监控某一个目录下的文件的变动(新增,修改,删除)并以事件的形式通知文件的变更,这里我们可以实时的获取到文件的修改事件,然后计算出追加的内容,Talk is cheap,Show me the code.
Listener
简单的接口,只有一个fire方法,当事件发生时处理事件。
public interface Listener { /** * 发生文件变动事件时的处理逻辑 * * @param event */ void fire(FileChangeEvent event); }
FileChangeListener
Listener接口的实现类,处理文件变更事件。
public class FileChangeListener implements Listener { /** * 保存路径跟文件包装类的映射 */ private final Mapmap = 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) { // 根据全路径获取包装类对象 FileWrapper wrapper = map.get(path.toString()); if (wrapper == null) { wrapper = new FileWrapper(path.toFile()); map.put(path.toString(), wrapper); } try { // 读取追加的内容 new ContentReader(wrapper).read(); } catch (IOException e) { e.printStackTrace(); } } }
FileWrapper
文件包装类,包含文件和当前读取的行号
public class FileWrapper { /** * 当前文件读取的行数 */ private int currentLine; /** * 监听的文件 */ 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
内容读取类
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()))) { Listcontents = lineReader.lines().collect(Collectors.toList()); if (contents.size() > wrapper.getCurrentLine()) { for (int i = wrapper.getCurrentLine(); i < contents.size(); i++) { // 这里只是简单打印出新加的内容到控制台 System.out.println(contents.get(i)); } } // 保存当前读取到的行数 wrapper.setCurrentLine(contents.size()); } } }
DirectoryTargetMonitor
目录监视器,监控目录下文件的变化
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(); // 注册变更事件到WatchService this.path.register(watchService, StandardWatchEventKinds.ENTRY_MODIFY); this.start = true; while (start) { WatchKey watchKey = null; try { // 阻塞直到有事件发生 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); } }
测试类
在D盘新建一个monitor文件夹, 新建一个test.txt文件,然后启动程序,程序启动完成后,我们尝试往test.txt添加内容然后保存,控制台会实时的输出我们追加的内容,PS:追加的内容要以新起一行的形式追加,如果只是在原来的尾行追加,本程序不会输出到控制台,有兴趣的同学可以扩展一下
public static void main(String[] args) throws IOException { DirectoryTargetMonitor monitor = new DirectoryTargetMonitor(new FileChangeListener(), "D:\\monitor"); monitor.startMonitor(); }
关于使用java怎么实时监控文件的行尾内容就分享到这里了,希望以上内容可以对大家有一定的帮助,可以学到更多知识。如果觉得文章不错,可以把它分享出去让更多的人看到。