文件变动监听

女爷i 2023-07-08 13:24 91阅读 0赞

import java.io.File;
    import java.util.concurrent.TimeUnit;
    
    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;
    
    /**
     * 文件变动监测器
     * @author yangxuan
     *
     */
    public class DocumentChangeMonitorService {
    	public static void DocumentChangeMonitor() {
    		File directory = new File("D:/file_temp");
    		try {
    			// 构造观察类主要提供要观察的文件或目录，当然还有详细信息的filter
    			FileAlterationObserver observer = new FileAlterationObserver(directory, FileFilterUtils.and(FileFilterUtils.fileFileFilter(),FileFilterUtils.suffixFileFilter(".testfile")));
    			//
    			FileAlterationListener listener = new MyFileListener();
    			// 为观察对象添加收听对象
    			observer.addListener(listener);
    			// 配置Monitor，第一个参数单位是毫秒，是监听的间隔；第二个参数就是绑定我们之前的观察对象。
    			long interval = TimeUnit.SECONDS.toMillis(5);//轮询间隔 5 秒
    			FileAlterationMonitor fileMonitor = new FileAlterationMonitor(interval, observer);
    			// 启动开始监听
    			fileMonitor.start();
    		} catch (Exception e) {
    			e.printStackTrace();
    		}
    	}
    }

import java.io.File;
    
    import org.apache.commons.io.monitor.FileAlterationListener;
    import org.apache.commons.io.monitor.FileAlterationObserver;
    
    public final class MyFileListener implements FileAlterationListener {
    
    	@Override
    	public void onDirectoryChange(File arg0) {
    		System.out.println("文件目录发生改变！！！");
    	}
    
    	@Override
    	public void onDirectoryCreate(File arg0) {
    		System.out.println("文件目录创建成功！！！");
    	}
    
    	@Override
    	public void onDirectoryDelete(File arg0) {
    		System.out.println("文件目录已经删除！！！");
    	}
    
    	@Override
    	public void onFileChange(File arg0) {
    		System.out.println("文件发生改变！！！");
    	}
    
    	@Override
    	public void onFileCreate(File arg0) {
    		System.out.println("文件创建成功！！！");
    	}
    
    	@Override
    	public void onFileDelete(File arg0) {
    		System.out.println("文件删除成功！！！");
    	}
    
    	@Override
    	public void onStart(FileAlterationObserver arg0) {
    		System.out.println("开始！！！");
    	}
    
    	@Override
    	public void onStop(FileAlterationObserver arg0) {
    		System.out.println("停止！！！");
    	}
    
    }