Java 實現(xiàn)實時監(jiān)聽文件夾是否有新文件增加并上傳服務器功能
本文中主要陳述一種實時監(jiān)聽文件夾中是否有文件增加的功能,可用于實際文件上傳功能的開發(fā)。
主要實現(xiàn)方式:
(1)利用Timer的定時循環(huán)執(zhí)行代碼的功能;
(2)利用WatchService實時監(jiān)聽文件夾是否有新文件增加,通過阻塞式IO流實現(xiàn)文件上傳服務器。
代碼如下:
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)聽文件夾
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());//根據(jù)后綴判斷
url = uploadFile(file1,uploadAddres);//上傳服務器
}if (!key.reset()) {
break; //中斷循環(huán)
}
}
}catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}, 2000 , 3000);//第一個數(shù)字2000表示,2000ms以后開啟定時器,第二個數(shù)字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;
// 用循環(huán)從流中讀取文件的大小
while ((length = in.read(buffer)) > 0) {
out.write(buffer, 0, length);
}
// 設置圖片標題和全路徑
imgURL = "uploadFile/" + fileName;
System.out.println("絕對路徑為"+imgURL);
// 關閉輸入流輸出流,釋放內(nèi)存
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,出現(xiàn)如下界面:

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

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

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


切換JRE后,該錯誤就會消失。
總結
以上所述是小編給大家介紹的Java 實現(xiàn)實時監(jiān)聽文件夾是否有新文件增加并上傳服務器功能,希望對大家有所幫助,如果大家有任何疑問請給我留言,小編會及時回復大家的。在此也非常感謝大家對腳本之家網(wǎng)站的支持!
如果你覺得本文對你有幫助,歡迎轉載,煩請注明出處,謝謝!
相關文章
Spring使用@Autowired為抽象父類注入依賴代碼實例
這篇文章主要介紹了Spring使用@Autowired為抽象父類注入依賴代碼實例,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2019-11-11
Sharding-jdbc報錯:Missing the data source
在使用MyBatis-plus進行數(shù)據(jù)操作時,新增Order實體屬性后,出現(xiàn)了數(shù)據(jù)源缺失的提示錯誤,原因是因為userId屬性值使用了隨機函數(shù)生成的Long值,這與sharding-jdbc的路由規(guī)則計算不匹配,導致無法找到正確的數(shù)據(jù)源,通過調(diào)整userId生成邏輯2024-11-11
Spring?Boot深入學習數(shù)據(jù)訪問之Spring?Data?JPA與Hibernate的應用
Spring?Data?JPA是Spring?Data的子項目,在使用Spring?Data?JPA之前,先了解一下Hibernate,因為Spring?Data?JPA是由Hibernate默認實現(xiàn)的2022-10-10

