您好,登錄后才能下訂單哦!
這期內容當中小編將會給大家帶來有關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; }
注:如果在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后,該錯誤就會消失。
上述就是小編為大家分享的Java中怎么實時監聽文件夾是否有新文件增加了,如果剛好有類似的疑惑,不妨參照上述分析進行理解。如果想知道更多相關知識,歡迎關注億速云行業資訊頻道。
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。