Java8 Lambda Handling Exceptions | SHIV STEP

link管理
链接快照平台
输入网页链接，自动生成快照
标签化管理网页链接
一问题

// 获取文件里的文本内容
public Stream<String> readFiles(String path) throws IOException {
        return Files.lines(Paths.get(getClass().getClassLoader().getResource(path).getPath()));
public void test3() {
        Stream.of("a.txt")
                .flatMap(this::readFiles) // 这里会出现编译异常
                .forEach(System.out::println);
到这里，我们就会发现一个编译问题：
Error:(64, 26) java: 方法引用中抛出的类型java.io.IOException不兼容
这是由于flatMap()支持的函数式接口
@FunctionalInterface
public interface Function<T, R> {
     * 并不支持抛出异常（没有申明throw）
     * Applies this function to the given argument.
     * @param t the function argument
     * @return the function result
    R apply(T t);
二 问题
处理这种受检异常时，我们可以先捕获，然后包装并抛出一个非受检异常。

方法一
public void test1() {
    Stream.of("a.txt")
            .flatMap(path -> {
                try {
                    return readFiles(path);
                } catch (IOException e) {
                    e.printStackTrace();
                    throw new RuntimeException();
            .forEach(System.out::println);
这样可以解决问题，但是会损失lambda的简洁性。
方法二
出现编译时异常的主要问题还是由于Function的apply方法不支持抛出异常，我们可以定义自己的函数式接口：

@FunctionalInterface
public interface ThrowingFunction<T,R,E extends Throwable> {
    R apply(T arg) throws E;
然后在使用一个包装器
static <T, R, E extends Exception> Function<T, R> unchecked(ThrowingFunction<T, R, E> f) {
        return t -> {
            try {
                return apply(t);
            } catch (final Throwable e) {
                throw new WrappedException(e);
然后就可以这样使用了：
@Test
    public void test5() {
        Stream.of("a.txt")
                .flatMap(unchecked(this::readFiles))
                .forEach(System.out::println);
这样的话就保证了代码的间接性，但是我们又不得不定义对应的函数式接口和对应的包装器。对于这个问题，我们可以利用一个开源库ThrowingFunction来解决。方法如下：
1 添加依赖
<dependency>
  <groupId>pl.touk</groupId>
  <artifactId>throwing-function</artifactId>
  <version>1.3</version>
</dependency>
@Test
public void test4() {
  Stream.of("a.txt")
    .flatMap(ThrowingFunction.unchecked(this::readFiles))
    .forEach(System.out::println);
到此为止，我们可以ThrowingFunction很好的解决这种检测异常问题！
一 问题

二 问题

方法一

方法二

一问题

二问题
