Jetty Scanner 를 이용한 특정 디렉토리 및 파일 변경사항(delete, change, add) 모니터링

maven jetty plugin 옵션 중에 scanIntervalSeconds 라는 옵션을 줘서 파일이 변경됬을 경우 일정시간 마다 서버를 리스타트 하는 기능이 있다.

이것과 비슷하게 지정된 특정 디렉토리에 파일이나 디렉토리가 생성, 삭제, 변경 되는 것을 모니터링 하는 클래스를 맨들어 보았다.

이것을 위해서 Jetty util 패키지에 있는 Scanner 클래스를 사용했다.

maven 사용자는 다음과 같은 dependency 를 추가한다.

1. <dependency>
2.     <groupId>org.eclipse.jetty</groupId>
3.     <artifactId>jetty-util</artifactId>
4.     <version>8.0.1.v20110908</version>
5. </dependency>

maven 사용안하는 사람은 jetty-util-8.0.1.v20110908.jar 요파일을 클래스 패스에 추가 시켜 주면 된다. 

jetty-util-8.0.1.v20110908.jar

FileChangeScanner 클래스는 다음과 같다. DiscreteListener 클래스의 각각의 경우에 대해서 원하는 엑션을 취해주면 된다.

1. package scanner;
2.  
3. import java.io.File;
4. import java.io.FileFilter;
5. import java.util.ArrayList;
6. import java.util.List;
7. import java.util.Timer;
8. import java.util.TimerTask;
9.  
10. import org.eclipse.jetty.util.Scanner;
11.  
12. public class FileChangeScanner {
13.     private Scanner scanner;
14.  
15.     public FileChangeScanner(String targetDir){
16.         List<File> scanFiles = new ArrayList<File>();
17.          
18.         searchSubDirs(targetDir, scanFiles);
19.          
20.         scanner = new Scanner();
21.         scanner.setScanInterval(1);          // 1초 간격으로 변경사항 스캔
22.         scanner.setScanDirs(scanFiles);
23.         scanner.setReportExistingFilesOnStartup(false);
24.          
25.         scanner.addListener(new Scanner.DiscreteListener() {
26.             public void fileRemoved(String filename) throws Exception {
27.                 System.out.println(filename + " is deleted");
28.             }
29.              
30.             public void fileChanged(String filename) throws Exception {
31.                 System.out.println(filename + " is changed");
32.             }
33.              
34.             public void fileAdded(String filename) throws Exception {
35.                 File f = new File(filename);
36.                 if(f.isDirectory()) scanner.addScanDir(f);
37.                  
38.                 System.out.println(filename + " is added");
39.             }
40.         });
41.     }
42.      
43.     public void start(){
44.         try {
45.             scanner.start();
46.         } catch (Exception e) {
47.             new RuntimeException(e);
48.         }
49.     }
50.      
51.     /**
52.      * 하위 디렉토리들 찾기
53.      * @param targetDir
54.      * @param dirs
55.      * @return
56.      */
57.     private List<File> searchSubDirs(String targetDir, final List<File> dirs){
58.         File target = new File(targetDir);
59.         target.listFiles(new FileFilter() {
60.             public boolean accept(File file) {
61.                 if( file.isDirectory() ) {
62.                     dirs.add(file);
63.                     searchSubDirs(file.toString(), dirs);
64.                 }
65.                 return false;
66.             }
67.         });
68.          
69.         return dirs;
70.     }
71.  
72.     public static void main(String[] args) throws Exception{
73.         // c:\test 하위 폴더 및 파일 변경 감시
74.         new FileChangeScanner("c:\\test").start();
75.          
76.         // 실행하자 마자 프로그램이 종료되기 때문에 프로그램 종료방지를 위해 타이머 생성
77.         // WAS 환경에서 돌릴때는 타이머 생성할 필요없음
78.         Timer timer = new Timer();
79.         timer.scheduleAtFixedRate(new TimerTask() {
80.             public void run() {}
81.         }, 60*1000, 60*1000 );
82.     }
83. }

출처 : http://stove99.tistory.com/61