分享一个文件监听器类:FileMonitor

   一直使用tomcat开发，只要将<Context docBase="MyTest" path="/MyTest" reloadable="true" /></Host>中的reloadable属性设置成true.Tomcat就能自动监测到某个文件发生了改变，然后重新装载。由于对这个有点兴趣，所有也试着写了一个简单的实现，但对于文件夹下的多个文件监测，除了把每个文件都加入监测器中外，没有更好的思路和方法。大家可以讨论一下：

 

除件有我测试的整个eclipse工程文件，有兴趣的童鞋们可以看一下.

 

FileMonitor类的代码如下所示：

 

public class FileMonitor {
	private static final FileMonitor instance = new FileMonitor();
	private Timer timer;
	private Map<String, FileMonitorTask> timerEntries;

	private FileMonitor() {
		this.timerEntries = new HashMap<String, FileMonitorTask>();
		this.timer = new Timer();
	}

	public static FileMonitor getInstance() {
		return instance;
	}

	/**
	 * 对某个文件实行监听
	 * 
	 * @param listener
	 *            The file listener
	 * @param filename
	 *            The filename to watch
	 * @param period
	 *            The watch interval.
	 */
	public void addFileChangeListener(FileChangeListener listener,

	String filename, long period) {
		this.removeFileChangeListener(filename);

		FileMonitorTask task = new FileMonitorTask(listener, filename);

		this.timerEntries.put(filename, task);
		this.timer.schedule(task, period, period);
	}

	/**
	 * 停止对某个文件的监听
	 * 
	 * @param listener
	 *            The file listener
	 * @param filename
	 *            The filename to keep watch
	 */
	public void removeFileChangeListener(String filename) {
		FileMonitorTask task = (FileMonitorTask) this.timerEntries
				.remove(filename);

		if (task != null) {
			task.cancel();
		}
	}

	private static class FileMonitorTask extends TimerTask {
		private FileChangeListener listener;
		private String filename;
		private File monitoredFile;
		private long lastModified;

		public FileMonitorTask(FileChangeListener listener, String filename) {
			this.listener = listener;
			this.filename = filename;

			this.monitoredFile = new File(filename);
			if (!this.monitoredFile.exists()) {
				return;
			}

			this.lastModified = this.monitoredFile.lastModified();
		}

		public void run() {
			long latestChange = this.monitoredFile.lastModified();
			if (this.lastModified != latestChange) {
				this.lastModified = latestChange;
				//对发生改变的文件调用处理方法
				this.listener.fileChanged(this.filename);
			}
		}
	}
}

 

当监听到文件发生改变时处理的类如下所示：

public class ClassFileChangeListener implements FileChangeListener {

	/*
	 * 当被监听的文件发生改变时，调用此方法
	 * */
	public void fileChanged(String filename) {
		System.out
				.println("File " + filename + " modified ,it must  reload  !");
	}
} 

 

当web容器启动时，将要监听的文件加入到文件监听器类中，servet类如下所示：

 

public class InitServlet extends HttpServlet {
	private static final long serialVersionUID = 1L;
	
	@Override
	public void init(ServletConfig config) throws ServletException {
		// TODO Auto-generated method stub
		super.init(config);
		long period = Long.parseLong(config.getInitParameter("period"));
		String filename = config.getInitParameter("filename");
		if(period > 0 && filename != null && !filename.isEmpty()){
			//String realPath = config.getServletContext().getRealPath("");
			//String filename = realPath + "\\WEB-INF\\classes\\jdbc.propertis";
			FileMonitor.getInstance().addFileChangeListener(new ClassFileChangeListener(), filename, period);
		}
		
	}

	/**
	 * @see HttpServlet#HttpServlet()
	 */
	public InitServlet() {
		super();
		// TODO Auto-generated constructor stub
	}
}

 

 

 web.xml中的配置如下所示：

 

 

<servlet>
		<description></description>
		<display-name>InitServlet</display-name>
		<servlet-name>InitServlet</servlet-name>
		<servlet-class>servlet.InitServlet</servlet-class>
		<init-param>
			<!-- the period of watching file -->
			<param-name>period</param-name>
			<!--  milliseconds -->
			<param-value>1000</param-value>
		</init-param>
		<init-param>
			<param-name>filename</param-name>
			<param-value>D:/aa.txt</param-value>
		</init-param>
		<load-on-startup>0</load-on-startup>
	</servlet>

 由于使用eclipse开发时，eclipse中的tomcat，将文件部署在了：D:\workspace\.metadata\.plugins\org.eclipse.wst.server.core\tmp3\wtpwebapps

下面，如我的这个工程中的jdbc.properties文件部署成了D:\workspace\.metadata\.plugins\org.eclipse.wst.server.core\tmp3\wtpwebapps\MyTest\WEB-INF\classes\jdbc.propertis,

此时使用此路径创建的File不存在，所以为了方便测试，我将要监听的文件路径作为InitServlet的一个初始化参数了。

 

除件是整个工程的文件，直接导入eclipse中即可使用。

评论

12 楼 knight_black_bob 2016-03-02  

楼主 ，怎么监听 远程 文件夹 ？

11 楼 小勇12 2011-06-22  

不晓得是否底层又是用JNI来完成的

10 楼 qiuboboy 2011-06-21  

你去找找有个java的开源实现，可以监控文件系统的。

9 楼 liyun_1981 2011-06-21  

支持楼主一个，觉得可在fileChanged方法里面加入自定义运行时类加载的逻辑，这样就比较有实用价值了。
PS：楼上几个都没说到点子上。。。

8 楼 cs624178950 2011-06-20  

呵呵！还是不错，，

7 楼 chenchuan 2011-06-20  

好像java7里面已经加上了这个功能了 具体的没有用过 模糊的记得Java7新特性监听文件改变
http://blog.csdn.net/jastar/archive/2011/03/18/6259500.aspx

6 楼 ryxxlong 2011-06-19  

gzfreeman 写道

好像apache的commons-io库就有可提供FileMonitor的功能阿

谢谢，commons-io库确实有FileMonitor的功能

Commons IO is a library of utilities to assist with developing IO functionality.
There are six main areas included:
Utility classes - with static methods to perform common tasks
Input - useful Input Stream and Reader implementations
Output - useful Output Stream and Writer implementations
Filters - various implementations of file filters
Comparators - various implementations of java.util.Comparator for files
File Monitor - a component for monitoring file system events

5 楼 甄子丹 2011-06-19  

apache vfs可以监听文件变化

4 楼 gzfreeman 2011-06-19  

好像apache的commons-io库就有可提供FileMonitor的功能阿

3 楼 ryxxlong 2011-06-17  

kimmking 写道

1\lastmodified不准
2\1000ms太长了
3\Timer太浪费了

还是等jdk支持操作系统级的fileWatch吧~(jdk7)

呵呵，我现在的水平只能想到这，谢谢你的建议

2 楼 kimmking 2011-06-17  

1\lastmodified不准
2\1000ms太长了
3\Timer太浪费了

还是等jdk支持操作系统级的fileWatch吧~(jdk7)

1 楼 ryxxlong 2011-06-17  

竟然没一个人有兴趣，真是杯具