C#编程中怎么对文件目录进行实时监控

本文主锋老要描述如何通过C＃实现实时监控文件目录下的变化，包括文件和目录的添加，删除，修改和重命名等 *** 作。 首先，我搜誉们需银漏升要对.net提供的FileSystemWatcher类有所了解。我有些懒，找了MSDN对该类的描述。 FileSystemWatcher类侦听文件系统更改通

许多情况下 如果创建或修改一个文件 系统需要执行某些任务 例如 在一个数据库中插入平面文件的重要系统就是如此

在这种情况下 程序必须监控目录中新建立的文件 如果目录中新建了一个文件 程序必须提取这个文件 进行解析 再把它插入到数据库中

许多时候 这类功能要通过 调查 目录并列举上次调查后任何新建的文件来完成 在 NET Framework中 微软为开发者提供另一种连续调查一个目录中的新建文件的方法——FileSystemWatcher对象

FileSystemWatcher对象为你完成目录监控工作 如果新建 更新或删除一个文件 FileSystemWatcher将提交一个事件 通知你发生了一项改变 这样 新建一个文件后 你的程序立即就知道可以使用这个文件 立即通知改变使得你的系统以更高的效率工作 因为你不能总是 调查 目录中发生的改变 而且在两次目录扫描之间也不会有时间流失

FileSystemWatcher基础

在应用FileSystemWatcher对象之前 你必须了解这个对象的一些基本属性和事件 毫无疑问 这个对象的最重要的属性为 EnableRaisingEvents 属性

这个属性决定对象在收到改变通知时是否提交事件 如果EnableRaisingEvents属性设为假 对象将不会提交改变事件 如果设为真 它将提交改变事件 下面是你在应用FileSystemWatcher对象时将要用到的其它一些重要属性/事件

属性

Path——这个属性告诉FileSystemWatcher它需要监控哪条路径 例如 如果我们将这个属性设为 C:Temp 对象就监控那个目录发生的所有改变 IncludeSubDirectories——这个属性说明FileSystemWatcher对象是否应该监控子目录中发生的改变 Filter——这个属性允许你过滤掉某些类型的文件发生的变化 例如 如果我们只希望在TXT文件被修改/新建/删除时提交通知 可以将这个属性设为 *txt 在处理高流量或大型目录时 使用这个属性非常方便

事件

Changed——当被监控的目录中有一个文件被修改时 就提交这个事件 值得注意的是 这个事件可能会被提交多次 即使文件的内容仅仅发生一项改变 这是由于在保存文件时 文件的其它属性也发生了改变 Created——当被监控的目录新建一个文件时 就提交这个事件 如果你计划用这个事件移动新建的事件 你必须在事件处理器中写入一些错误处理代码 它能处理当前文件被其它进程使用的情况 之所以要这样做 是因为Created事件可能在建立文件的进程释放文件之前就被提交 如果你没有准备正确处理这种情况的代码 就可能出现异常 Deleted——当被监控的目录中有一个文件被删除 就提交这个事件 Renamed——当被监控的目晌嫌闷录中有一个文件被重命名 就提交这宴弯个事件

注 如果你没有将EnableRaisingEvents设为真 系统不会提交任何一个事件 如果有时FileSystemWatcher对象似乎无法工作 请首先检查EnableRaisingEvents 确保它被设为真

事件处理

当FileSystemWatcher调用一个事件处理器时 它包含两个自变量——一个叫做 sender 的对象和一个叫做 e 的FileSystemEventArgs对象 我们感兴趣的自变量为FileSystemEventArgs自变量 这个对象中包含有提交事件的原因 以下是FileSystemEventArgs对象的一些属性

属性

Name——这个属性中使事件被提交的文件的名称 其中并不包含文件的路径——只包含使用事件被提交的文件或目录名称 ChangeType——这是一个WatcherChangeTypes 它指出要提交哪个类型的事件 其有效值包括 ○ Changed○ Created○ Deleted○ Renamed FullPath——这个属性中包含使事件被提交的文件的完整路径 包括文件名和目者肢录名

代码实例

列表A列出了FileSystemWatcher对象的一个简单应用实例 在这个例子中 我们监控 C:Temp 目录中是否建立了* TXT文件 这可能是FileSystemWatcher的最简单用法

列表A

publicvoid CreateWatcher()

{

//Create a new FileSystemWatcher

FileSystemWatcher watcher = newFileSystemWatcher()

//Set the filter to only catch TXT files

watcher Filter = * txt

//Subscribe to the Created event

watcher Created += new

FileSystemEventHandler(watcher_FileCreated)

//Set the path to C:Temp

watcher Path = @ C:Temp

//Enable the FileSystemWatcher events

watcher EnableRaisingEvents = true

}

void watcher_FileCreated(object sender FileSystemEventArgs e)

{

//A new TXT file has been created in C:Temp

Console WriteLine( A new * txt file has been created! )

}

这篇文章下载版本的样本项目中还提供了另外一些实例

应用

最初 FileSystemWatcher的用途可能并不明显 当然 如果一个文件或目录发生改变 它会向我们发出警报 但在哪些情况下我们需要这类信息呢？

如果一个系统允许客户端上传文件进行处理 这时可能就要用到FileSystemWatcher对象 尽管很明显我们已经进入Web服务和SOA时代 但许多系统仍然要将平面文件插入到某些位置 不管是FTP服务器或网络共享文件夹中 我已经将FileSystemWatcher对象应用到这种类型的系统中 虽然并不是完全没有出错 但它在 调查 目录变化方面确实有一定的优势

如果你想让两个文件保持同步 这时也可以用到FileSystemWatcher对象 你可以用FileSystemWatcher同时监控这两个文件的位置 如果其中一个出现更新 就提交一个Changed事件 然后你就可以将这些改变复制到其它系统/文件中

lishixinzhi/Article/program/net/201311/13620

JavaSE 1.7提供了相关的API，去监视文件或者文件夹的变动，主要的API都在java.nio.file下面，其大概流程如下：

package org.xdemo.superutil.j2se.filewatch

 闭咐

import static java.nio.file.LinkOption.NOFOLLOW_LINKS

 

import java.io.File

import java.io.IOException

import java.nio.file.FileSystems

import java.nio.file.FileVisitResult

import java.nio.file.Files

import java.nio.file.Path

import java.nio.file.Paths

import java.nio.file.SimpleFileVisitor

import java.nio.file.StandardWatchEventKinds

import java.nio.file.WatchEvent

import java.nio.file.WatchEvent.Kind

import java.nio.file.WatchKey

import java.nio.file.WatchService

import java.nio.file.attribute.BasicFileAttributes

import java.util.HashMap

import java.util.Map

 

/**

 * 文件夹监控

 * 

 * @author Goofy <a href="http://www.xdemo.org/">http://www.xdemo.org/</a>

 * @Date 2015年7月3日 上午9:21:33

 */

public class WatchDir {

 

    private final WatchService watcher

    private final Map<WatchKey, Path> keys

    private final boolean subDir

 

    /**

     * 构造方法

     * 

     * @param file

     *            文件目录，不可以是文件

     * @param subDir

     * @throws Exception

     */

    public WatchDir(File file, boolean subDir, FileActionCallback callback) throws Exception {

        历裤if (!file.isDirectory())

            throw new Exception(file.getAbsolutePath() + "is not a directory!")

 

        this.watcher = FileSystems.getDefault().newWatchService()

        this.keys = new HashMap<WatchKey, Path>()

        this.subDir = subDir

 

        Path dir = Paths.get(file.getAbsolutePath())

 

        if (subDir) {

            registerAll(dir)

        } else {

            register(dir)

        }

        processEvents(callback)

    }

 

    @SuppressWarnings("unchecked")

    static <T> WatchEvent<T> cast(WatchEvent<?> event) {

        return (WatchEvent<T>) event

    }

 

    /**

     * 观察指定的目录

     * 

     * @param dir

     * @throws IOException

     */

    private void register(Path dir) throws IOException {

        WatchKey key = dir.register(watcher, StandardWatchEventKinds.ENTRY_CREATE, StandardWatchEventKinds.ENTRY_DELETE, StandardWatchEventKinds.ENTRY_MODIFY)

   肢态简     keys.put(key, dir)

    }

 

    /**

     * 观察指定的目录，并且包括子目录

     */

    private void registerAll(final Path start) throws IOException {

        Files.walkFileTree(start, new SimpleFileVisitor<Path>() {

            @Override

            public FileVisitResult preVisitDirectory(Path dir, BasicFileAttributes attrs) throws IOException {

                register(dir)

                return FileVisitResult.CONTINUE

            }

        })

    }

 

    /**

     * 发生文件变化的回调函数

     */

    @SuppressWarnings("rawtypes")

    void processEvents(FileActionCallback callback) {

        for () {

            WatchKey key

            try {

                key = watcher.take()

            } catch (InterruptedException x) {

                return

            }

            Path dir = keys.get(key)

            if (dir == null) {

                System.err.println(" *** 作未识别")

                continue

            }

 

            for (WatchEvent<?> event : key.pollEvents()) {

                Kind kind = event.kind()

 

                // 事件可能丢失或遗弃

                if (kind == StandardWatchEventKinds.OVERFLOW) {

                    continue

                }

 

                // 目录内的变化可能是文件或者目录

                WatchEvent<Path> ev = cast(event)

                Path name = ev.context()

                Path child = dir.resolve(name)

                File file = child.toFile()

                if (kind.name().equals(FileAction.DELETE.getValue())) {

                    callback.delete(file)

                } else if (kind.name().equals(FileAction.CREATE.getValue())) {

                    callback.create(file)

                } else if (kind.name().equals(FileAction.MODIFY.getValue())) {

                    callback.modify(file)

                } else {

                    continue

                }

 

                // if directory is created, and watching recursively, then

                // register it and its sub-directories

                if (subDir && (kind == StandardWatchEventKinds.ENTRY_CREATE)) {

                    try {

                        if (Files.isDirectory(child, NOFOLLOW_LINKS)) {

                            registerAll(child)

                        }

                    } catch (IOException x) {

                        // ignore to keep sample readbale

                    }

                }

            }

 

            boolean valid = key.reset()

            if (!valid) {

                // 移除不可访问的目录

                // 因为有可能目录被移除，就会无法访问

                keys.remove(key)

                // 如果待监控的目录都不存在了，就中断执行

                if (keys.isEmpty()) {

                    break

                }

            }

        }

    }

 

}

---