Java 实现实时监听文件夹是否有新文件增加并上传服务器功能

程序员文章站 2022-07-22 09:20:22

本文中主要陈述一种实时监听文件夹中是否有文件增加的功能，可用于实际文件上传功能的开发。主要实现方式： ...

本文中主要陈述一种实时监听文件夹中是否有文件增加的功能，可用于实际文件上传功能的开发。

主要实现方式：

（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，出现如下界面：

Java 实现实时监听文件夹是否有新文件增加并上传服务器功能