学习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下面简单设置，如下图

 

 

 

 

 如需要实际业务操作，根据情况做适当调整。