Java 實(shí)現(xiàn)實(shí)時(shí)監(jiān)聽(tīng)文件夾是否有新文件增加并上傳服務(wù)器功能
本文中主要陳述一種實(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)文章
Java根據(jù)開(kāi)始時(shí)間和結(jié)束時(shí)間及周幾計(jì)算日期的示例代碼
在Java 7中,java.time包不存在,所以我們需要使用java.util.Calendar和java.util.Date類來(lái)實(shí)現(xiàn)類似的功能,這篇文章主要介紹了Java根據(jù)開(kāi)始時(shí)間和結(jié)束時(shí)間及周幾計(jì)算出日期的示例代碼,需要的朋友可以參考下2024-06-06RocketMQ根據(jù)Tag進(jìn)行消息過(guò)濾
消費(fèi)者訂閱了某個(gè)主題后,Apache RocketMQ 會(huì)將該主題中的所有消息投遞給消費(fèi)者。若消費(fèi)者只需要關(guān)注部分消息,可通過(guò)設(shè)置過(guò)濾條件在 Apache RocketMQ 服務(wù)端進(jìn)行過(guò)濾,只獲取到需要關(guān)注的消息子集,避免接收到大量無(wú)效的消息2023-02-02Netty分布式ByteBuf使用subPage級(jí)別內(nèi)存分配剖析
這篇文章主要為大家介紹了Netty分布式ByteBuf使用subPage級(jí)別內(nèi)存分配剖析,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2022-03-03java并發(fā)編程synchronized底層實(shí)現(xiàn)原理
這篇文章主要介紹了java并發(fā)編程synchronized底層實(shí)現(xiàn)原理2022-02-02java實(shí)現(xiàn)ftp上傳 如何創(chuàng)建文件夾
這篇文章主要為大家詳細(xì)介紹了java實(shí)現(xiàn)ftp上傳的相關(guān)資料,教大家如何創(chuàng)建文件夾?具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2017-04-04javax.persistence中@Column定義字段類型方式
這篇文章主要介紹了javax.persistence中@Column定義字段類型方式,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2022-11-11JPA @Basic單表查詢?nèi)绾螌?shí)現(xiàn)大字段懶加載
這篇文章主要介紹了JPA @Basic單表查詢?nèi)绾螌?shí)現(xiàn)大字段懶加載的操作,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2021-08-08淺談springioc實(shí)例化bean的三個(gè)方法
下面小編就為大家?guī)?lái)一篇淺談springioc實(shí)例化bean的三個(gè)方法。小編覺(jué)得挺不錯(cuò)的,現(xiàn)在就想給大家,也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧2017-09-09