java - Java のディレクトリ スキャナ

Question

ディレクトリのセットを連続的にスキャンして、一連のファイル名フィルターを探します。到着したファイル名フィルターごとに、ファイルを処理し、すべてのファイルについて手順を繰り返します。

おそらく java.concurrent.Executor と Future を使用して、 jdk 1.5 でこれに推奨される設計は何ですか

Answer 1

Webクローラーで同様のタスクを実行しました。いくつかの変更を加える必要がありました...これは、新しく見つかったディレクトリがExecutor Frameworkのスレッドプールによってスキャンされる同時実装です.QueueとListの同時コレクションを使用しますインデックス付きファイルを保持します。インデクサーはキューからファイルを取得し、それらに対して何らかの処理を行います。ここに FileFilter 実装があります

    public class ImageFileFilter implements FileFilter
    {
      private final String[] okFileExtensions = 
        new String[] {"jpg", "png", "gif"};

      public boolean accept(File file)
      {
        for (String extension : okFileExtensions)
        {
          if (file.getName().toLowerCase().endsWith(extension))
          {
            return true;
          }
        }
        return false;
      }
    }

これがメインメソッドを持つクラスです...

     public class FileFilterTest {
        public static void main(String[] args) {
            File dir = new File("D:\\dev\\css-templates\\cms-admin");
            BlockingQueue blockingQueue = new ArrayBlockingQueue(5);
            FileCrawler fileCrawler = new FileCrawler(blockingQueue,
                    new ImageFileFilter(), dir);
            new Thread(fileCrawler).start();

            FileIndexer indexer = new FileIndexer(blockingQueue);
            new Thread(indexer).start();
        }
    }

ファイルクローラーのスレッドはこちら

     public class FileCrawler implements Runnable {
            private final BlockingQueue fileQueue;
            private ConcurrentSkipListSet indexedFiles = new ConcurrentSkipListSet();
            private final FileFilter fileFilter;
            private final File root;
            private final ExecutorService exec = Executors.newCachedThreadPool();

            public FileCrawler(BlockingQueue fileQueue,
                               final FileFilter fileFilter,
                               File root) {
                this.fileQueue = fileQueue;
                this.root = root;
                this.fileFilter = new FileFilter() {
                    public boolean accept(File f) {
                        return f.isDirectory() || fileFilter.accept(f);
                    }
                };
            }

            public void run() {

                    submitCrawlTask(root);

            }

            private void submitCrawlTask(File f) {
                CrawlTask crawlTask = new CrawlTask(f);
                exec.execute(crawlTask);
            }

            private class CrawlTask implements Runnable {
                private final File file;

                CrawlTask(File file ) {

                    this.file= file;
                }

             public void run() {        
                 if(Thread.currentThread().isInterrupted())
                return;

                    File[] entries = file.listFiles(fileFilter);

                    if (entries != null) {
                        for (File entry : entries)
                            if (entry.isDirectory())
                                submitCrawlTask(entry);
                            else if (entry !=null && !indexedFiles.contains(entry)){
                                indexedFiles.add(entry);
                                try {
                                    fileQueue.put(entry);
                                } catch (InterruptedException e) {
                                        Thread.currentThread().interrupt();
                                }
                            }
                    }
                }
        }
       }

これがファイルインデクサースレッドです

        public class FileIndexer implements Runnable {
        private final BlockingQueue queue;

        public FileIndexer(BlockingQueue queue) {
            this.queue = queue;
        }

        public void run() { 
            try {
                while (true) {
                    indexFile(queue.take());
                }
            } catch (InterruptedException e) {
                System.out.println("Indexer Interrupted");
                Thread.currentThread().interrupt();
            }
        }

        public void indexFile(File file) {
            // do something with the file...
            System.out.println("Indexing File : " + file.getAbsolutePath() + " " + file.getName());
        };
    }

Answer 2

これがあなたがやろうとしていることだと思います：

1. ディレクトリのセットがあります：

   dir1
   dir2
   dir3

2. また、特定のファイル名パターンについて、これら 3 つのディレクトリに「監視」を配置する必要があります。例: 新しいファイルが name:watchme_9192.logで追加された場合、Java ロジックが起動してそのファイルを処理する必要があります。

したがって、その仮定に基づいて、次のことを試すことができます。

JNotify は、Java アプリケーションが次のようなファイル システム イベントをリッスンできるようにする Java ライブラリです。
ファイルが作成された
ファイルが変更された
ファイルの名前が変更された
ファイルが削除され た

また、関連：ディレクトリポーリングのベストプラクティス