2. 程式人生 > >Java實現系統目錄實時監聽更新。

Java實現系統目錄實時監聽更新。

阿新 • • 發佈：2017-05-25
warning xtend absolute ava single sdn data- sdk spl

SDK1.7新增的nio WatchService能完美解決這個問題。美中不足是如果部署在window系統下會出現莫名其妙的文件夾占用異常導致子目錄監聽失效，linux下則完美運行。這個問題著實讓人頭疼。如果有童鞋找到問題根源請一起探討。

這裏簡單的列出用Servlet實現的基本類供大家參考。首先是核心的實現類。

   1
   2
   3
   4
   5
   6
   7
   8
   9
  10
  11
  12
  13
  14
  15
  16
  17
  18
  19
  20
  21
  22
  23
  24
  25
  26
  27
  28
  29
  30
  31
  32
  33
  34
  35
  36
  37
  38
  39
  40
  41
  42
  43
  44
  45
  46
  47
  48
  49
  50
  51
  52
  53
  54
  55
  56
  57
  58
  59
  60
  61
  62
  63
  64
  65
  66
  67
  68
  69
  70
  71
  72
  73
  74
  75
  76
  77
  78
  79
  80
  81
  82
  83
  84
  85
  86
  87
  88
  89
  90
  91
  92
  93
  94
  95
  96
  97
  98
  99
 100
 101
 102
 103
 104
 105
 106
 107
 108
 109
 110
 111
 112
 113
 114
 115
 116
 117
 118
 119
 120
 121
 122
 123
 124
 125
 126
 127
 128
 129
 130
 131
 132
 133
 134
 135
 136
 137
 138
 139
 140
 141
 142
 143
 144
 145
 146
 147
 148
 package com.event; import static java.nio.file.StandardWatchEventKinds.ENTRY_CREATE; import static java.nio.file.StandardWatchEventKinds.ENTRY_DELETE; import static java.nio.file.StandardWatchEventKinds.ENTRY_MODIFY; import static java.nio.file.StandardWatchEventKinds.OVERFLOW; import java.io.File;
 import java.io.IOException; import java.nio.file.FileSystems; import java.nio.file.Path; import java.nio.file.Paths; import java.nio.file.WatchEvent; import java.nio.file.WatchEvent.Kind; import java.nio.file.WatchKey; import java.nio.file.WatchService; import java.util.ArrayList; import java.util.HashMap;
 import java.util.List; import java.util.Map; import java.util.Map.Entry; import java.util.Observable; import java.util.concurrent.Executor; import java.util.concurrent.Executors; import java.util.concurrent.FutureTask; import org.apache.poi.ss.formula.ptg.Ptg; public class DirectoryWatcher extends Observable { // 存儲監聽主鍵和監聽目錄的對應 private static Map<WatchKey, String> pathMap = null; private WatchService watcher;// 目錄監聽服務 private WatchKey key;// 目錄對應的監聽key private Executor executor = Executors.newSingleThreadExecutor(); FutureTask<Integer> task = new FutureTask<Integer>(() -> { processEvents(); return Integer.valueOf(0); }); @SuppressWarnings("unchecked") static <T> WatchEvent<T> cast(WatchEvent<?> event) { return (WatchEvent<T>) event; } public DirectoryWatcher(String dir) throws IOException { watcher = FileSystems.getDefault().newWatchService(); pathMap = new HashMap<WatchKey, String>(); registDirs(dir); } private void registDirs(String dir) throws IOException { List<File> dirs = new ArrayList<File>(); File dirRoot = new File(dir); getAllDirs(dirRoot, dirs); // 循環路徑下所有目錄填充map for (File eveDir : dirs) { Path path = Paths.get(eveDir.getAbsolutePath()); // 監控目錄內文件的更新、創建和刪除事件 try { key = path.register(watcher, ENTRY_CREATE, ENTRY_DELETE); pathMap.put(key, eveDir.getAbsolutePath()); } catch (IOException e) { e.printStackTrace(); } } } // 遞歸獲取所有目錄 private void getAllDirs(File dir, List<File> dirs) { if (dir.isDirectory()) { dirs.add(dir); File[] fs = dir.listFiles(); for (File f : fs) { getAllDirs(f, dirs); } } } /** * 啟動監控過程 */ public void execute() { // 通過線程池啟動一個額外的線程加載Watching過程 executor.execute(task); } /** * 關閉後的對象無法重新啟動 */ public void shutdown() throws IOException { watcher.close(); executor = null; } // * 監控文件系統事件 void processEvents() { while (true) { // 等待直到獲得事件信號 WatchKey signal; try { signal = watcher.take(); } catch (InterruptedException x) { return; } for (WatchEvent<?> event : signal.pollEvents()) { Kind<?> kind = event.kind(); if (kind == OVERFLOW) { continue; } WatchEvent<Path> ev = cast(event); Path name = ev.context(); String fileName = name.getFileName().toString(); String dirPath = pathMap.get(signal) + "/" + fileName; if (kind.name().equals("ENTRY_CREATE") && fileName.indexOf(".") == -1) { Path path = Paths.get(dirPath); try { key = path .register(watcher, ENTRY_CREATE, ENTRY_DELETE); pathMap.put(key, dirPath); } catch (IOException e) { e.printStackTrace(); } } else if (kind.name().equals("ENTRY_DELETE") && fileName.indexOf(".") == -1) { pathMap.remove(key); key.cancel(); } System.out.println("event:" + kind.name() + ";file:" + dirPath); FileWatchEventArgs args = new FileWatchEventArgs(kind.name(), pathMap.get(signal), fileName); notifiy(args);// 通知所有觀察者事件變更 } // 為監控下一個通知做準備 signal.reset(); } } // * 通知外部各個Observer目錄有新的事件更新 void notifiy(FileWatchEventArgs args) { // 標註目錄已經被做了更改 setChanged(); // 主動通知各個觀察者目標對象狀態的變更 notifyObservers(args); } }
來自CODE的代碼片
DirectoryWatcher.java

Servlet的實現類： 
   1
   2
   3
   4
   5
   6
   7
   8
   9
  10
  11
  12
  13
  14
  15
  16
  17
  18
  19
  20
  21
  22
  23
  24
  25
  26
  27
  28
  29
  30
  31
  32
  33
  34
  35
  36
  37
  38
  39
  40
  41
  42
  43
  44
  45
  46
  47
  48
  49
  50
  51
  52
  53
  54
  55
  56
  57
  58
  59
  60
  61
  62
  63
  64
  65
  66
  67
  68
  69
  70
  71
  72
  73
  74
  75
  76
  77
  78
  79
  80
  81
  82
  83
  84
  85
  86
  87
  88
  89
  90
  91
  92
  93
  94
  95
  96
  97
  98
  99
 100
 101
 102
 103
 104
 105
 106
 107
 108
 109
 110
 111
 112
 113
 114
 115
 116
 117
 118
 119
 120
 121
 122
 123
 124
 125
 126
 127
 128
 129
 130
 131
 package com.demo; import java.io.File; import java.io.IOException; import java.util.ArrayList; import java.util.List; import java.util.Observable; import java.util.Observer; import javax.servlet.ServletException; import javax.servlet.http.HttpServlet; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import com.entry.VedioFile; import com.event.DirectoryWatcher; import com.event.FileWatchEventArgs; public class GetList extends HttpServlet implements Observer { private static final long serialVersionUID = 3715567236188574915L; private String PATH; private String JsonTreeStr = null; private static List<VedioFile> vedioFileList; private static ThreadLocal<String> SubRequestURL = new ThreadLocal<String>(); public static ThreadLocal<String> getSubRequestURL() { return SubRequestURL; } public static List<VedioFile> getVedioFileList() { return vedioFileList; } public void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { PATH = request.getServletContext().getRealPath("/") + "/curse"; request.getRequestDispatcher("/WEB-INF/index.jsp").forward(request, response); } public void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { if (vedioFileList == null) { PATH = request.getServletContext().getRealPath("/") + "curse"; System.out.println(PATH); setVedioFileList(); // 建立目錄監聽，註冊觀察者為本身 DirectoryWatcher dw = new DirectoryWatcher(PATH); dw.addObserver(this); dw.execute(); } SubRequestURL .set(request.getRequestURL().toString().split("getList")[0]); JsonTreeStr = vedioFileList.toString(); response.setContentType("text/xml;charset=utf-8"); response.setHeader("Cache-Control", "no-cache"); response.getWriter().write(JsonTreeStr); } @Override // 實現Observer觀察者接口，接收通知 public void update(Observable o, Object arg) { FileWatchEventArgs args = (FileWatchEventArgs) arg; String name = args.getName(); String kind = args.getKind(); String dir = args.getDir(); File file = new File(dir + File.separator + name); if (kind.equals("ENTRY_CREATE")) { addVedioFile(file); } else if (kind.equals("ENTRY_DELETE")) { removeVedioFile(file); } } private void removeVedioFile(File file) { VedioFile nowVf = getNowVedioFile(file); if (nowVf != null) { for (int i = vedioFileList.size() - 1; i >= 0; i--) { if (nowVf.getPath() .equals(vedioFileList.get(i).getParentPath())) { vedioFileList.remove(i); } } vedioFileList.remove(nowVf); } } private VedioFile getNowVedioFile(File file) { VedioFile nowVf = null; for (VedioFile vf : vedioFileList) { if (file.getAbsolutePath().equals(vf.getPath())) { nowVf = vf; break; } } return nowVf; } private void setVedioFileList() { File file = new File(PATH); vedioFileList = new ArrayList<VedioFile>(); getVedioFiles(file, vedioFileList); } private void getVedioFiles(File file, List<VedioFile> vfs) { if (file.isDirectory()) { File[] files = file.listFiles(); for (File f : files) { getVedioFiles(f, vfs); } } addVedioFile(file); } private void addVedioFile(File file) { VedioFile vf = new VedioFile(); vf.setParentPath(file.getParent()); vf.setPath(file.getAbsolutePath()); vf.setName(file.getName()); if (file.getName().toLowerCase().endsWith(".mp4")) { vf.setUrl("vedio?url=" + MD5Utils.md5(vf.getPath())); } vedioFileList.add(vf); } }
來自CODE的代碼片
GetList.java
轉：http://blog.csdn.net/feiying2j/article/details/50719648 附上源碼下載地址： http://download.csdn.net/detail/feiying2j/9439698

Java實現系統目錄實時監聽更新。

相關推薦

Java實現系統目錄實時監聽更新。

warning xtend absolute ava single sdn data- sdk spl SDK1.7新增的nio WatchService能完美解決這個問題。美中不足是如果部署在window系統下會出現莫名其妙的文件夾占用異常導致子目錄監聽失效

java實時監聽日誌寫入kafka

put article -c exti tab round 1.5 valueof max 目的 實時監聽某目錄下的日誌文件，如有新文件切換到新文件，並同步寫入kafka，同時記錄日誌文件的行位置，以應對進程異常退出，能從上次的文件位置開始讀取（考慮到效率，這裏是每

Swift實時監聽網路狀態（更新到Swift3）

最近做個專案，需要實時的監聽網路連線狀態，網路連線斷開時需要提醒使用者手動開啟網路，網路重新連線上之後需要做些操作。身為小白的我感到很有壓力，所以就不自覺的又上度娘那裡去取經了。（哈哈，初學者嘛，大家理解）自己整理下，加深下印象以後也方便用 :) 下面直入正題，如何實現實時監聽網路連線

Java可以如何實現文件的監聽

循環 加載失敗 常見 void execution pwa 改變 都是 depend 應用中使用logback作為日誌輸出組件的話，大部分會去配置 logback.xml 這個文件，而且生產環境下，直接去修改logback.xml文件中的日誌級別，不用重啟應用就可以生效 那

unix/linux 系統實現多個程序監聽同一個埠

F S   UID   PID  PPID  C PRI  NI ADDR SZ WCHAN  TTY          TIME CMD 4 S   500  3019  2370  0  80   0 -  1315 -      tty2     00:00:01 bash 0 S   500  733

JS-實現可拖動的div；實時監聽input標籤value變化

實現可拖動的div var mover = new Mover(document.getElementById("header")); // js封裝：實現可拖動的div. function Mover(title) { this.obj = title; this.st

【java小程式】zookeeper監聽並自動更新

開發需求背景，在開發小程式視訊時(springboot後端），需要一個後臺管理系統（ssm後端），並且這兩個系統是部署在不同的伺服器上，當管理人員通過短視訊後臺管理背景音樂的上傳和刪除，需要小程式端的伺服器能通過監聽能自動下載背景音樂。這裡我們就通過zookeeper中介軟體，springb

關於JAVA中事件分發和監聽機制實現的程式碼例項-絕對原創實用

轉載：http://blog.csdn.net/5iasp/article/details/37054171 謝謝博主 ====================================================================

JAVA 使用Interface 實現自己的事件監聽

上班沒什麼事做，看了一下同事的程式碼。覺得挺有意思，於是拿出來分享一下，當然這不是什麼很難得技術，很多人都能夠呀看得懂。所以這一次也是很輕鬆的學習。 對於介面，我們使用最多的莫過於在設定控制元件的點選事件中了，例如： view.setOn

java中的key事件監聽機制

com java.awt imp package 時間 ext javax .get pri package com.at221; import java.awt.event.KeyAdapter; import java.awt.event.KeyEvent; im

js 實時監聽input中值變化

對象 不同 round 字符 實時 char div har 但是 摘自：http://blog.csdn.net/spy19881201/article/details/25537225 示例： <!DOCTYPE html> <html>

實時監聽輸入框值變化的完美方案：oninput & onpropertychange

ner 監聽 jpg number ima 方案 radio 技術 search 　　oninput 是 HTML5 的標準事件，對於檢測 textarea, input:text, input:password 和 input:search 這幾個元素通過用戶界面發生

類似吸頂功能解決io不能實時監聽onscroll的觸發問題

內核 所有 ble 解決 classname 監聽 頁面 osi window 問題：近期項目需要一個類似西東功能，當頁面向上滾動160px後div固定在頂部 解決方法：首先，想到的是window.onscroll方法 　　.fixed{position:fixed;-we

jquery實時監聽輸入框值變化

property per 並且 details dom 支持 觸發事件 java 不能 在做web開發時候很多時候都需要即時監聽輸入框值的變化，以便作出即時動作去引導瀏覽者增強網站的用戶體驗感。而采用onchange時間又往往是在輸入框失去焦點（onblur）時候觸發，有時

實時監聽數據示例

頁面 NPU 標識 log gis for temp true IE 1、基於長輪詢、queue實現 app01.py #基於queue實現在線實時投票 import uuid import queue from flask import Flas

利用Maxwell組件實時監聽Mysql的binlog日誌

nbsp 重啟 mysqld pan cli 生成 flush rest 插入數據 一：在linux環境下安裝部署好mysql 開啟binlog Vim /etc/my.cnf mysql的binlog格式有3種，為了把binlog解析成json數據格式，要設置b

input輸入框內容變化實時監聽

lur 螞蟻 onchange copy word arch 知識 -- 並且 js實現的文本框內容發生改變立馬觸發事件簡單介紹:本章節介紹一下如何在文本框的內容發生變化的時候，立馬觸發一個事件執行響應的操作，而不是像是keydown或者keyup事件一樣，只能夠檢測通過鍵

Linux系統配置ssh監聽多個埠方法

1、為避免其他使用者惡意登陸裝置，一般會修改ssh登陸的埠修改方法如下： 在配置檔案 /etc/ssh/sshd_config 檔案中修改 Port 5022 #AddressFamily any#listenAddress 0.0.0.0:22 #ListenAdd

JQuery 實時監聽文字框變化

文章目錄 JQuery 實時監聽文字框變化 html 的文字框 js 程式碼 JS 監聽長按事件 $(f

JS 實時監聽input的value值改變 解決方案

該方案在 FoxFire、Chrome、360急速、Microsoft Edge、IE11下測試均可以正常顯示。 html頁面程式碼： <!DOCTYPE html><html><head> <meta charset="