首页 > 代码库 > 工具类commons-io的Tailer用来监控文件

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

2024-08-15 16:06:29   223人阅读

一、前言：在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

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


联系
我们