zoukankan      html  css  js  c++  java
  • 使用apache common-io 监控文件变化--转

    package common.io;
    
    
    import org.apache.commons.io.filefilter.FileFilterUtils;
    import org.apache.commons.io.monitor.FileAlterationListener;
    import org.apache.commons.io.monitor.FileAlterationMonitor;
    import org.apache.commons.io.monitor.FileAlterationObserver;
    
    
    import java.io.File;
    import java.util.concurrent.TimeUnit;
    
    
    /**
     * Created with IntelliJ IDEA.
     * User: superman
     * Date: 14-1-5
     * Time: 上午11:43
     * To change this template use File | Settings | File Templates.
     */
    public class Example3 {
        public static void main(String[] args) throws Exception{
            File directory = new File("D:/test");
            // 轮询间隔 5 秒
            long interval = TimeUnit.SECONDS.toMillis(5);
            // 创建一个文件观察器用于处理文件的格式
            FileAlterationObserver observer = new FileAlterationObserver(directory, FileFilterUtils.and(
                    FileFilterUtils.fileFileFilter(),FileFilterUtils.suffixFileFilter(".txt")));
            //设置文件变化监听器
            observer.addListener(new MyFileListener());
            FileAlterationMonitor monitor = new FileAlterationMonitor(interval,observer);
            monitor.start();
            //Thread.sleep(30000);
            //monitor.stop();
        }
    }
    final class MyFileListener implements FileAlterationListener{
        @Override
        public void onStart(FileAlterationObserver fileAlterationObserver) {
            System.out.println("monitor start scan files..");
        }
    
    
        @Override
        public void onDirectoryCreate(File file) {
            System.out.println(file.getName()+" director created.");
        }
    
    
        @Override
        public void onDirectoryChange(File file) {
            System.out.println(file.getName()+" director changed.");
        }
    
    
        @Override
        public void onDirectoryDelete(File file) {
            System.out.println(file.getName()+" director deleted.");
        }
    
    
        @Override
        public void onFileCreate(File file) {
            System.out.println(file.getName()+" created.");
        }
    
    
        @Override
        public void onFileChange(File file) {
            System.out.println(file.getName()+" changed.");
        }
    
    
        @Override
        public void onFileDelete(File file) {
            System.out.println(file.getName()+" deleted.");
        }
    
    
        @Override
        public void onStop(FileAlterationObserver fileAlterationObserver) {
            System.out.println("monitor stop scanning..");
        }
    }
  • 相关阅读:
    DedeCMS的arclist循环中判断第一个元素并添加class样式
    PC 浏览器伪装移动(微信)User-Agent
    DedeCMS后台无法保存中文字符
    java spring boot 定时器
    java spring boot 部署redis
    java spring boot 打包方法
    java spring boot返回json的写法
    关于java idea 创建spring boot没有下载依赖的解决方案
    java和golang并发测试
    php转java 系列2 Spring boo 链接数据库jdbc
  • 原文地址:https://www.cnblogs.com/davidwang456/p/3689421.html
Copyright © 2011-2022 走看看