Java 实现实时监听文件夹是否有新图片增加并下载 求代码实例

Java 实现实时监听文件夹是否有新图片增加并下载  求代码实例

主要实现方式:
    (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;
	  }

参考:https://blog.csdn.net/guanmao4322/article/details/82730404

 或者 定时 10分钟 或 30 分钟 扫描一次文件夹中最新的那批图片

可追加酬金

书写定时任务:

一、扫描当前文件夹下所有文件,添加所有文件名称至数据库中,并下载文件。(初始化,第一次定时任务)

二、扫描当前文件夹下所有文件,判断文件个数是否与数据库中记录的文件个数相同。(后续定时任务)

1、判断如果数量相同结束本次任务;

2、如果数量不相同,对比文件名称;

3、如果不存在将当前文件名称存入数据库中并下载文件;

好的

Apacha common.io2.0提供了监听文件变化的功能。

监听器 FileAlterationListener

观察者 FileAlterationObserver

监视器 FileAlterationMonitor

本身Apache都做了现成的插件,不需要你自己去写,只要实现对应的接口就行了。

用定时器每秒扫描,首先第一次获取的文件名集合添加到缓冲区中,之后获取的文件名集合再判断是否有更新,更新则下载并加到缓冲区中。(无论是定时器,获取指定文件夹下文件集合,或者是下载文件,这些网上一抓一大把)

你好,我是有问必答小助手,本次您提出的有问必答问题,已经由其他小伙伴为您做出解答,并解决了您的问题。

本次提问扣除的有问必答次数,已经为您补发到账户,我们后续会持续优化,扩大我们的服务范围,为您带来更好地服务。