Java利用WatchService监听文件变化示例

Java利用WatchService监听文件变化示例

在实现配置中心的多种方案中，有基于JDK7+的WatchService方法，其在单机应用中还是挺有实践的意义的。

代码如下：

package com.longge.mytest;

import java.io.IOException;

import java.nio.file.FileSystems;

import java.nio.file.Path;

import java.nio.file.Paths;

import java.nio.http://file.StandardWatchEventKinds;

import java.nio.file.WatchEvent;

import java.nio.file.WatchKey;

import java.nio.file.WatchService;

import java.util.List;

/**

* 测试JDK的WatchService监听文件变化

* @author yangzhilong

*

*/

public class TestWatchService {

public static void main(String[] args) throws IOException {

// 需要监听的文件目录（只能监听目录）

String path = "d:/test";

WatchService watchService = FileSystems.getDefault().newWatchService();

Path p = Paths.get(path);

p.register(watchService, StandardWatchEventKinds.ENTRY_MODIFY,

StandardWatchEventKinds.ENTRY_DELETE,

StandardWatchEventKinds.ENTRY_CREATE);

Thread thread = new Thread(() -> {

try {

while(true){

WatchKey watchKey = watchService.take();

List> watchEvents = watchKey.pollEvents();

for(WatchEvent> event : watchEvents){

//TODO 根据事件类型采取不同的操作。。。。。。。

System.out.println("["+path+"/"+event.context()+"]文件发生了["+event.kind()+"]事件");

}

watchKey.reset();

}

} catch (InterruptedException e) {

e.printStackTrace();

}

});

thread.setDaemon(false);

thread.start();

// 增加jvm关闭的钩子来关闭监听

Runtime.getRuntime().addShutdownHook(new Thread(() -> {

try {

watchService.close();

} catch (Exception e) {

}

}));

}

}

运行示例结果类似如下：

[d:/test/1.txt]文件发生了[ENTRY_MODIFY]事件

[d:/test/1.txt]文件发生了[ENTRY_DELETE]事件

[d:/test/新建文本文档.txt]文件发生了[ENTRY_CREATE]事件

[d:/test/新建文本文档.txt]文件发生了[ENTRY_DELETE]事件

[d:/test/222.txt]文件发生了[ENTRY_CREATE]事件

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。