zoukankan      html  css  js  c++  java
  • 工具类commons-io的Tailer用来监控文件

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

  • 相关阅读:
    一个docker容器中运行多个服务还是弄一堆docker容器运行?
    golang配置 GoGetProxyConfig,goproxy.io的介绍
    Docker下运行Mysql报错 mbind: Operation not permitted
    linux允许root用户远程登录
    docker-compose 安装 mysql并初始化用户与sql文件
    spring报错 xxxxxxxxxxxx has been injected into other beans
    mysql报错[Warning] IP address 'xxxx' could not be resolved: Name or service not known错误解决
    idea 高效找出全部未被使用的代码
    springboot配置Filter的两种方法
    .net core Elasticsearch 查询更新
  • 原文地址:https://www.cnblogs.com/hd-zg/p/5930636.html
Copyright © 2011-2022 走看看