Java實現(xiàn)文件監(jiān)控器FileMonitor
應用場景：
成都創(chuàng)新互聯(lián)是一家專業(yè)提供花溪企業(yè)網(wǎng)站建設,專注與做網(wǎng)站、網(wǎng)站設計、H5建站、小程序制作等業(yè)務。10年已為花溪眾多企業(yè)、政府機構等服務。創(chuàng)新互聯(lián)專業(yè)網(wǎng)站設計公司優(yōu)惠進行中。
代碼可以實現(xiàn)文件變化后的監(jiān)聽，如文件變化，自動重新加載文件內容，實現(xiàn)配置文件的熱部署。
代碼：
package com.yx.demo.filemonitor;
import java.io.File;
import java.lang.ref.WeakReference;
import java.util.ArrayList;
import java.util.Collection;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Timer;
import java.util.TimerTask;
/**
* FileMonitor
* 文件監(jiān)控器
*
* @author yx
* @date 2019/12/21 0:59
*/
public class FileMonitor {
/**
* 每2秒更新的默認監(jiān)控器
*/
private static FileMonitor defaultFileMonitor = new FileMonitor(2 * 1000);
private Timer timer_;
private HashMap files_; // File -> Long
private List fileEntrys = new java.util.concurrent.CopyOnWriteArrayList();
private Collection> listeners_; // of WeakReference(FileListener)
private long pollingInterval = 10000;
public static FileMonitor getDefaultFileMonitor() {
return defaultFileMonitor;
}
/**
* Create a file monitor instance with specified polling interval.
*
* @param pollingInterval Polling interval in milli seconds.
*/
public FileMonitor(long pollingInterval) {
this.pollingInterval = pollingInterval;
files_ = new HashMap();
listeners_ = new ArrayList>();
timer_ = new Timer("FileMonitor", true);
timer_.schedule(new FileMonitorNotifier(), 0, pollingInterval);
}
/**
* Stop the file monitor polling.
*/
public void stop() {
timer_.cancel();
timer_ = null;
}
public void start() {
if (timer_ == null) {
timer_ = new Timer(true);
timer_.schedule(new FileMonitorNotifier(), 0, pollingInterval);
}
}
/**
* Add file to listen for. File may be any java.io.File (including a
* directory) and may well be a non-existing file in the case where the
* creating of the file is to be trepped.
*
* More than one file can be listened for. When the specified file is
* created, modified or deleted, listeners are notified.
*
* @param file File to listen for.
*/
public void addFile(String id, File file) {
if (!files_.containsKey(file)) {
FileEntry entry = new FileEntry(id, file, file.exists() ? file.lastModified() : -1);
files_.put(file, entry);
}
}
/**
* 添加監(jiān)控文件實體。
*
* @param fileEntry
*/
public void addFileEntry(FileEntry fileEntry) {
if (!fileEntrys.contains(fileEntry)) {
fileEntrys.add(fileEntry);
}
}
/**
* 通過文件實體的標識判斷監(jiān)控文件實體是否存在。
*
* @param id
* @return
*/
public boolean fileEntryExists(String id) {
if (id == null) {
return false;
}
for (int i = 0; i < fileEntrys.size(); i++) {
if (id.equals(fileEntrys.get(i).getId())) {
return true;
}
}
return false;
}
/**
* 通過文件實體標識刪除一個監(jiān)控文件實體。
*
* @param id
*/
public void removeFileEntry(String id) {
if (id == null) {
return;
}
for (int i = 0; i < fileEntrys.size(); i++) {
if (id.equals(fileEntrys.get(i).getId())) {
fileEntrys.remove(i);
return;
}
}
}
/**
* Remove specified file for listening.
*
* @param file File to remove.
*/
public void removeFile(File file) {
files_.remove(file);
}
/**
* Add listener to this file monitor.
*
* @param fileListener Listener to add.
*/
public void addListener(FileListener fileListener) {
// Don't add if its already there
for (Iterator> i = listeners_.iterator(); i.hasNext(); ) {
WeakReference reference = i.next();
FileListener listener = (FileListener) reference.get();
if (listener == fileListener) {
return;
}
}
// Use WeakReference to avoid memory leak if this becomes the
// sole reference to the object.
listeners_.add(new WeakReference(fileListener));
}
/**
* Remove listener from this file monitor.
*
* @param fileListener Listener to remove.
*/
public void removeListener(FileListener fileListener) {
for (Iterator> i = listeners_.iterator(); i.hasNext(); ) {
WeakReference reference = (WeakReference) i.next();
FileListener listener = (FileListener) reference.get();
if (listener == fileListener) {
i.remove();
break;
}
}
}
/**
* This is the timer thread which is executed every n milliseconds according
* to the setting of the file monitor. It investigates the file in question
* and notify listeners if changed.
*/ 鄭州治療婦科哪個醫(yī)院好 http://www.120kdfk.com/
private class FileMonitorNotifier extends TimerTask {
@Override
public void run() {
try {
for (Iterator i = fileEntrys.iterator(); i.hasNext(); ) {
try {
FileEntry entry = i.next();
if (entry == null || !entry.check()) {
i.remove();
}
} catch (Throwable t) {
t.printStackTrace();
System.out.println("執(zhí)行文件監(jiān)控發(fā)生錯誤:" + t.getMessage());
}
}
// Loop over the registered files and see which have changed.
// Use a copy of the list in case listener wants to alter the
// list within its fileChanged method.
Collection files = new ArrayList(files_.keySet());
for (Iterator i = files.iterator(); i.hasNext(); ) {
File file = i.next();
try {
FileEntry fileEntry = files_.get(file);
long lastModifiedTime = fileEntry.getLastModified();
long newModifiedTime = file.exists() ? file.lastModified() : -1;
//logger.debug(file.getAbsolutePath());
//logger.debug(" {}=>{}", lastModifiedTime, newModifiedTime);
// Chek if file has changed
if (newModifiedTime != lastModifiedTime) {
//logger.debug("file changed {})", file.getAbsolutePath());
fileEntry.setLastModified(newModifiedTime);
// Register new modified time
files_.put(file, fileEntry);
if (fileEntry.getFileListener() != null) {
fileEntry.getFileListener().fileChanged(fileEntry);
} else {
// Notify listeners
for (Iterator> j =
listeners_.iterator(); j.hasNext(); ) {
WeakReference reference =
(WeakReference) j.next();
FileListener listener = (FileListener) reference.get();
// Remove from list if the back-end object has been GC'd
if (listener == null) {
j.remove();
} else {
listener.fileChanged(fileEntry);
}
}
}
}
} catch (Throwable t) {
if (file != null) {
t.printStackTrace();
System.out.println(
"file monitor execute error, file=" + file.getAbsolutePath() +
t.getMessage());
} else {
System.out.println(
"file monitor execute error, file=null" + t.getMessage());
}
}
}
} catch (Throwable t) {
System.out.println("執(zhí)行文件監(jiān)控發(fā)生錯誤" + t.getMessage());
}
}
}
}
package com.yx.demo.filemonitor;
/**
* FileListener
*
* @author yx
* @date 2019/12/21 0:55
*/
public interface FileListener {
/**
*
* @param fileEntry
*/
public void fileChanged(FileEntry fileEntry);
}
package com.yx.demo.filemonitor;
import java.io.File;
import java.lang.ref.WeakReference;
/**
* FileEntry
* 文件Entry，如果FileEntry指定了FileListener，那么當文件發(fā)生變動時只觸發(fā)指定的FileListener
*
* @author yx
* @date 2019/12/21 0:56
*/
public class FileEntry {
String id;
File file;
long lastModified;
FileListener fileListener = null;
Object userData;
WeakReference
文章題目：Java實現(xiàn)文件監(jiān)控器FileMonitor
標題URL：http://muchs.cn/article26/gpjhcg.html
成都網(wǎng)站建設公司_創(chuàng)新互聯(lián)，為您提供微信小程序、關鍵詞優(yōu)化、用戶體驗、App開發(fā)、網(wǎng)站排名、Google
聲明：本網(wǎng)站發(fā)布的內容（圖片、視頻和文字）以用戶投稿、用戶轉載內容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內容未經允許不得轉載，或轉載時需注明來源： 創(chuàng)新互聯(lián)
- 企業(yè)網(wǎng)站建設用戶體驗的多種表現(xiàn)形式 2021-10-23
- 網(wǎng)站建設方面對提高用戶體驗的幾點建議 2016-07-31
- 網(wǎng)站設計制作的標準如何精準用戶體驗？ 2023-01-24
- 網(wǎng)站制作中如何增進用戶體驗度 2021-11-09
- 成都網(wǎng)站建設你不可不知的提升用戶體驗的秘訣 2016-10-29
- 房地產網(wǎng)站建設優(yōu)化用戶體驗的有利因素 2022-05-04
- 提高用戶體驗的方法 2021-09-21
- 5個很棒的網(wǎng)站用戶體驗提示 2022-11-12
- 如何設計網(wǎng)站可以擁有更好的用戶體驗？ 2022-11-08
- 網(wǎng)站設計怎樣才能滿足用戶體驗？ 2015-04-07
- 網(wǎng)站優(yōu)化就是優(yōu)化用戶體驗 2021-10-17
- 從三個方面打造更好的網(wǎng)站建設用戶體驗 2022-01-03