扫二维码与项目经理沟通
我们在微信上24小时期待你的声音
解答本文疑问/技术咨询/运营咨询/技术建议/互联网交流
java 使用线程监控文件目录变化的实现方法
创新新互联,凭借十多年的成都做网站、网站建设经验,本着真心·诚心服务的企业理念服务于成都中小企业设计网站有近千家案例。做网站建设,选成都创新互联。
由于某种特殊的需求、弄了个使用线程监控文件目录变化的
代码基本如下、其中减去一些复杂的操作、只留下基本代码:
package com.file; import java.io.File; import java.util.ArrayList; import java.util.HashMap; import java.util.Iterator; import java.util.List; import java.util.Map; public class FilesMonitor implements Runnable { // 文件夹路径 private String filePath = "D:\\t\\user\\local\\test\\"; // 存放已读文件<即:缓存目录> private static Mapmap = new HashMap (); @Override public void run() { while (true) { try { // 设置每隔3秒检测一次 Thread.sleep(3000); FileMonitor(); } catch (InterruptedException e) { e.printStackTrace(); } } } // 文件监听 public void FileMonitor() { File[] files = getFiles(filePath, null); if (files != null && files.length > 0) { // 如果缓存中文件与读取的个数不一样的时候 String fName = ""; if (files.length != map.size()) { if (map.size() == 0) { for (File file : files) { fName = file.getName(); map.put(fName, file); System.out.println("新增了文件:" + fName); } } else { // 如果减少了文件 if (map.size() > files.length) { List removeName = new ArrayList (); Iterator iter = map.keySet().iterator(); int j = 0; while (iter.hasNext()) { String key = iter.next(); if (key != null && key.length() > 0) { for (File file : files) { fName = file.getName(); if (fName.equals(key)) { j = 1; break; } } if (j != 1) { removeName.add(key); } j = 0; } } // 判断是否有删除的文件 if (removeName.size() > 0) { for (String item : removeName) { map.remove(item); System.out.println("减少了文件:" + item); } } } else { for (File file : files) { fName = file.getName(); if (!map.containsKey(fName.trim())) { map.put(fName, file); System.out.println("新增了文件:" + fName); } } } } } else { map.clear(); for (File file : files) { fName = file.getName(); map.put(fName, file); } } System.out.println("此时缓存中文件个数:" + map.size()); } } /** * 文件读取 * * @param filePath * 路径 * @param fileName * 名称 * @return 返回文件数组 */ public File[] getFiles(String filePath, String fileName) { File[] files = null; if (fileName == null) { File doc = new File(filePath); if (doc.isDirectory()) { String[] fileNameArr = doc.list(); if (fileNameArr.length > 0) { files = new File[fileNameArr.length]; for (int i = 0; i < fileNameArr.length; i++) { fileName = fileNameArr[i]; String fileAbsPath = filePath + fileName; File regInfoFile = new File(fileAbsPath); files[i] = regInfoFile; } } } } else { String path = filePath + fileName; File doc = new File(path); if (doc.isFile()) { files = new File[1]; files[0] = doc; } } return files; } // 启动线程 public void show() { FilesMonitor t = new FilesMonitor(); Thread tread = new Thread(t); tread.setName("eshore"); tread.start(); } // Main测试 public static void main(String[] args) { FilesMonitor t = new FilesMonitor(); t.show(); } }
执行后,效果图如下:
如有疑问请留言或者到本站社区交流讨论,感谢阅读,希望能帮助到大家,谢谢大家对本站的支持!
我们在微信上24小时期待你的声音
解答本文疑问/技术咨询/运营咨询/技术建议/互联网交流