Java8 predicate with try catch



我是java8流词的新手,但我想了解这一点。 在做了一些简单的东西之后,我更深入了,所以我喜欢列出文件夹中的所有文件。我从这里得到了这个想法。

Files.walk(start)
.filter(Files::isRegularFile)
.forEach(System.out::println);

它运行得很好,但我运行了一个文件夹,那里有一些规范文件,并抛出AccessDeniedException.我做了一些搜索,我知道这不是一个简单的问题。我尝试像这样处理异常:

private static Predicate<Path> fillAccessDenied() {
return p -> {
try {
if(Files.isRegularFile(p)) {                    
return true;                
} else {
return false;
}
} catch (UncheckedIOException e) {
e.printStackTrace();
return false;
}
};
}
//....
Files.walk(start)
.filter(Utils.fillAccessDenied())
.forEach(System.out::println);

但问题仍然存在,我不明白为什么。有人可以给我一些线索,这里有什么问题吗?

提前感谢!

编辑:

我在尝试捕获之间取出了系统,但问题仍然存在。

public static void println(Object x) {
try {
String s = String.valueOf(x);
System.out.println(s);
} catch (UncheckedIOException e) {
e.printStackTrace();
}
}
//...
Files.walk(start)
.filter(Utils.fillAccessDenied())
.forEach(Utils::println);

我的输入路径"/",我在 Linux 上运行它。它会导致此问题吗?

堆栈跟踪:

java.io.UncheckedIOException: java.nio.file.AccessDeniedException: /etc/sysconfig/network/providers
at java.nio.file.FileTreeIterator.fetchNextIfNeeded(FileTreeIterator.java:88)
at java.nio.file.FileTreeIterator.hasNext(FileTreeIterator.java:104)
at java.util.Iterator.forEachRemaining(Iterator.java:115)
at java.util.Spliterators$IteratorSpliterator.forEachRemaining(Spliterators.java:1801)
at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:481)
at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:471)
at java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:151)
at java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:174)
at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:418)
at hu.gergelylakatos.jbackupper.JBackupper.main(JBackupper.java:45)
Caused by: java.nio.file.AccessDeniedException: /etc/sysconfig/network/providers
at sun.nio.fs.UnixException.translateToIOException(UnixException.java:84)
at sun.nio.fs.UnixException.rethrowAsIOException(UnixException.java:102)
at sun.nio.fs.UnixException.rethrowAsIOException(UnixException.java:107)
at sun.nio.fs.UnixFileSystemProvider.newDirectoryStream(UnixFileSystemProvider.java:427)
at java.nio.file.Files.newDirectoryStream(Files.java:457)
at java.nio.file.FileTreeWalker.visit(FileTreeWalker.java:300)
at java.nio.file.FileTreeWalker.next(FileTreeWalker.java:372)
at java.nio.file.FileTreeIterator.fetchNextIfNeeded(FileTreeIterator.java:95)
... 10 more

当异常未在这个地方抛出时,您无法在Files.isRegularFile处捕获异常。由于异常是在实现Files.walk迭代逻辑的代码中抛出的,因此只有在forEach方法已经终止整个操作时,才能捕获它。

您可以自己实现迭代逻辑以获得更多控制。 例如

public static Stream<Path> traverse(Path p, BiConsumer<Path,IOException> handler) {
if(Files.isDirectory(p)) try {
return Stream.concat(Stream.of(p),
Files.list(p).flatMap(sub -> traverse(sub, handler)));
} catch(IOException ex) {
handler.accept(p,ex);
}
return Stream.of(p);
}

你可以像这样使用

traverse(start, (p,ex) -> System.err.println(p+": "+ex))
.filter(Files::isRegularFile)
.forEach(System.out::println);

以打印异常并继续,或

traverse(start, (p,ex) -> { throw new UncheckedIOException(ex); })
.filter(Files::isRegularFile)
.forEach(System.out::println);

Files.walk一样纾困.


当您知道自己只对常规文件感兴趣时,您可以创建一个专门的方法,例如

public static Stream<Path> traverseLeafs(Path p, BiConsumer<Path,IOException> handler) {
if(Files.isDirectory(p)) try {
return Files.list(p).flatMap(sub -> traverseLeafs(sub, handler));
} catch(IOException ex) {
handler.accept(p,ex);
return Stream.empty();
}
return Stream.of(p);
}

它排除了源中的目录。不过,您仍然可以使用filter(Files::isRegularFile)来排除既不是目录也不是常规文件的特殊文件。

您也可以在此处使用Files.isDirectory(p) && Files.isReadable(p)作为条件,以防止发生AccessDeniedException,至少只要访问标志在Files.isReadable(p)Files.list(p)之间不更改。

我相信你需要改变你的过滤器。检查文件是否isRegular,并不意味着您不会得到AccessException

确保筛选出文件夹。

private static Predicate<Path> fillAccessDenied() {
return p -> {
try {
if(Files.isReadable(p) && !Files.isDirectory(p)) {                    
return true;                
} else {
return false;
}
} catch (UncheckedIOException e) {
e.printStackTrace();
return false;
}
};
}

最新更新