来点实用的Java NIO（三）

淡淡的烟草味﹌ 2022-04-21 14:10 221阅读 0赞

package com.watchservice;
    
    import java.nio.file.FileSystems;
    import java.nio.file.Path;
    import java.nio.file.Paths;
    import java.nio.file.StandardWatchEventKinds;
    import java.nio.file.WatchEvent;
    import java.nio.file.WatchKey;
    import java.nio.file.WatchService;
    
    /***
     * 
     * @author 秦东亮
     * 实时监控某个目录
     * 
     * **/
    public class MyWatchService {
       
    
    
    	public static void main(String[] args)throws Exception {
       
    
    		//获取当前文件系统的WatchService监控对象
    		WatchService watchService=FileSystems.getDefault().newWatchService();
    		//监听的事件类型，有创建，删除，以及修改
    		Paths.get("E:\\测试java监听").register(watchService, StandardWatchEventKinds.ENTRY_CREATE,StandardWatchEventKinds.ENTRY_DELETE,StandardWatchEventKinds.ENTRY_MODIFY,StandardWatchEventKinds.OVERFLOW);
    
    	  while(true){
       
    		  //获取下一个文件变化事件
    		  WatchKey key=watchService.take();
    		  for(WatchEvent<?> event:key.pollEvents()){
       
    
    			  System.out.println(event.context()+"文件发生了"+event.kind()+"事件"+"此事件发生的次数: "+event.count());
    		  }
    		  //重设WatchKey
    		  boolean valid=key.reset();
    		  //监听失败，退出监听
    		  if(!valid){
       
    			  break;
    		  }
    	  }
    	}
    }

\[b\]\[color=green\]\[size=large\]运行，效果如下：\[/size\]\[/color\]\[/b\]

新建文件夹文件发生了ENTRY_CREATE事件此事件发生的次数: 1
    新建 Microsoft Excel 工作表.xlsx文件发生了ENTRY_CREATE事件此事件发生的次数: 1
    新建 Microsoft Excel 工作表.xlsx文件发生了ENTRY_MODIFY事件此事件发生的次数: 1
    新建 Microsoft Excel 工作表.xlsx文件发生了ENTRY_MODIFY事件此事件发生的次数: 1
    新建 Microsoft Excel 工作表.xlsx文件发生了ENTRY_MODIFY事件此事件发生的次数: 1
    新建 Microsoft Excel 工作表 (2).xlsx文件发生了ENTRY_CREATE事件此事件发生的次数: 1
    新建 Microsoft Excel 工作表 (2).xlsx文件发生了ENTRY_MODIFY事件此事件发生的次数: 1
    新建 Microsoft Excel 工作表 (2).xlsx文件发生了ENTRY_MODIFY事件此事件发生的次数: 1
    新建 Microsoft Excel 工作表 (2).xlsx文件发生了ENTRY_MODIFY事件此事件发生的次数: 1
    新建 Microsoft Excel 工作表 (2).xlsx文件发生了ENTRY_DELETE事件此事件发生的次数: 1

\[b\]\[color=green\]\[size=large\]截图如下：\[/size\]\[/color\]\[/b\]  
  
\[img\]http://dl2.iteye.com/upload/attachment/0091/5775/a99cdcb4-44f9-377a-b33c-a8dc86e45f0d.jpg\[/img\]  
  
\[b\]\[color=green\]\[size=x-large\]  
  
至此，我们的一个小型监控项目就完成了，这个技术在很多时候，都非常有用，例如一些主从架构的数据同步的场景，Master数据状态改变了，然后就可以立即同步到Slave里，这其实就跟文件系统监控的原理差不多。文件系统的监控不仅要求可靠性高，而且还得简单，好用，说到这里，不得不提下，我们分布式环境下经常用到的一个集群协作服务Zookeeper，当然zookeeper的实现原理，比我们这个小技术要复杂多了，其中的一些leader选举算法，状态一致算法都是非常复杂的，不过zookeeper的对外API提供的非常短小简单，它的安装部署也是非常容易的，有兴趣的朋友可以深入的研究一下。\[/size\]\[/color\]\[/b\]