0

私のアプリケーションは、いくつかのディレクトリとそのサブディレクトリをリッスンします。ディレクトリでリッスンするには、JNotifyを使用します。ディレクトリアプリケーションで新しいファイルが作成されると、ファイルがチェックされ、何らかの方法で処理されます。以下はコードです：

import net.contentobjects.jnotify.JNotify;
import net.contentobjects.jnotify.JNotifyListener;

    public class JNotifyDemo {

    public void sample() throws Exception {
        // path to watch
        //String path = System.getProperty("user.home");
        String path = "/folder";
        System.out.println(path);

        // 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(1000000);

        // to remove watch the watch
        boolean res = JNotify.removeWatch(watchID);
        if (!res) {
            // invalid watch ID specified.
        }
    }

    class Listener implements JNotifyListener {

        public void fileRenamed(int wd, String rootPath, String oldName,
                String newName) {
            print("renamed " + rootPath + " : " + oldName + " -> " + newName);
        }

        public void fileModified(int wd, String rootPath, String name) {
            print("modified " + rootPath + " : " + name);
        }

        public void fileDeleted(int wd, String rootPath, String name) {
            print("deleted " + rootPath + " : " + name);
        }

        public void fileCreated(int wd, String rootPath, String name) {
            print("created " + rootPath + " : " + name);
            //check file whether it is xml or not
            //validate xml
            //do some internal processing of file
            // and do other jobs like inserting into database
        }

        void print(String msg) {
            System.err.println(msg);
        }
    }

    public static void main(String[] args) throws Exception {
        new JNotifyDemo().sample();
    }
}

コードからわかるように、アプリケーションは一度に 1 つのファイルを処理します。スレッド化などを使用するなど、このアプリケーションを高速化するためのアドバイスはありますか?

4

2 に答える 2

1

java.nio.file.Pathインターフェースを拡張するものを使用することをお勧めしWatchableます。変更やイベントを監視できるように、監視サービスに登録されている場合があります。

このイベント駆動型のアプローチにより、アプリケーションが高速化されます。例を見てください。

PathWatchableどちらもJava 7に含まれています。

于 2012-12-14T08:54:09.007 に答える
0

実際にどのくらいの処理が行われていますか？IO は非常に遅いことに注意してください。処理にかなりの時間がかからない限り、マルチスレッド ソリューションはファイルの読み取り時にボトルネックになります。

とにかく、並列処理を実装する簡単な方法は、ExecutorServiceRunnableを開始し、ファイル パスをパラメーターとして送信することです。

于 2012-12-14T09:14:31.610 に答える