Java实现的文件监控管理
实现功能：实时监控指定目录下文件的增加 / 更新 / 删除 情况.// monitor.file.FileMonitor.javapackage monitor.file;/** *@date 2010-3-18 上午10:12:14 *@author dycc *@file monitor.file.FileMonitor.java */public class FileMonitor {public static void main(String[] args) { FileSchedulerTask task = new FileSchedulerTask("D:\\Temp"); FileScheduler monitor = new FileScheduler(); monitor.schedule(task, new TimeStep()); }}// monitor.file.FileScheduler.javapackage monitor.file;import java.util.Date;import java.util.Timer;import java.util.TimerTask;/** *@date 2010-3-18 上午10:31:26 *@author dycc *@file monitor.file.FileScheduler.java */public class FileScheduler {// 定时器private final Timer timer;public FileScheduler(){timer = new Timer();}public FileScheduler(boolean isDaemon){// 是否为守护线程timer = new Timer(isDaemon);}/** * 为定时器分配可执行任务 * @param task * @param step */public void schedule(Runnable task,TimeStep step){Date time = step.next();SchedulerTimerTask timeTask = new SchedulerTimerTask(task,step);// 安排在指定的时间 time 执行指定的任务 timetasktimer.schedule(timeTask, time);// 此处不使用// public void schedule(TimerTask task, Date firstTime, long period)// 执行定时任务,而是使用 reSchedule 来重复执行任务,是因为首次执行时可能需要做一些额外的初始化,// 这样方便以后扩展.}/** * 重新执行任务 * @param task * @param step */private void reSchedule(Runnable task,TimeStep step){Date time = step.next();SchedulerTimerTask timeTask = new SchedulerTimerTask(task,step);// 安排在指定的时间 time 执行指定的任务 timetasktimer.schedule(timeTask, time);}/** * 停止当前定时器 */public void cancle(){timer.cancel();}/** * 定时任务 * @author dycc * */private class SchedulerTimerTask extends TimerTask{private Runnable task;private TimeStep step;public SchedulerTimerTask(Runnable task,TimeStep step){this.task = task;this.step = step;}@Overridepublic void run() {// 执行指定任务 task.run(); // 继续重复执行任务 reSchedule(task, step);}}}// monitor.file.FileSchedulerTask.javapackage monitor.file;import java.io.File;import java.util.HashMap;import java.util.HashSet;import java.util.Iterator;import java.util.Map;import java.util.Set;/** *@date 2010-3-18 上午10:39:29 *@author dycc *@file monitor.file.FileSchedulerTask.java */public class FileSchedulerTask implements Runnable{private boolean firstRun = true;private String directory = "";// 初始文件信息private Map<String,Long> currentFiles = new HashMap<String,Long>();// 当前文件信息private Set<String> newFiles = new HashSet<String>();/** * 构造函数 */public FileSchedulerTask(){}public FileSchedulerTask(String directory){this.directory = directory;}/** * 在 run() 中执行具体任务 */public void run() { File file = new File(directory); if(firstRun){ firstRun = false; // 初次运行 loadFileInfo(file); System.out.println("----- init success -----"); } else{ // 检查文件更新状态 checkFileUpdate(file); // 检查被移除的文件 checkRemovedFiles(); // 清空临时文件集合 newFiles.clear(); }}/** * 初始化文件信息 * @param file */private void loadFileInfo(File file){if(file.isFile()){currentFiles.put(file.getAbsolutePath(), file.lastModified());return;}File[] files = file.listFiles();for(int i=0;i<files.length;i++){loadFileInfo(files);}}/** * 检查文件更新状态 * @param file */private void checkFileUpdate(File file){if(file.isFile()){// 将当前文件加入到 newFiles 集合中newFiles.add(file.getAbsolutePath());// Long lastModified = currentFiles.get(file.getAbsolutePath());if(lastModified == null){// 新加入文件currentFiles.put(file.getAbsolutePath(), file.lastModified());System.out.println("添加文件:" + file.getAbsolutePath());return;}if(lastModified.doubleValue() != file.lastModified()){// 更新文件currentFiles.put(file.getAbsolutePath(), file.lastModified());System.out.println("更新文件:" + file.getAbsolutePath());return;}return;} else if(file.isDirectory()){File[] files = file.listFiles();if(files == null || files.length == 0){// 没有子文件或子目录时返回return;}for(int i=0;i<files.length;i++){checkFileUpdate(files);}}}/** * 检查被移除的文件 */private void checkRemovedFiles(){// 增加或更新时,newFiles.size() == currentFiles.size()// 删除时, newFiles.size()< currentFiles.size()// 不可能出现 newFiles.size()> currentFiles.size()if(newFiles.size() == currentFiles.size()){// 增加或更新时没有被移除的文件,直接返回return;}Iterator<String> it = currentFiles.keySet().iterator();while(it.hasNext()){String filename = it.next();if(!newFiles.contains(filename)){// 此处不能使用 currentFiles.remove(filename);从 map 中移除元素,// 否则会引发同步问题.// 正确的做法是使用 it.remove();来安全地移除元素.it.remove();System.out.println("删除文件:" + filename);}}}/** * 起始目录 * @return */public String getDirectory() { return directory; }public void setDirectory(String directory) { this.directory = directory; }}// monitor.file.TimeStep.javapackage monitor.file;import java.util.Calendar;import java.util.Date;/** *@date 2010-3-18 上午10:12:14 *@author dycc *@file monitor.file.TimeStep.java */public class TimeStep {private Calendar calendar = Calendar.getInstance();// calendar fieldprivate int field = Calendar.SECOND;// the amount of the date or timeprivate int amount = 10;/** * field * @return */public int getField() { return field; }public void setField(int field) { this.field = field; }/** * amount * @return */public int getAmount() { return amount; }public void setAmount(int amount) { this.amount = amount; }/** * 获取时间 * @exception IllegalArgumentException if field is unknown * @return */public Date next(){calendar.add(field, amount);return calendar.getTime();}}
页:
[1]