在文件的內容發(fā)生變動時，應用可以感知這種變種，并重新加載文件內容，更新應用內部緩存

實現(xiàn)

1. 輪詢：定時器Timer，ScheduledExecutorService

2. 判斷文件修改：根據java.io.File#lastModified獲取文件的上次修改時間，比對

3. public class FileUpTest{private long lastTime;private void ttt(){throw new NullPointerException();}@Testpublic void testFileUpdate(){File file = new File("/tmp/alarmConfig");//首先文件的最近一次修改時間戳lastTime = file.lastModified();//定時任務，每秒來判斷一下文件是否發(fā)生變動，即判斷l(xiāng)astModified是否改變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();}}
   }
   

4. 使用這種的，如果定時任務執(zhí)行過程中遇到發(fā)生異常，則后面的任務將不再執(zhí)行

apache版本

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

2. 借助工具中FileAlterationObserver,FileAlterationListener,FileAlterationMonitor三個類實現(xiàn)相關需求

3. public class PropertiesConfListenerHelper{public static boolean registerConfChangeListener(File file,Function<File,Map<String,AlarmConfig>> func){try{//輪詢間隔5秒long interval = TimeUnit.SECONDS.toMillis(5);//因為監(jiān)聽是以目錄為單位進行的，所以這里直接獲取文件的根目錄File dir = file.getParentFile();//創(chuàng)建一個文件觀察期用于過濾FileAlterationObserver observer = new FileAlterationObserver(dir,FileFilterUtils.and(FileFilterUtils.fileFileFilter(),FileFilterUtils.nameFileFilter(file.getName())));//設置文件變化監(jiān)聽器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);}}
   }
   

4. 介紹

   1. 這個文件監(jiān)聽，是以目錄為根源，可以設置過濾器，來實現(xiàn)對應文件變動的監(jiān)聽
   2. 上面的registerConfChangeListener方法，傳入的file是具體的配置文件，因此構建參數的時候，拿到目錄，拿到文件名作為過濾
   3. 第二個參數是jdk1.8語法，其中為具體的讀取配置文件內容，并影射為對應的實體對象
   4. 如果func方式執(zhí)行時，拋出了一場，程序失敗，不在運行

JDK版本

1. JDK1.7提供了一個WatchService，可以用來實現(xiàn)文件變動的監(jiān)聽

2. @Test
   public void testFileUpWather() throws IOException{//監(jiān)聽必須是目錄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();}
   }
   

3. 千萬不要在定時任務或者文件變動的回調方法中拋出異常

4. 為了避免異常斷開情況，一個是可以做的實現(xiàn)借助EventBus的異步消息通知機制來實現(xiàn)，當文件變動之后，發(fā)送一個消息即可，然后在具體的重新加載文件內容的方法上，添加一個@Subscribe注解即可，這樣既實現(xiàn)了解耦，也避免了一場導致的服務異常