13518219792
本篇文章为大家展示了java中怎么实时监控文件行尾内容，内容简明扼要并且容易理解，绝对能使你眼前一亮，通过这篇文章的详细介绍希望你能有所收获。
成都创新互联一直秉承“诚信做人，踏实做事”的原则，不欺瞒客户，是我们最起码的底线！ 以服务为基础，以质量求生存，以技术求发展，成交一个客户多一个朋友！为您提供网站制作、成都网站建设、成都网页设计、微信小程序、成都网站开发、成都网站制作、成都软件开发、重庆APP软件开发是成都本地专业的网站建设和网站设计公司，等你一起来见证！
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 Map
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()))) { List
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中怎么实时监控文件行尾内容，你们学到知识或技能了吗？如果还想学到更多技能或者丰富自己的知识储备，欢迎关注创新互联行业资讯频道。
