我正在尝试使用 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 上运行,或者有什么可能吗?如果不是,那将是一种替代方法。