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

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

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

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

2、TailerListener类

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

三、测试使用代码

[java]view plaincopy

packagecom.hadoop.leran.commons.io;
importorg.apache.commons.io.FileUtils;
importorg.apache.commons.io.IOUtils;
importorg.apache.commons.io.input.Tailer;
importorg.apache.commons.io.input.TailerListenerAdapter;
importjava.io.File;
publicclassTailerTest{
publicstaticvoidmain(String[]args)throwsException{
TailerTesttailerTest=newTailerTest();
tailerTest.test();
booleanflag=true;
Filefile=newFile("C:/Users/hadoop/Desktop/test/1.txt");
while(flag){
Thread.sleep(1000);
FileUtils.write(file,""+System.currentTimeMillis()+IOUtils.LINE_SEPARATOR,true);
}
}
publicvoidtest()throwsException{
Filefile=newFile("C:/Users/hadoop/Desktop/test/1.txt");
FileUtils.touch(file);
Tailertailer=newTailer(file,newTailerListenerAdapter(){
@Override
publicvoidfileNotFound(){//文件没有找到
System.out.println("文件没有找到");
super.fileNotFound();
}
@Override
publicvoidfileRotated(){//文件被外部的输入流改变
System.out.println("文件rotated");
super.fileRotated();
}
@Override
publicvoidhandle(Stringline){//增加的文件的内容
System.out.println("文件line:"+line);
super.handle(line);
}
@Override
publicvoidhandle(Exceptionex){
ex.printStackTrace();
super.handle(ex);
}
},4000,true);
newThread(tailer).start();
}
}

工具类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 plaincopy

packagecom.hadoop.leran.commons.io;
importorg.apache.commons.io.FileUtils;
importorg.apache.commons.io.filefilter.FileFilterUtils;
importorg.apache.commons.io.filefilter.IOFileFilter;
importorg.apache.commons.io.monitor.FileAlterationListenerAdaptor;
importorg.apache.commons.io.monitor.FileAlterationMonitor;
importorg.apache.commons.io.monitor.FileAlterationObserver;
importjava.io.File;
importjava.io.FileFilter;
publicclassFileAlterationObserverTest{
publicstaticvoidmain(String[]args)throwsException{
FileAlterationObserverTestfileAlter=newFileAlterationObserverTest();
fileAlter.test();
StringfilePath="C:/Users/hadoop/Desktop/test/";
Filefile=newFile(filePath);
FileUtils.deleteDirectory(file);
file.mkdirs();
//FiletxtFile=newFile(filePath+File.separator+System.currentTimeMillis()+".txt");
//FileUtils.touch(txtFile);
//FiletxtFile=newFile("C:/Users/hadoop/Desktop/test/1401629335839.txt");
//txtFile.deleteOnExit();
//FileUtils.touch(txtFile);
//FilenewFile=newFile(filePath+File.separator+System.currentTimeMillis());
//newFile.mkdirs();
booleanflag=true;
while(flag){
/***测试文件的变化代码*/
//FilenewFileTxt=newFile(filePath+File.separator+System.currentTimeMillis()+".txt");
//FileUtils.touch(newFileTxt);
//Thread.sleep(2000);
//FileUtils.write(newFileTxt,"1",true);
//Thread.sleep(2000);
//newFileTxt.delete();
/****测试文件夹的变化代码***/
FilenewFile=newFile(filePath+File.separator+System.currentTimeMillis());
newFile.mkdir();
Thread.sleep(2000);
FilenewFileTxt=newFile(newFile.getAbsolutePath()+File.separator+System.currentTimeMillis()+".txt");
FileUtils.touch(newFileTxt);
}
}
publicvoidtest()throwsException{
StringfilePath="C:/Users/hadoop/Desktop/test/";
FileFilterfilter=FileFilterUtils.and(newMyFileFilter());
FileAlterationObserverfileAlterationObserver=newFileAlterationObserver(filePath,filter);
fileAlterationObserver.addListener(newFileAlterationListenerAdaptor(){
@Override
publicvoidonStart(FileAlterationObserverobserver){
System.out.println("startonfile");
super.onStart(observer);
}
@Override
publicvoidonDirectoryDelete(Filedirectory){
System.out.println("deletefile");
super.onDirectoryDelete(directory);
}
@Override
publicvoidonDirectoryCreate(Filedirectory){
System.out.println("createfile");
super.onDirectoryCreate(directory);
}
@Override
publicvoidonDirectoryChange(Filedirectory){
System.out.println("changefile");
super.onDirectoryChange(directory);
}
@Override
publicvoidonFileCreate(Filefile){
System.out.println("filecreate");
super.onFileCreate(file);
}
@Override
publicvoidonFileDelete(Filefile){
System.out.println("filedelete");
super.onFileDelete(file);
}
@Override
publicvoidonFileChange(Filefile){
System.out.println("filechange");
super.onFileChange(file);
}
});
FileAlterationMonitorfileAlterationMonitor=newFileAlterationMonitor(1000);
fileAlterationMonitor.addObserver(fileAlterationObserver);
fileAlterationMonitor.start();
}
}
/***
*自定义的文件过滤器
*/
classMyFileFilterimplementsIOFileFilter{
@Override
publicbooleanaccept(Filefile){
//Stringextension=FilenameUtils.getExtension(file.getAbsolutePath());
//if(extension!=null&&extension.equals("txt"))
//returntrue;
//returnfalse;
returntrue;
}
@Override
publicbooleanaccept(Filedir,Stringname){
//System.out.println("dir:"+dir+"----->"+name);
returntrue;
}
}

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

优质内容筛选与推荐>>
1、网络操作与AFNetworking
2、转载-软件测试职业发展方向
3、药剂科处方点评的数据过滤
4、这是时间的推移不是系统的分类
5、优化前台标题，导航，面包屑导航，列表页左侧产品属性，及分类h1标签内文字。

0 │ 收藏 │ 举报

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

工具类commons-io的文件监控

朋友将在看一看看到

分享想法到看一看