1

我正在尝试使用 Java SE 7 中提供的 WatchService 观看远程目录(在网络机器上)。当我在 Windows XP 上运行程序时它工作得很好,但在 Windows 7 上 WatchService.take() 不会等待,返回一个无效的密钥。

这是示例代码:

import java.io.IOException;
import java.nio.file.FileSystems;
import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.nio.file.StandardOpenOption;
import java.nio.file.StandardWatchEventKinds;
import java.nio.file.WatchEvent;
import java.nio.file.WatchKey;
import java.nio.file.WatchService;
import java.nio.file.WatchEvent.Kind;

public class MyWatchingService {

public void watchDir(Path path) throws IOException, InterruptedException {

    try (WatchService watchService = FileSystems.getDefault().newWatchService()) {

        path.register(watchService, StandardWatchEventKinds.ENTRY_CREATE, StandardWatchEventKinds.ENTRY_DELETE);        

        while (true) {
            // gets a watch key
            final WatchKey key = watchService.take();

            // retrieves pending events for a key.
            for (WatchEvent<?> watchEvent : key.pollEvents()) {

                // retrieves the event type and count.
                // gets the kind of event (create, delete) 
                final Kind<?> kind = watchEvent.kind();

                // handles OVERFLOW event
                if (kind == StandardWatchEventKinds.OVERFLOW) {
                    continue;
                } 

                final WatchEvent<Path> watchEventPath = cast(watchEvent);
                final Path entry = watchEventPath.context();

                // outputs an event type and entry
                System.out.println(kind + " -> " + entry);
            }

            boolean valid = key.reset();

            //exit loop if the key is not valid
            if (!valid) {
                System.out.println("Key is invalid!");
                break;
            }
        }

    }
}

public void writeFile (Path path, String fileName) throws IOException {
    Path target = Paths.get(path.toString(), fileName);
    if (target.toFile().exists()) {
        Files.delete(target);
        System.out.println("file is deleted ok!");
    }
    Path fileTo = Files.createFile(target);
    Files.write(fileTo, String.valueOf(true).getBytes(), StandardOpenOption.WRITE);
    System.out.println("file is written ok!");
}

@SuppressWarnings("unchecked")
private static <T> WatchEvent<T> cast(WatchEvent<?> event) {
    return (WatchEvent<T>)event;
}

/**
 * @param args
 */
public static void main(String[] args) {

    // case 1: network directory mapped to Y volume
    final Path path = Paths.get("Y:/workspace");
    // case 2: local directory: 
//  final Path path = Paths.get("D:/workspace");

    MyWatchingService service = new MyWatchingService();
    try {
        long start = System.currentTimeMillis();
        service.watchDir(path);
        System.out.println("exiting after " + Long.toString(System.currentTimeMillis() - start) + "ms...");
        service.writeFile(path, "test");
    } catch (IOException e) {
        e.printStackTrace();
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
}
}

这是输出:

Key is invalid!
exiting after 16ms...
file is deleted ok!
file is written ok!

如您所见,我检查了是否可以在此网络目录中写入/删除文件。我也尝试过不映射定义这样的路径://server/workspace也没有运气。如果我为带有本地目录的注释掉的案例 2 运行相同的程序,那么它会进入等待状态,并且没有预期的输出。

我使用 64 位的 jdk1.7.0_17。(我尝试了 32 位的 jre7,但也没有运气)。远程目录位于 Windows Server 2008 R2 Standard 上。

我在 API 中读到了以下句子,这让我怀疑这根本不可能:

如果监视的文件不在本地存储设备上,则是否可以检测到对文件的更改是特定于实现的。特别是,不需要检测在远程系统上对文件进行的更改。

这对我来说是个坏消息,因为我使用 WatchService 在这个策略上投入了大量时间。有人有任何想法/经验,为什么它不能在 Windows 7 上运行,或者有什么可能吗?如果不是,那将是一种替代方法。

4

1 回答 1

2

正如文档所说:我根本不希望“观看”在网络驱动器工作。

它是否工作肯定取决于客户端的操作系统及其配置,以及服务器的操作系统及其配置,以及其他一些未知因素;似乎极其脆弱,不值得指望。

文档中也提到了一个简单的替代方案:

[...] 或在本地设施不可用时使用原始机制,例如轮询

轮询方法可以在纯 Java 中实现,而无需使用NIO。警告:可能会导致大量资源使用(网络)。

并且,与往常一样,建议您退后一步,重新考虑您是否真的需要在这些文件系统操作上构建您的“网络协议”,或者您是否可以通过其他方式实现您想要/需要的东西。

于 2013-03-28T18:08:41.453 回答