Java中怎么实时监听文件夹是否有新文件增加
创始人
2024-12-22 12:01:56
0次

主要实现方式:

(1)利用Timer的定时循环执行代码的功能;

(2)利用WatchService实时监听文件夹是否有新文件增加,通过阻塞式IO流实现文件上传服务器。

代码如下:

private static String path = "E:\\Kankan";public static void getFile() throws FileNotFoundException, IOException{ final Timer timer = new Timer(); timer.schedule(new TimerTask() { public void run() {  WatchKey key; try { WatchService watchService = FileSystems.getDefault().newWatchService(); Paths.get(path).register(watchService, StandardWatchEventKinds.ENTRY_CREATE);   while (true) {   File file = new File(path);//path为监听文件夹    File[] files = file.listFiles();  System.out.println("等待图片加载!");   key = watchService.take();//没有文件增加时,阻塞在这里  for (WatchEvent event : key.pollEvents()) {    String fileName = path+"\\"+event.context();   System.out.println("增加文件的文件夹路径"+fileName);   File file1 = files[files.length-1];//获取最新文件   System.out.println(file1.getName());//根据后缀判断   url = uploadFile(file1,uploadAddres);//上传服务器  }if (!key.reset()) {   break; //中断循环  }  }  }catch (Exception e) {  // TODO Auto-generated catch block  e.printStackTrace();  }  } }, 2000 , 3000);//第一个数字2000表示,2000ms以后开启定时器,第二个数字3000,表示3000ms后运行一次run  }

需要导入的jar包

import java.io.File;import java.io.FileInputStream;import java.io.FileNotFoundException;import java.io.FileOutputStream;import java.io.IOException;import java.io.InputStream;import java.io.OutputStream;import java.nio.file.FileSystems;//阻塞式IO流jar包import java.nio.file.Paths;import java.nio.file.StandardWatchEventKinds;import java.nio.file.WatchEvent;import java.nio.file.WatchKey;import java.nio.file.WatchService;import java.sql.Timestamp;import java.text.SimpleDateFormat;import java.util.Date;import java.util.Timer;import java.util.TimerTask;

文件上传服务器代码:

/** * 将file文件上传到指定dir文件夹中 * @param file:待上传文件 * @param dir:指定路径 * @throws FileNotFoundException * @throws IOException */final static String uploadAddres = System.getProperty("catalina.home")+"\\webapps\\TiaoZhanB\\uploadFile"; public static String uploadFile(File file , String dir) throws FileNotFoundException, IOException { String imgURL = null; try {  InputStream in = new FileInputStream(file);  System.out.println("服务器路径:" + dir);  // 获取文件名称  String fileName = file.getName();  // 路径和文件名丢进file对象里  File uploadFile = new File(dir, fileName);  // 输出流  OutputStream out = new FileOutputStream(uploadFile);  // 设置文件大小1MB  byte[] buffer = new byte[1024 * 1024];  int length;  // 用循环从流中读取文件的大小  while ((length = in.read(buffer)) > 0) {   out.write(buffer, 0, length);  }  // 设置图片标题和全路径  imgURL = "uploadFile/" + fileName;    System.out.println("绝对路径为"+imgURL);  // 关闭输入流输出流,释放内存  in.close();  out.close();  } catch (Exception e) {  e.printStackTrace();  }  return imgURL; }

注:如果在MyEclipse中使用上述代码(eclipse不会出错),需要将使用的Java jre切换成自己安装的jre,原因在于myeclipse自带的jre没有阻塞式io流的jar包,一定会报错。

切换方法如下:

(1)首先右键点击项目名称,找到并点击Build Path,后点击configure build path,出现如下界面:

(2)点击上图中JRE System Library------------->点击Edit

(3)出现如下界面,点击install JREs

(4)出现如下界面,点击Edit,找到自己安装的java JDK,点击确定

切换JRE后,该错误就会消失。

相关内容

热门资讯

空调连续工作多久需要停机休息 空调连续工作的时间取决于多个因素,包括空调的型号、功率、使用环境和维护情况等。一般来说,空调可以连续...
空调哪个符号是除湿的 空调除湿功能通常用一个水滴形状的符号表示。不同品牌和型号的空调遥控器可能会有所差异,但一般来说,除湿...
格力空调多长时间加一次氟利昂 1、一般情况下,空调对氟利昂的使用量是非常小的,所以在空调使用了四年左右的时候再考虑加也没问题。2、...
空调用多长时间需要加氟一次 一般情况下是五年。当出现以下这几种情况时,空调才需要加氟。1、空调的室内机和室外机各有两个接口,当接...
格调生活·C标思享荟:卡萨帝在... 9月12日的郑州龙湖金融岛,夜风轻拂,灯光璀璨。“C标时刻共传奇——卡萨帝思享荟暨20周年品牌盛典郑...
品牌价值破千亿、高端份额持续领... 9月12日,“C标时刻共传奇——卡萨帝思享荟暨20周年品牌盛典郑州站”在郑州龙湖金融岛举办。2026...
空调主板坏了修800还是换新的 空调主板坏了是修还是换新,需要考虑多个因素,以下是一些建议:1. 维修成本:如果维修费用较低,比如 ...
空调开多久需要休息多长时间 问题:空调开多久需要休息多长时间回答:1、在使用空调的过程中,一般空调开7~8个小时左右需要休息2~...
中央空调多长时间清洗一次 1、一般空调开机前清洗一次即可,空调开机中间时段再清洗一次,空调关机时清洗一次,这样比较合理。2、空...
中央空调氟利昂多久加一次 看空调制热和制冷程度,很多人的观点认为氟利昂必须一年放一次,其实这个观点是错误的,理解上面有点偏差,...