小师妹学JavaIO之:文件系统和WatchService
文章目录
- 简介
- 监控的痛点
- WatchService和文件系统
- WatchSerice的使用和实现本质
- 总结
简介
小师妹这次遇到了监控文件变化的问题，F师兄给小师妹介绍了JDK7 nio中引入的WatchService，没想到又顺道普及了一下文件系统的概念，万万没想到。
监控的痛点
小师妹：F师兄最近你有没有感觉到呼吸有点困难，后领有点凉飕飕的，说话有点不顺畅的那种？
没有啊小师妹，你是不是秋衣穿反了？
小师妹：不是的F师兄，我讲的是心里的感觉，那种莫须有的压力，还有一丝悸动缠绕在心。
别绕弯子了小师妹，是不是又遇到问题了。
更多精彩内容且看：
- 区块链从入门到放弃系列教程-涵盖密码学,超级账本,以太坊,Libra,比特币等持续更新
- Spring Boot 2.X系列教程:七天从无到有掌握Spring Boot-持续更新
- Spring 5.X系列教程:满足你对Spring5的一切想象-持续更新
- java程序员从小工到专家成神之路（2020版）-持续更新中,附详细文章教程
更多内容请访问www.flydean.com
小师妹：还是F师兄懂我，这不上次的Properties文件用得非常上手，每次修改Properties文件都要重启java应用程序，真的是很痛苦。有没有什么其他的办法呢？
办法当然有，最基础的办法就是开一个线程定时去监控属性文件的最后修改时间，如果修改了就重新加载，这样不就行了。
小师妹：写线程啊，这么麻烦，有没有什么更简单的办法呢？
就知道你要这样问，还好我准备的比较充分，今天给你介绍一个JDK7在nio中引入的类WatchService。
WatchService和文件系统
WatchService是JDK7在nio中引入的接口：
监控的服务叫做WatchService，被监控的对象叫做Watchable：
WatchKey register(WatchService watcher,WatchEvent.Kind<?>[] events,WatchEvent.Modifier... modifiers)throws IOException;
WatchKey register(WatchService watcher, WatchEvent.Kind<?>... events)throws IOException;
Watchable通过register将该对象的WatchEvent注册到WatchService上。从此只要有WatchEvent发生在Watchable对象上，就会通知WatchService。
WatchEvent有四种类型：
- ENTRY_CREATE 目标被创建
- ENTRY_DELETE 目标被删除
- ENTRY_MODIFY 目标被修改
- OVERFLOW 一个特殊的Event，表示Event被放弃或者丢失
register返回的WatchKey就是监听到的WatchEvent的集合。
现在来看WatchService的4个方法：
- close 关闭watchService
- poll 获取下一个watchKey，如果没有则返回null
- 带时间参数的poll 在等待的一定时间内获取下一个watchKey
- take 获取下一个watchKey，如果没有则一直等待
小师妹：F师兄，那怎么才能构建一个WatchService呢？
上次文章中说的文件系统，小师妹还记得吧，FileSystem中就有一个获取WatchService的方法：
public abstract WatchService newWatchService() throws IOException;
我们看下FileSystem的结构图：
在我的mac系统上，FileSystem可以分为三大类，UnixFileSystem，JrtFileSystem和ZipFileSystem。我猜在windows上面应该还有对应的windows相关的文件系统。小师妹你要是有兴趣可以去看一下。
小师妹：UnixFileSystem用来处理Unix下面的文件，ZipFileSystem用来处理zip文件。那JrtFileSystem是用来做什么的？
哎呀，这就又要扯远了，为什么每次问问题都要扯到天边…
从前当JDK还是9的时候，做了一个非常大的改动叫做模块化JPMS（Java Platform Module System），这个Jrt就是为了给模块化系统用的，我们来举个例子：
public void useJRTFileSystem(){String resource = "java/lang/Object.class";URL url = ClassLoader.getSystemResource(resource);log.info("{}",url);}
上面一段代码我们获取到了Object这个class的url，我们看下如果是在JDK8中，输出是什么：
jar:file:/Library/Java/JavaVirtualMachines/jdk1.8.0_171.jdk/Contents/Home/jre/lib/rt.jar!/java/lang/Object.class
输出结果是jar:file表示这个Object class是放在jar文件中的，后面是jar文件的路径。
如果是在JDK9之后：
jrt:/java.base/java/lang/Object.class
结果是jrt开头的，java.base是模块的名字，后面是Object的路径。看起来是不是比传统的jar路径更加简洁明了。
有了文件系统，我们就可以在获取系统默认的文件系统的同时，获取到相应的WatchService：
WatchService watchService = FileSystems.getDefault().newWatchService();
WatchSerice的使用和实现本质
小师妹：F师兄，WatchSerice是咋实现的呀？这么神奇，为我们省了这么多工作。
其实JDK提供了这么多类的目的就是为了不让我们重复造轮子，之前跟你讲监控文件的最简单办法就是开一个独立的线程来监控文件变化吗？其实…WatchService就是这样做的！
PollingWatchService() {// TBD: Make the number of threads configurablescheduledExecutor = Executors.newSingleThreadScheduledExecutor(new ThreadFactory() {@Overridepublic Thread newThread(Runnable r) {Thread t = new Thread(null, r, "FileSystemWatcher", 0, false);t.setDaemon(true);return t;}});}
上面的方法就是生成WatchService的方法，小师妹看到没有，它的本质就是开启了一个daemon的线程，用来接收监控任务。
下面看下怎么把一个文件注册到WatchService上面：
private void startWatcher(String dirPath, String file) throws IOException {WatchService watchService = FileSystems.getDefault().newWatchService();Path path = Paths.get(dirPath);path.register(watchService, ENTRY_MODIFY);Runtime.getRuntime().addShutdownHook(new Thread(() -> {try {watchService.close();} catch (IOException e) {log.error(e.getMessage());}}));WatchKey key = null;while (true) {try {key = watchService.take();for (WatchEvent<?> event : key.pollEvents()) {if (event.context().toString().equals(fileName)) {loadConfig(dirPath + file);}}boolean reset = key.reset();if (!reset) {log.info("该文件无法重置");break;}} catch (Exception e) {log.error(e.getMessage());}}}
上面的关键方法就是path.register，其中Path是一个Watchable对象。
然后使用watchService.take来获取生成的WatchEvent，最后根据WatchEvent来处理文件。
总结
道生一，一生二，二生三，三生万物。一个简简单单的功能其实背后隐藏着…道德经，哦，不对，背后隐藏着道的哲学。
本文的例子https://github.com/ddean2009/learn-java-io-nio
本文作者：flydean程序那些事
本文链接：http://www.flydean.com/java-io-file-watchservice/
本文来源：flydean的博客
欢迎关注我的公众号:程序那些事，更多精彩等着您！
小师妹学JavaIO之:文件系统和WatchService相关推荐
- 小师妹学JavaIO之:文件File和路径Path
文章目录 简介 文件和路径 文件中的不同路径 构建不同的Path 总结 简介 文件和路径有什么关系?文件和路径又隐藏了什么秘密?在文件系统的管理下,创建路径的方式又有哪些?今天F师兄带小师妹再给大家来 ...
- 小师妹学JavaIO之:文件写入那些事
文章目录 简介 字符输出和字节输出 格式化输出 输出其他对象 在特定的位置写入 给文件加锁 总结 简介 小师妹又对F师兄提了一大堆奇奇怪怪的需求,要格式化输出,要特定的编码输出,要自己定位输出,什么? ...
- 小师妹学JavaIO之:文件编码和字符集Unicode
文章目录 简介 使用Properties读取文件 乱码初现 字符集和文件编码 解决Properties中的乱码 真.终极解决办法 总结 简介 小师妹一时兴起,使用了一项从来都没用过的新技能,没想却出现 ...
- 小师妹学JavaIO之:文件读取那些事
文章目录 简介 字符和字节 按字符读取的方式 按字节读取的方式 寻找出错的行数 总结 简介 小师妹最新对java IO中的reader和stream产生了一点点困惑,不知道到底该用哪一个才对,怎么读取 ...
- .dat文件写入byte类型数组_小师妹学JavaIO之:文件写入那些事
简介 小师妹又对F师兄提了一大堆奇奇怪怪的需求,要格式化输出,要特定的编码输出,要自己定位输出,什么?还要阅后即焚?大家看F师兄怎么一一接招吧. 字符输出和字节输出 小师妹:F师兄,上次你的IO讲到了 ...
- java文件夹路径的表达_小师妹学JavaIO之:文件File和路径Path
简介 文件和路径有什么关系?文件和路径又隐藏了什么秘密?在文件系统的管理下,创建路径的方式又有哪些?今天F师兄带小师妹再给大家来一场精彩的表演. 文件和路径 小师妹:F师兄我有一个问题,java中的文 ...
- 小师妹学JavaIO之:MappedByteBuffer多大的文件我都装得下
文章目录 简介 虚拟地址空间 详解MappedByteBuffer MapMode MappedByteBuffer的最大值 MappedByteBuffer的使用 MappedByteBuffer要 ...
- mappedbytebuffer_小师妹学JavaIO之:MappedByteBuffer多大的文件我都装得下
简介 大大大,我要大!小师妹要读取的文件越来越大,该怎么帮帮她,让程序在性能和速度上面得到平衡呢?快来跟F师兄一起看看吧. 虚拟地址空间 小师妹:F师兄,你有没有发现,最近硬盘的价格真的是好便宜好便宜 ...
- 小师妹学JavaIO之:目录还是文件
文章目录 简介 linux中的文件和目录 目录的基本操作 目录的进阶操作 目录的腰疼操作 总结 简介 目录和文件傻傻分不清楚,目录和文件的本质到底是什么?在java中怎么操纵目录,怎么遍历目录.本文F ...
最新文章
- 安卓ttf格式的字体包_多看字体包优化篇
- iOS 消息推送原理及实现总结
- Discuz x3论坛使用CDN后获取真实IP的解决方法
- 深入理解分布式技术 - Kafka 高性能原理剖析
- [译]以PostgreSQL为例，谈join计算的代价
- python的垃圾处理机制_Python语法入门之垃圾回收机制
- 竞争者无数的大数据赛道，这家创业公司靠什么获得众多资本青睐？
- CSS权威指南之css声明，伪类，文本处理--(简要笔记一)
- 使用BeanPostProcessor接口对受管Bean进行预处理
- github(GitHub Flavored Markdown)
- C++中使用sizeof查看几种数据类型所占内存字节大小
- 记录一次解决后端接口设置cookie设置不上去经过，一级域名可以设置上去cookie，二级域名设置不上cookie
- IDEA本地插件下载及安装
- Centos实现软路由
- 关于视频号主页实现一键添加个人微信功能的思路
- 几组数据的相关性python_几的笔顺 笔画数：2 拼音：jī,jǐ 部首：几 - 智慧山
- 机器学习笔记六——特征工程之数据预处理
- 突破与升维，技术赋能下的新时代企业营销攻略（附报告下载）
- cmap参数 plt_小坑记录：get_cmap参数区分大小写-阿里云开发者社区
- 群晖设置公网ipv6方式域名解析访问