`
oboaix
  • 浏览: 273860 次
社区版块
存档分类
最新评论

学习Jnotify文件监视

    博客分类:
  • JAVA
 
阅读更多



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

 

 

 

 

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

 

  • 描述: java -Djava.library.path 简单设置
  • 大小: 129.7 KB
分享到:
评论

相关推荐

    java文件监控例子--jnotify

    在Java中,实现文件监控的一种流行库是`jnotify`。`jnotify`是一个轻量级的库,它提供了一个简单的方式来监控文件系统的变化。这个例子将深入探讨如何使用`jnotify`来实现文件监控。 `jnotify`库通过JNI(Java ...

    JNotify监控文件夹及文件变化.zip

    在Java开发中,有时我们需要实时监控文件或文件夹的变化,...通过学习和使用这个库,你可以提升应用程序的实时性,使其能够对文件系统的动态变化做出响应。这个资料包提供了一个很好的起点,帮助你理解和实践这一功能。

    Jnotify-0.94源码

    总的来说,Jnotify-0.94源码包提供了深入了解Java文件系统监控的一个机会,无论是对学习JNI、操作系统交互,还是对优化文件系统监控应用都极具价值。通过阅读源码,你可以学习到如何利用底层系统服务,以及如何编写...

    jnotify(包含dll与so).rar

    《jnotify:跨平台文件系统监控利器》 在IT领域,高效管理和监控文件系统变动是一项重要的任务,尤其在开发和运维场景中。jnotify就是这样一款工具,它为Java开发者提供了跨平台的文件系统变动监控功能。这个压缩包...

    jNotify漂亮的提示插件

    通常,你可以将下载的压缩包解压后,将`jnotify.css`和`jnotify.js`文件放入你的项目资源目录中。然后,在HTML文件的`<head>`部分添加以下引用: ```html <link rel="stylesheet" href="path/to/jnotify.css"> ...

    jnotify32.dll

    jnotify32 位

    Jquery jNotify

    由于其文件大小仅为2KB,jNotify具有很高的性能优势,不会对网站加载速度产生显著影响,因此在资源有限的项目中特别受欢迎。 **主要特点:** 1. **易用性**:jNotify设计简洁,开发者只需要编写少量代码就能快速...

    jnotify资料及源码.zip

    JNotify,一个支持动态监控文件和文件夹(支持级联监控)的架包。在linux系统中,调用的是linux底层的inotify服务,只是添加了对子文件夹级联监控的功能。在windows中,需要添加附件的dll文件,因为windows默认没有...

    监视指定文件的变化.rar

    在IT领域,监视指定文件的变化是一项重要的任务,特别是在系统监控、日志分析、软件调试以及自动化脚本编写等场景中。这项技术可以帮助我们实时获取文件的更新情况,以便及时响应和处理相关事件。下面将详细讲解如何...

    jnotify_64bit.dll

    jnotify_64bit jnotify_64bit jnotify_64bit jnotify_64bit

    jnotify-lib-0.93

    1. **jnotify.dll** 和 **jnotify_64bit.dll**:这是针对Windows系统的本地库,提供了对文件系统变更事件的底层支持。 2. **libjnotify.dylib**:适用于Mac OS X系统的动态链接库,同样用于实现文件系统监控。 3. **...

    jnotify-lib-0.93.rar

    总的来说,jnotify-lib-0.93是一个强大的工具,可以帮助Java开发者轻松实现对文件系统的实时监控,广泛应用于日志监控、文件同步、版本控制系统等领域。其简洁的API设计和良好的跨平台性,使其成为Java开发中的必备...

    java文件监控例子

    通过学习这个例子,你可以了解如何在自己的Java应用中集成文件监控功能,提升程序的响应性和实时性。在实际开发中,可以根据需求调整监控的粒度和性能优化,比如设置适当的缓冲以减少不必要的回调,或者采用异步处理...

    文件实时监控

    在IT领域,文件实时监控是一项重要的技术,它用于持续跟踪并记录文件系统中的变化,确保数据的安全性和一致性。本文将详细解析"文件实时监控"这一主题,并基于描述中提到的每五分钟一次的文件内容同步机制进行深入...

    jNotify:操作结果信息提示条

    例如,如果库文件名为`jnotify.js`,可以这样引入: ```html <script src="path/to/jnotify.js"> ``` 2. **初始化** 在引入库文件后,需要对jNotify进行初始化。这通常在文档加载完成后执行,以确保DOM已经...

    FileSync 文件监控同步工具

    例如,一个任务可能只需要监视特定类型的文件,而另一个任务可能需要在文件变化后立即进行全量同步,或者是设置为在指定时间点进行增量同步。这种灵活性使得FileSync适应各种工作场景,无论是个人项目还是大型企业...

    window文件系统索引引擎

    用java写的windows下的文件搜索程序,底层索引存储采用bst(二叉排序树),构造索引时采用深度递归算法(偏慢),只支持对文件的索引,不支持对文件夹的索引,采用jnotify监听文件的新建,修改,删除和重命名,同时自动...

    文件内容监控程序

    1. 文件系统监视服务(FileSystemWatcher):在.NET框架中,FileSystemWatcher是一个内置的类,可以用来监视指定目录及其子目录中的文件和目录的创建、更改和删除事件。通过订阅这些事件,我们可以实现实时的文件...

    基于Java的实例源码-目录监视器源程序.zip

    学习和理解这些源码可以帮助我们更好地掌握Java的文件系统监控能力,以及如何在实际项目中实现高效可靠的目录监视器。在开发过程中,根据具体需求,我们可以选择使用标准的`WatchService`API,或者采用第三方库来...

Global site tag (gtag.js) - Google Analytics