工具类commons-io的Tailer用来监控文件

Posted 2020-08-12 世界那么大，我想去看看

一、前言：在Linux下有使用tail命令

      在Commons-io中也提供这种方法

二、他采用的是线程方式来监控文件内容的变化

1、Tailer类（采用线程的方式进行文件的内容变法）

2、TailerListener类

3、TailerListenerAdapter类，该类是集成了TailerListener的实现空的接口方式

三、测试使用代码

 

[java] view plain copy

 

1. package com.hadoop.leran.commons.io;  
2.   
3. import org.apache.commons.io.FileUtils;  
4. import org.apache.commons.io.IOUtils;  
5. import org.apache.commons.io.input.Tailer;  
6. import org.apache.commons.io.input.TailerListenerAdapter;  
7.   
8. import java.io.File;  
9.   
10. public class TailerTest {  
11.   
12.     public static void main(String []args) throws Exception{  
13.         TailerTest tailerTest = new TailerTest();  
14.         tailerTest.test();  
15.         boolean flag = true;  
16.         File file = new File("C:/Users/hadoop/Desktop/test/1.txt");  
17.   
18.         while(flag){  
19.             Thread.sleep(1000);  
20.             FileUtils.write(file,""+System.currentTimeMillis()+ IOUtils.LINE_SEPARATOR,true);  
21.         }  
22.   
23.     }  
24.   
25.     public void test() throws Exception{  
26.         File file = new File("C:/Users/hadoop/Desktop/test/1.txt");  
27.         FileUtils.touch(file);  
28.   
29.         Tailer tailer = new Tailer(file,new TailerListenerAdapter(){  
30.   
31.             @Override  
32.             public void fileNotFound() {  //文件没有找到  
33.                 System.out.println("文件没有找到");  
34.                 super.fileNotFound();  
35.             }  
36.   
37.             @Override  
38.             public void fileRotated() {  //文件被外部的输入流改变  
39.                 System.out.println("文件rotated");  
40.                 super.fileRotated();  
41.             }  
42.   
43.             @Override  
44.             public void handle(String line) { //增加的文件的内容  
45.                 System.out.println("文件line:"+line);  
46.                 super.handle(line);  
47.             }  
48.   
49.             @Override  
50.             public void handle(Exception ex) {  
51.                 ex.printStackTrace();  
52.                 super.handle(ex);  
53.             }  
54.   
55.         },4000,true);  
56.         new Thread(tailer).start();  
57.     }  
58. }  

工具类commons-io的文件监控

一、前言：

使用Commons-io的monitor下的相关类可以处理对文件进行监控，它采用的是观察者模式来实现的

1、可以监控文件夹的创建、删除和修改

2、可以监控文件的创建、删除和修改

3、采用的是观察者模式来实现的

4、采用线程去定时去刷现检测文件的变化情况

二、代码分析

（一）、FileAlterationListener分析，提供了检测文件夹和文件的变化回调函数的接口，观察模式回调的接口

        1、提供了文件夹的创建、删除和修改的接口

        2、提供了文件的创建、删除和修改的接口

（二）、FileAlterationListenerAdaptor实现了FileAlterationListener的接口，只是空的实现，可以根据用户的使用情况来处理文件的变化

（三）、FileAlterationObserver重点的观察者模式的类

       1、提供对某路径下文件监控

       2、使用FileFilter来控制对那些文件进行监控，在实际的使用情况是使用FileFilterUtils来控制，他设置了添加一系列的FileFilter

       3、IOCase可以用来对系统的判断，使用是Unix和Windows进行不同的处理，Unix支持文件名的大小写，Windows不区分文件的大小写

（四）、FileAlterationMonitor类

      1、它继承了Runnable接口

      2、它检测文件的过程是采用一个线程去不停的进行文件的检测

      3、精髓之处，文件的内容的改变处理过程

            对于文件的变化有点不太准确，只是判断文件名、文件大小、文件的修改日期来判断

( 五)、FileEntry类

      1、提供了文件夹和文件夹下文件的层级结构

      2、提供了文件是否改变了，采用了备忘录模式(形式上有点，没有很严格的控制)，将上一次的状态进行保存，在比较的时候重新读取新的状态，

            比较完后备忘录重新将新的状态进行保存。

（六）、Common-io中提供一序列的文件的FileFilter类，使用是可以看情况查看源代码

      1、提供了FileFilterUtils来提供添加一些列的FileFilter

      2、添加一序列的FileFilter的实现是使用AndFileFilter来实现的

      3、提供相识的OrFileFilter和NotFileFilter

三、读源代码的测试代码

 

[java] view plain copy

 

1. package com.hadoop.leran.commons.io;  
2.   
3. import org.apache.commons.io.FileUtils;  
4. import org.apache.commons.io.filefilter.FileFilterUtils;  
5. import org.apache.commons.io.filefilter.IOFileFilter;  
6. import org.apache.commons.io.monitor.FileAlterationListenerAdaptor;  
7. import org.apache.commons.io.monitor.FileAlterationMonitor;  
8. import org.apache.commons.io.monitor.FileAlterationObserver;  
9.   
10. import java.io.File;  
11. import java.io.FileFilter;  
12.   
13.  
14. public class FileAlterationObserverTest {  
15.   
16.     public static void main(String []args) throws Exception{  
17.   
18.   
19.         FileAlterationObserverTest fileAlter = new FileAlterationObserverTest();  
20.         fileAlter.test();  
21.         String filePath = "C:/Users/hadoop/Desktop/test/";  
22.         File file = new File(filePath);  
23.         FileUtils.deleteDirectory(file);  
24.         file.mkdirs();  
25.         //File txtFile = new File(filePath+File.separator+System.currentTimeMillis()+".txt");  
26.         //FileUtils.touch(txtFile);  
27. //        File txtFile = new File("C:/Users/hadoop/Desktop/test/1401629335839.txt");  
28. //        txtFile.deleteOnExit();  
29. //        FileUtils.touch(txtFile);  
30.   
31. //        File newFile = new File(filePath+File.separator+System.currentTimeMillis());  
32. //        newFile.mkdirs();  
33.   
34.         boolean flag = true;  
35.         while(flag){  
36.             /***测试文件的变化代码*/  
37. //            File newFileTxt = new File(filePath+File.separator+System.currentTimeMillis()+".txt");  
38. //            FileUtils.touch(newFileTxt);  
39. //            Thread.sleep(2000);  
40. //            FileUtils.write(newFileTxt,"1",true);  
41. //            Thread.sleep(2000);  
42. //            newFileTxt.delete();  
43.   
44.   
45.   
46.             /****测试文件夹的变化代码***/  
47.             File newFile = new File(filePath+File.separator+System.currentTimeMillis());  
48.             newFile.mkdir();  
49.             Thread.sleep(2000);  
50.             File newFileTxt = new File(newFile.getAbsolutePath()+File.separator+System.currentTimeMillis()+".txt");  
51.             FileUtils.touch(newFileTxt);  
52.         }  
53.     }  
54.   
55.     public void test() throws Exception{  
56.         String filePath = "C:/Users/hadoop/Desktop/test/";  
57.         FileFilter filter = FileFilterUtils.and(new MyFileFilter());  
58.         FileAlterationObserver fileAlterationObserver = new FileAlterationObserver(filePath,filter);  
59.         fileAlterationObserver.addListener(new FileAlterationListenerAdaptor() {  
60.   
61.             @Override  
62.             public void onStart(FileAlterationObserver observer) {  
63.                 System.out.println("start on file");  
64.                 super.onStart(observer);  
65.             }  
66.   
67.             @Override  
68.             public void onDirectoryDelete(File directory) {  
69.                 System.out.println("delete file");  
70.                 super.onDirectoryDelete(directory);  
71.             }  
72.   
73.             @Override  
74.             public void onDirectoryCreate(File directory) {  
75.                 System.out.println("create file");  
76.                 super.onDirectoryCreate(directory);  
77.             }  
78.   
79.             @Override  
80.             public void onDirectoryChange(File directory) {  
81.                 System.out.println("change file");  
82.                 super.onDirectoryChange(directory);  
83.             }  
84.   
85.             @Override  
86.             public void onFileCreate(File file) {  
87.                 System.out.println("file create");  
88.                 super.onFileCreate(file);  
89.             }  
90.   
91.             @Override  
92.             public void onFileDelete(File file) {  
93.                 System.out.println("file delete");  
94.                 super.onFileDelete(file);  
95.             }  
96.   
97.             @Override  
98.             public void onFileChange(File file) {  
99.                 System.out.println("file change");  
100.                 super.onFileChange(file);  
101.             }  
102.         });  
103.         FileAlterationMonitor fileAlterationMonitor =  new FileAlterationMonitor(1000);  
104.         fileAlterationMonitor.addObserver(fileAlterationObserver);  
105.         fileAlterationMonitor.start();  
106.     }  
107. }  
108.   
109. /*** 
110.  * 自定义的文件过滤器 
111.  */  
112. class MyFileFilter implements IOFileFilter {  
113.   
114.     @Override  
115.     public boolean accept(File file) {  
116. //        String extension = FilenameUtils.getExtension(file.getAbsolutePath());  
117. //        if(extension!=null&&extension.equals("txt"))  
118. //           return true;  
119. //        return false;  
120.         return true;  
121.     }  
122.   
123.     @Override  
124.     public boolean accept(File dir, String name) {  
125.         //System.out.println("dir:"+dir+"----->"+name);  
126.         return true;  
127.     }  
128. }  

出处：http://blog.csdn.net/xiaoyezi1001/article/details/28095281