欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

Java 實(shí)現(xiàn)實(shí)時(shí)監(jiān)聽(tīng)文件夾是否有新文件增加并上傳服務(wù)器功能

 更新時(shí)間:2019年09月04日 09:46:22   作者:夏沐_lk  
本文中主要陳述一種實(shí)時(shí)監(jiān)聽(tīng)文件夾中是否有文件增加的功能,可用于實(shí)際文件上傳功能的開(kāi)發(fā)。本文通過(guò)實(shí)例代碼給大家介紹的非常詳細(xì),具有一定的參考借鑒價(jià)值,需要的朋友參考下吧

本文中主要陳述一種實(shí)時(shí)監(jiān)聽(tīng)文件夾中是否有文件增加的功能,可用于實(shí)際文件上傳功能的開(kāi)發(fā)。

    主要實(shí)現(xiàn)方式:

    (1)利用Timer的定時(shí)循環(huán)執(zhí)行代碼的功能;

    (2)利用WatchService實(shí)時(shí)監(jiān)聽(tīng)文件夾是否有新文件增加,通過(guò)阻塞式IO流實(shí)現(xiàn)文件上傳服務(wù)器。

    代碼如下:

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為監(jiān)聽(tīng)文件夾 
   File[] files = file.listFiles();
  System.out.println("等待圖片加載!");
   key = watchService.take();//沒(méi)有文件增加時(shí),阻塞在這里
  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());//根據(jù)后綴判斷
   url = uploadFile(file1,uploadAddres);//上傳服務(wù)器
  }if (!key.reset()) {
   break; //中斷循環(huán)
  }
  }
  }catch (Exception e) {
  // TODO Auto-generated catch block
  e.printStackTrace();
  }
  }
 }, 2000 , 3000);//第一個(gè)數(shù)字2000表示,2000ms以后開(kāi)啟定時(shí)器,第二個(gè)數(shù)字3000,表示3000ms后運(yùn)行一次run 
 }

需要導(dǎo)入的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;

文件上傳服務(wù)器代碼:

/**
 * 將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("服務(wù)器路徑:" + dir);
  // 獲取文件名稱
  String fileName = file.getName();
  // 路徑和文件名丟進(jìn)file對(duì)象里
  File uploadFile = new File(dir, fileName);
  // 輸出流
  OutputStream out = new FileOutputStream(uploadFile);
  // 設(shè)置文件大小1MB
  byte[] buffer = new byte[1024 * 1024];
  int length;
  // 用循環(huán)從流中讀取文件的大小
  while ((length = in.read(buffer)) > 0) {
   out.write(buffer, 0, length);
  }
  // 設(shè)置圖片標(biāo)題和全路徑
  imgURL = "uploadFile/" + fileName;
  
  System.out.println("絕對(duì)路徑為"+imgURL);
  // 關(guān)閉輸入流輸出流,釋放內(nèi)存
  in.close();
  out.close();
  } catch (Exception e) {
  e.printStackTrace();
  }
  return imgURL;
 }

注:如果在MyEclipse中使用上述代碼(eclipse不會(huì)出錯(cuò)),需要將使用的Java  jre切換成自己安裝的jre,原因在于myeclipse自帶的jre沒(méi)有阻塞式io流的jar包,一定會(huì)報(bào)錯(cuò)。

切換方法如下:

(1)首先右鍵點(diǎn)擊項(xiàng)目名稱,找到并點(diǎn)擊Build Path,后點(diǎn)擊configure build path,出現(xiàn)如下界面:

(2)點(diǎn)擊上圖中JRE System Library------------->點(diǎn)擊Edit

(3)出現(xiàn)如下界面,點(diǎn)擊install JREs

(4)出現(xiàn)如下界面,點(diǎn)擊Edit,找到自己安裝的java JDK,點(diǎn)擊確定

切換JRE后,該錯(cuò)誤就會(huì)消失。

總結(jié)

以上所述是小編給大家介紹的Java 實(shí)現(xiàn)實(shí)時(shí)監(jiān)聽(tīng)文件夾是否有新文件增加并上傳服務(wù)器功能,希望對(duì)大家有所幫助,如果大家有任何疑問(wèn)請(qǐng)給我留言,小編會(huì)及時(shí)回復(fù)大家的。在此也非常感謝大家對(duì)腳本之家網(wǎng)站的支持!
如果你覺(jué)得本文對(duì)你有幫助,歡迎轉(zhuǎn)載,煩請(qǐng)注明出處,謝謝!

相關(guān)文章

最新評(píng)論