Java使用WatchService监控文件内容变化的示例
作者:Chown 时间:2023-02-15 10:10:19
场景
系统实现中经常需要能够感知配置文件的变化,然后及时更新上下文。
实现方案
自己起一个单独线程,定时加载文件,实现较简单,但是无法保证能够实时捕捉文件变化,同时耗CPU
使用commons-io中的 FileAlterationObserver,思想和上面类似,对比前后文件列表的变化,触发对应事件
JDK 1.7提供的WatchService,利用底层文件系统提供的功能
使用 WatchService
WatchService用来监控一个目录是否发生改变,但是可以通过 WatchEvent 上下文定位具体文件的变化。具体使用过程中要注意以下两点:
文件改变可能会触发两次事件(我的理解:文件内容的变更,元数据的变更),可以通过文件的时间戳来控制
在文件变化事件发生后,如果立即读取文件,可能所获内容并不完整,建议的做法判断文件的 length > 0
// 监控文件的变化,重新加载
executor.submit(new Runnable() {
@Override
public void run() {
try {
final Path path = FileSystems.getDefault().getPath(getMonitorDir());
System.out.println(path);
final WatchService watchService = FileSystems.getDefault().newWatchService();
final WatchKey watchKey = path.register(watchService, StandardWatchEventKinds.ENTRY_MODIFY);
while (true) {
final WatchKey wk = watchService.take();
for (WatchEvent<?> event : wk.pollEvents()) {
final Path changed = (Path) event.context();
Path absolute = path.resolve(changed);
File configFile = absolute.toFile();
long lastModified = configFile.lastModified();
logger.info(lastModified + "----------------");
// 利用文件时间戳,防止触发两次
if (changed.endsWith(getLicenseName()) && lastModified != LAST_MOD && configFile.length > 0) {
logger.info("----------------- reloading -----------------");
LAST_MOD = lastModified; // 保存上一次时间戳
UPDATED = true; // 设置标志位
}
}
if (UPDATED) {
reloadFile(); // 重新加载
}
// reset the key
boolean valid = wk.reset();
if (!valid) {
logger.error("watch key invalid!");
}
}
} catch (Exception e) {
logger.error("");
}
}
});
参考
Watching a Directory for Changes
来源:https://zhuanlan.zhihu.com/p/29089171
标签:java,监控,文件
0
投稿
猜你喜欢
快速解决设置Android 23.0以上版本对SD卡的读写权限无效的问题
2021-08-26 09:31:43
解析spring事务管理@Transactional为什么要添加rollbackFor=Exception.class
2021-09-03 17:07:41
Android实现极简打开摄像头
2022-09-10 15:56:51
Mybatis Plus中的流式查询案例
2023-08-18 16:35:13
java开发微信分享接口的步骤
2021-08-22 12:30:59
关于Springboot+gateway整合依赖并处理依赖冲突问题
2023-10-23 21:13:56
使用 CliWrap 让C#中的命令行交互(推荐)
2023-04-19 01:31:51
java 多线程死锁详解及简单实例
2022-02-25 19:48:52
IntelliJ IDEA引入第三方jar包或查看Java源码的时候报decompiled.class file bytecode version:52.0(java 8)错误的解决办法
2022-11-24 12:50:16
JAVA发送HTTP请求的四种方式总结
2023-08-23 20:27:23
MyBatis-plus中的模糊查询解读
2022-06-16 08:27:03
Java中Map实现线程安全的3种方式
2021-10-07 21:23:36
jar包手动添加到本地maven仓库的步骤详解
2023-11-23 05:09:37
C#用Activex实现Web客户端读取RFID功能的代码
2021-10-28 21:07:36
使用IDEA搭建SSM框架的详细教程(spring + springMVC +MyBatis)
2023-04-24 07:35:45
Android控件之CheckBox、RadioButton用法实例分析
2021-06-01 06:31:26
SpringBoot中使用Servlet三大组件的方法(Servlet、Filter、Listener)
2021-07-19 18:41:43
Java SpringCache+Redis缓存数据详解
2023-11-29 01:01:05
获取控件大小和设置调整控件的位置XY示例
2022-06-06 04:40:25
Android Webview滑进出屏幕闪烁的解决方法
2021-11-30 11:57:33