此文章是基于 搭建Jquery+SpringMVC+Spring+Hibernate+MySQL平台
一. 相关文件介绍
1. applicationInterface.xml，spring配置文件，可设置监测的文件夹、扫描时间、指定监控哪些扩展名的文件
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:tx="http://www.springframework.org/schema/tx" xmlns:aop="http://www.springframework.org/schema/aop"
xmlns:context="http://www.springframework.org/schema/context"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.1.xsd
http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.1.xsd
http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.1.xsd
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.1.xsd"> <!-- 文件监测器 -->
<bean id="monitor"
class="com.ims.interfaces.file.monitor.FileMonitorImpl"> <constructor-arg index="0" value="10000" /> <!-- 监测时间间隔，单位：毫秒 -->
<constructor-arg index="1" ref="observer" /> <!-- 文件观察器 -->
</bean> <!-- 文件观察器 -->
<bean id="observer"
class="com.ims.interfaces.file.monitor.FileObserverImpl"> <constructor-arg index="0" value="D:\\UploadDir"/> <!-- 观察的目录 -->
<constructor-arg index="1" ref="filter"/> <!-- 文件过滤器-->
<constructor-arg index="2" ref="listener"/> <!-- 文件监听器 -->
</bean> <!-- 文件监听器 -->
<bean id="listener"
class="com.ims.interfaces.file.monitor.FileListener"/> <!-- 文件过滤器 -->
<bean id="filter"
class="com.ims.interfaces.file.monitor.FileFilterImpl">
<!--
指定文件扩展名，只有指定的扩展名文件会被处理。
不同的扩展名间以 "," 间隔，如：xml,txt,bak
-->
<constructor-arg index="0" value="xml"/>
</bean>
</beans>
2. SpringContextLoaderListener.java，spring上下文加载监听器，服务运行时启动扫描，结束时关闭扫描
package com.ims.web; import javax.servlet.ServletContextEvent; import org.springframework.web.context.ContextLoaderListener; import com.ims.interfaces.file.monitor.FileMonitor; /**
* Spring场景加载监听器，用于加载/销毁Spring场景
*/
public class SpringContextLoaderListener extends ContextLoaderListener { public SpringContextLoaderListener() {
super();
} @Override
public void contextInitialized(ServletContextEvent event) {
super.contextInitialized(event); FileMonitor scanner = getScanner();
// 启动目录扫描器
scanner.start();
} @Override
public void contextDestroyed(ServletContextEvent event) { FileMonitor scanner = getScanner();
// 关闭目录扫描器
scanner.stop(); super.contextDestroyed(event);
} /**
* 获取目录扫描器
* @return
*/
private FileMonitor getScanner() {
return getCurrentWebApplicationContext().getBean(FileMonitor.class);
} }
3. web.xml，web工程配置文件
如果存在如下代码，则去掉
<listener>
<listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
</listener>
然后添加上如下代码：
<listener>
<listener-class>com.ims.web.SpringContextLoaderListener</listener-class>
</listener>
4. 文件监测器
4.1. 接口：FileMonitor.java
package com.ims.interfaces.file.monitor; import org.apache.commons.io.monitor.FileAlterationObserver; /**
* 文件监测器角色
*/
public interface FileMonitor { /**
* 注册观察器
* @param observer 观察器
*/
void addObserver(FileAlterationObserver observer); /**
* 删除观察器
* @param observer 观察器
*/
void removeObserver(FileAlterationObserver observer); /**
* 获取注册的所有观察器
* @return 观察器集合
*/
Iterable<FileAlterationObserver> getObservers(); /**
* 启动监测器
*/
void start(); /**
* 停止监测器
*/
void stop(); /**
* 获取监测间隔时间
* @return 间隔时间（单位：毫秒）
*/
long getInterval(); }
4.2. 实现类：FileMonitorImpl.java
package com.ims.interfaces.file.monitor; import java.util.concurrent.ThreadFactory; import org.apache.commons.io.monitor.FileAlterationMonitor;
import org.apache.commons.io.monitor.FileAlterationObserver;
import org.apache.commons.lang3.concurrent.BasicThreadFactory; /**
* 监测器，监测时间间隔，设置文件观察器
*/
public class FileMonitorImpl implements FileMonitor{ private final FileAlterationMonitor monitor; /**
* 监测器线程名称
*/
private static final String MONITOR_THREAD_NAME = "File MONITOR Daemon"; /**
* 监测器线程Daemon标记
*/
private static final boolean DAEMON = false; /**
* 定义监测时间间隔、文件观察器
* @param interval 监测时间间隔
* @param observer 文件观察者
*/
FileMonitorImpl(int interval, final FileAlterationObserver observer) {
this(interval, observer,
new BasicThreadFactory.Builder().
namingPattern(MONITOR_THREAD_NAME).daemon(DAEMON).build());
} /**
* 定义监测时间间隔、文件观察器和线程工厂
* @param interval 监测时间间隔
* @param observer 文件观察器
* @param factory 线程工厂
*/
FileMonitorImpl(int interval, final FileAlterationObserver observer,
final ThreadFactory factory) {
this.monitor = new FileAlterationMonitor(interval, new FileAlterationObserver[] { observer });
monitor.setThreadFactory(factory);
} /**
* 添加文件观察器
* @param observer
*/
@Override
public void addObserver(FileAlterationObserver observer) {
monitor.addObserver(observer);
} /**
* 删除文件观察器
* @param observer
*/
@Override
public void removeObserver(FileAlterationObserver observer) {
monitor.removeObserver(observer);
} /**
* 获取注册的所有观察器
* @return
*/
@Override
public Iterable<FileAlterationObserver> getObservers() {
return monitor.getObservers();
} /**
* 启动监测器
*/
@Override
public void start() {
try {
monitor.start();
}
catch (Exception e) {
e.printStackTrace();
}
} /**
* 停止监测器
*/
@Override
public void stop() {
try {
monitor.stop();
}
catch (Exception e) {
e.printStackTrace();
}
} /**
* 获取监测时间间隔
*/
@Override
public long getInterval() {
return monitor.getInterval();
} }
5. 文件观察器
5.1. 接口：FileObserver.java
package com.ims.interfaces.file.monitor; import java.io.File; import org.apache.commons.io.monitor.FileAlterationListener; /**
* 文件观察器角色
*/
public interface FileObserver { /**
* 添加监听器
* @param listener
*/
void addListener(final FileAlterationListener listener); /**
* 删除监听器
* @param listener
*/
void removeListener(final FileAlterationListener listener); /**
* 获取注册的监听器
* @return
*/
Iterable<FileAlterationListener> getListeners(); /**
* 初始化观察器
* @throws Exception
*/
void initialize() throws Exception; /**
* 销毁观察器
* @throws Exception
*/
void destroy() throws Exception; /**
* 获取观察的目录
* @return
*/
File getDirectory(); /**
* 获取文件过滤器
*
* @return
*/
public FileFilter getFilter();
}
5.2. 实现类：FileObserverImpl.java
package com.ims.interfaces.file.monitor; import java.io.File;
import java.io.IOException; import org.apache.commons.io.FileUtils;
import org.apache.commons.io.IOCase;
import org.apache.commons.io.monitor.FileAlterationListener;
import org.apache.commons.io.monitor.FileAlterationObserver; /**
* 文件观察器
*
* 当有文件创建、删除、或变更动作时，则消息通知监听器
*/
public class FileObserverImpl extends FileAlterationObserver implements FileObserver{ private static final long serialVersionUID = -7239227289538993830L; /**
* 文件过滤器
*/
private final FileFilter filter; /**
* 设置要监听观察的目录，并设置文件过滤器和监听器，用以观察指定具有指定扩展名的文件
* @param dir 观察监听的目录
* @param filter 文件过滤器
* @param listener 文件监听器
*/
public FileObserverImpl(String dir, final FileFilter filter,
FileAlterationListener listener) {
super(dir, filter, (IOCase) null);
addListener(listener); this.filter = filter; File directory = new File(dir); // 如果目录不存在
if(!directory.exists()) {
try {
FileUtils.forceMkdir(directory);
}
catch (IOException e) {
e.printStackTrace();
}
}
// 如果存在的是文件
else if(directory.exists() && directory.isFile()) {
try {
FileUtils.forceDelete(directory);
FileUtils.forceMkdir(directory);
}
catch (IOException e) {
e.printStackTrace();
}
}
} /**
* 添加监听器
*/
@Override
public void addListener(final FileAlterationListener listener) {
super.addListener(listener);
} /**
* 移除监听器
*/
@Override
public void removeListener(final FileAlterationListener listener) {
super.removeListener(listener);
} /**
* 获取观察者对象的所有监听器
*/
@Override
public Iterable<FileAlterationListener> getListeners() {
return super.getListeners();
} /**
* 初始化文件观察者
*/
@Override
public void initialize() throws Exception {
super.initialize();
} /**
* 销毁文件观察者
*/
@Override
public void destroy() throws Exception {
super.destroy();
} /**
* 获取所观察的目录
*/
@Override
public File getDirectory() {
return super.getDirectory();
} /**
* 获取文件过滤器
* @return
*/
public FileFilter getFilter() {
return filter;
}
}
6. 文件监听器：FileListener.java
package com.ims.interfaces.file.monitor; import java.io.File; import org.apache.commons.io.monitor.FileAlterationListenerAdaptor;
import org.apache.commons.io.monitor.FileAlterationObserver; /**
* 文件监听器
*/
public final class FileListener extends FileAlterationListenerAdaptor { /**
* 文件创建时执行的动作
*/
@Override
public void onFileCreate(File file) {
// To do something
System.out.println("Create file: "+file.getName());
} /**
* 文件删除（转移）时执行的动作
*/
@Override
public void onFileDelete(File file) {
// To do something
System.out.println("Delete file: "+file.getName());
} /**
* 文件内容改变时执行的动作
*/
@Override
public void onFileChange(File file) {
// To do something
} /**
* 开始执行监听时执行的动作
*/
@Override
public void onStart(FileAlterationObserver observer) {
// To do something
} /**
* 停止监听时执行的动作
*/
@Override
public void onStop(FileAlterationObserver observer) {
// To do something
}
}
7. 文件过滤器
7.1. 接口：FileFilter.java
package com.ims.interfaces.file.monitor; /**
* 文件过滤器角色，扩展自java.io.FileFilter
*/
public interface FileFilter extends java.io.FileFilter { /**
* 获取定义的扩展名
*
* @return
*/
String[] getExtensions();
}
7.2. 实现类：FileFilterImpl.java
package com.ims.interfaces.file.monitor; import java.io.File; import org.apache.commons.io.FilenameUtils; /**
* 文件过滤器
*/
public class FileFilterImpl implements FileFilter{ private String[] extensions; public FileFilterImpl(String... extensions) {
this.extensions = extensions;
} /**
* 是否接受该文件
*/
@Override
public boolean accept(File pathname) {
return FilenameUtils.isExtension(pathname.getName(), extensions);
} /**
* 获取定义的扩展名
* @return
*/
@Override
public String[] getExtensions() {
return extensions;
} }
二. 测试
在 "D:\UploadDir" 目录下，新建或删除xml格式的文件，FileListener.java 会在后台打印出文件的名字