学习Jnotify文件监视
?学习Jnotify文件监视用例
?
研究文件监视(Windows)，对文件的增加、修改、重命名、删除做记录，找到Java开源技术Jnotify，做了稍微学习，留下一点记录，以资备用，网络上资料有限。
?
?
package com.jnotify;import net.contentobjects.jnotify.JNotify;/** * Monitor file directory file (folder ) is created, modified, deleted, renamed files[folders] * (To adapt to a sub-folders). * JDK: 1.6.0_19 * JAR: jnotify-0.94.jar * @author Dennis Zhao * @createdTime：2012-09-28 * Technology from website: http://jnotify.sourceforge.net/ */public class JNotifyTest { public static void main(String[] args) { JNotifyTest test = new JNotifyTest(); try { test.sample(); } catch (Exception e) { e.printStackTrace(); } } public void sample() throws Exception { // path to watch String path = "D:\\abc"; // watch mask, specify events you care about, // or JNotify.FILE_ANY for all events. int mask = JNotify.FILE_CREATED | JNotify.FILE_DELETED | JNotify.FILE_MODIFIED | JNotify.FILE_RENAMED; // watch subtree? boolean watchSubtree = true; // add actual watch int watchID = JNotify.addWatch(path, mask, watchSubtree, new Listener()); // sleep a little, the application will exit if you // don't (watching is asynchronous), depending on your // application, this may not be required Thread.sleep(15000); //Thread.sleep(5000); // to remove watch the watch boolean res = JNotify.removeWatch(watchID); if (!res) { // invalid watch ID specified. System.out.println("Delete from data : " + watchID); } }}?
?
package com.jnotify;import java.io.File;import java.io.FileWriter;import java.io.IOException;import java.sql.Connection;import java.sql.PreparedStatement;import java.sql.SQLException;import net.contentobjects.jnotify.JNotifyListener;/** * Listener implement * JDK: 1.6.0_19 * JAR: jnotify-0.94.jar * @author Dennis Zhao * @createdTime：2012-09-28 * Technology from website: http://jnotify.sourceforge.net/ */public class Listener implements JNotifyListener { public void fileRenamed(int wd, String rootPath, String oldName, String newName) { writeTextAppend("Renamed==1==File path== [" + rootPath + File.separator + oldName + "] --> [" + rootPath + File.separator + newName + "]==time==" + System.currentTimeMillis()); //print("Renamed " + rootPath + " : " + oldName + " -> " + newName); operateDataDB2(wd,rootPath + File.separator + newName,"Renamed",rootPath,rootPath + File.separator + oldName,rootPath + File.separator + newName); } public void fileModified(int wd, String rootPath, String name) { writeTextAppend("Modified==2==File path== [" + rootPath + File.separator + name + "]==time==" + System.currentTimeMillis()); //print("Modified " + rootPath + " : " + name); operateDataDB2(wd,rootPath + File.separator + name,"Modified",rootPath,"",""); } public void fileDeleted(int wd, String rootPath, String name) { writeTextAppend("Deleted==3==File path== [" + rootPath + File.separator + name + "]==time==" + System.currentTimeMillis()); //print("Deleted " + rootPath + " : " + name); operateDataDB2(wd,rootPath + File.separator + name,"Deleted",rootPath,"",""); } public void fileCreated(int wd, String rootPath, String name) { writeTextAppend("Created==4==File path== [" + rootPath + File.separator + name + "]==time==" + System.currentTimeMillis()); //print("Created " + rootPath + " : " + name); operateDataDB2(wd,rootPath + File.separator + name,"Created",rootPath,"",""); } void print(String msg) { System.out.println(msg); } /** * * writeText * @param record * @return the void */ private void writeTextAppend(final String record) { try { FileWriter writer = new FileWriter("d:\\File_log.txt", true); writer.write(record + "\n"); writer.close(); } catch (IOException e) { e.printStackTrace(); } } /** * * oracle database test * operateDataOracle * @param wd * @param operatName * @param operateType * @param rootPath * @param oldName * @param newName * @return void */ private void operateDataOracle(int wd, String operatName, String operateType, String rootPath, String oldName, String newName) { Connection conn = null; try { Class.forName("oracle.jdbc.driver.OracleDriver"); conn = java.sql.DriverManager.getConnection("jdbc:oracle:thin:@10.199.130.221:1522:ORCL", "scott", "tiger"); String sql = "insert into t_file_log (ID, OP_NAME, OP_DATETIME, OP_ID, OP_TYPE, ROOT_PATH, OLD_NAME, NEW_NAME) " + "values (seq_file_log.nextval, ?, sysdate, ?, ?, ?, ?, ?)"; PreparedStatement pst = conn.prepareStatement(sql); pst.setString(1, operatName); pst.setInt(2, wd); pst.setString(3, operateType); pst.setString(4, rootPath); pst.setString(5, oldName); pst.setString(6, newName); pst.executeUpdate(); pst.close(); } catch (ClassNotFoundException e) { e.printStackTrace(); } catch (SQLException e) { e.printStackTrace(); } finally { if (conn != null) { try { conn.close(); } catch (SQLException e) { e.printStackTrace(); } } } } /** * * DB2 database test * operateDataDB2 * @param wd * @param operatName * @param operateType * @param rootPath * @param oldName * @param newName * @return void */ private void operateDataDB2(int wd, String operatName, String operateType, String rootPath, String oldName, String newName) { Connection conn = null; try { Class.forName("com.ibm.db2.jcc.DB2Driver"); conn = java.sql.DriverManager.getConnection( "jdbc:db2://10.199.30.249:50000/DB902:currentSchema=ORCL;", "SCOTT", "TIGER"); String sql = "insert into TRSUAT.t_file_log (ID, OP_NAME, OP_DATETIME, OP_ID, OP_TYPE, ROOT_PATH, OLD_NAME, NEW_NAME) " + "values (seq_file_log.nextval, ?, sysdate, ?, ?, ?, ?, ?)"; PreparedStatement pst = conn.prepareStatement(sql); pst.setString(1, operatName); pst.setInt(2, wd); pst.setString(3, operateType); pst.setString(4, rootPath); pst.setString(5, oldName); pst.setString(6, newName); pst.executeUpdate(); pst.close(); } catch (ClassNotFoundException e) { e.printStackTrace(); } catch (SQLException e) { e.printStackTrace(); } finally { if (conn != null) { try { conn.close(); } catch (SQLException e) { e.printStackTrace(); } } } }}?
?
?
注意地方：
增加启动命令项，
java -Djava.library.path=. -jar jnotify-VER.jar [dir]
这里有如图Ecplise下面简单设置，如下图
?
?
?
?
?如需要实际业务操作，根据情况做适当调整。
?