当前位置：首页 > news >正文

java实现文件变动监听

news 2024/10/22 10:43:28

在文件的内容发生变动时，应用可以感知这种变种，并重新加载文件内容，更新应用内部缓存

实现

轮询：定时器Timer，ScheduledExecutorService
判断文件修改：根据java.io.File#lastModified获取文件的上次修改时间，比对

public class FileUpTest{private long lastTime;private void ttt(){throw new NullPointerException();}@Testpublic void testFileUpdate(){File file = new File("/tmp/alarmConfig");//首先文件的最近一次修改时间戳lastTime = file.lastModified();//定时任务，每秒来判断一下文件是否发生变动，即判断lastModified是否改变ScheduledExecutorService scheduledExcutorService = Executors.newScheduledThreadPool(1);scheduledExecutorService.scheduleAtFixedRate(new Runnable(){@Oveerridepublic void run(){if(file.lastModified() > lastTime){System.out.println("file update! time : "+ file.lastModified());lastTime = file.getlastModified();ttt();}}},0,1,TimeUnit.SECONDS);try{Thread.sleep(100*60);}catch(InterruptedException e){e.printStackTrace();}}
}

使用这种的，如果定时任务执行过程中遇到发生异常，则后面的任务将不再执行

apache版本

<dependency><groupId>commons-io</groupId><artifactId>commons-io</artifactId><version>2.6</version>
</dependency>

借助工具中FileAlterationObserver,FileAlterationListener,FileAlterationMonitor三个类实现相关需求

public class PropertiesConfListenerHelper{public static boolean registerConfChangeListener(File file,Function<File,Map<String,AlarmConfig>> func){try{//轮询间隔5秒long interval = TimeUnit.SECONDS.toMillis(5);//因为监听是以目录为单位进行的，所以这里直接获取文件的根目录File dir = file.getParentFile();//创建一个文件观察期用于过滤FileAlterationObserver observer = new FileAlterationObserver(dir,FileFilterUtils.and(FileFilterUtils.fileFileFilter(),FileFilterUtils.nameFileFilter(file.getName())));//设置文件变化监听器observer.addListener(new MyFileListener(func));FileAlterationMonitor monitor = new FileAlterationMonitor(interval,observer);monitor.start();return true;}catch(Exception e){log.error("register properties change listener error! e:{}",e);return false;}}static final class MyFileListener extends FileAlterationListenerAdaptor{private Function<File,Map<String,AlarmConfig>> func;public MyfileListener(Function<File,Map<String,AlarmConfig>> func){this.func = func;}@Overridepublic void onFileChange(File file){Map<String,AlarmConfig> ans = func.apply(file);//如果加载失败，打印一条日志log.warn("PropertiesConfig changed ! reload ans: {}",ans);}}
}

介绍
1. 这个文件监听，是以目录为根源，可以设置过滤器，来实现对应文件变动的监听
2. 上面的registerConfChangeListener方法，传入的file是具体的配置文件，因此构建参数的时候，拿到目录，拿到文件名作为过滤
3. 第二个参数是jdk1.8语法，其中为具体的读取配置文件内容，并影射为对应的实体对象
4. 如果func方式执行时，抛出了一场，程序失败，不在运行

JDK版本

JDK1.7提供了一个WatchService，可以用来实现文件变动的监听

@Test
public void testFileUpWather() throws IOException{//监听必须是目录Path path = Paths.get("/tmp");WatchService watcher = FileSystems.getDefault().newWatchService();path.register(watcher,ENTRY_MODIFY);new Thread(() ->{try{while(true){WatchKey key = watcher.take();for(WatchEvent<?> event : key.pollEvents()){if(event.kind() == OVERFLOW){                        // 实践可能lost or discardedcontinue；                	}Path fileName = (Path)event.context();System.out.println("文件更新："+fileName);}if(!key.reset()){//重设WatchKeybreak；}}}catch(Exception e){e.printStackTrace();}}).start();try{Thread.sleep(1000* 60 * 10);}catch(InterruptedException e){e.printStackTrace();}
}