Java流操作中FFmpeg异常无法传递的编译报错原因解析

问题描述 #

现有以下Java代码，试图在Stream的forEach操作中调用会抛出受检异常FFmpegFrameRecorder.Exception的consume方法，并希望将该异常传递给调用write方法的上层代码：

public void write(FrameConsumer fc) throws FFmpegFrameRecorder.Exception{
    frameStream.forEach(n -> fc.consume(n));        
}

但这段代码无法编译，报错：Unhandled exception type FFmpegFrameRecorder.Exception Java(16777384)。即使在lambda内添加try-catch块重新抛出异常，仍然无法通过编译：

public void write(FrameConsumer fc) throws FFmpegFrameRecorder.Exception{
    frameStream.forEach(n -> {
        try {
            fc.consume(n);
        } catch (FFmpegFrameRecorder.Exception e) {
            throw e;   // 此处编译失败
        }
    });
}

根本原因 #

1. 函数式接口的签名约束：Stream的forEach方法接收的是Consumer<T>函数式接口，该接口的accept(T t)方法没有声明抛出任何受检异常——它仅允许抛出RuntimeException或Error这类非受检异常。而FFmpegFrameRecorder.Exception是受检异常，lambda表达式直接调用抛出该异常的方法，会违反Consumer接口的方法签名约定，因此编译器报错。
2. try-catch重抛仍失败的原因：哪怕在lambda内捕获异常后重新抛出，Consumer的accept方法依然不允许抛出受检异常，编译器会判定你违反了接口的方法约定，因此依然报错。

可行解决方案 #

方案1：将受检异常包装为RuntimeException抛出 #

把受检异常包装成非受检的RuntimeException，符合Consumer接口的约束，上层代码可以捕获RuntimeException后拆包获取原异常：

public void write(FrameConsumer fc) {
    frameStream.forEach(n -> {
        try {
            fc.consume(n);
        } catch (FFmpegFrameRecorder.Exception e) {
            throw new RuntimeException(e);
        }
    });
}

上层调用示例：

try {
    write(fc);
} catch (RuntimeException e) {
    if (e.getCause() instanceof FFmpegFrameRecorder.Exception) {
        FFmpegFrameRecorder.Exception originalEx = (FFmpegFrameRecorder.Exception) e.getCause();
        // 处理原异常
    }
}

方案2：改用传统循环替代Stream操作 #

放弃Stream的forEach，使用普通的增强for循环，这样不受函数式接口的约束，可以直接抛出受检异常：

public void write(FrameConsumer fc) throws FFmpegFrameRecorder.Exception{
    // 如果stream是有限的，先转换为集合再遍历
    for (Frame frame : frameStream.collect(Collectors.toList())) {
        fc.consume(frame);
    }
}

方案3：自定义支持受检异常的函数式接口 #

定义一个允许抛出指定受检异常的函数式接口，再实现对应的遍历逻辑：

// 自定义支持抛出受检异常的Consumer接口
@FunctionalInterface
public interface ThrowingConsumer<T, E extends Exception> {
    void accept(T t) throws E;
}

// 工具方法：遍历Stream并支持抛出受检异常
public static <T, E extends Exception> void forEachThrowing(Stream<T> stream, ThrowingConsumer<T, E> consumer) throws E {
    for (T t : stream.collect(Collectors.toList())) {
        consumer.accept(t);
    }
}

// 改造后的write方法
public void write(FrameConsumer fc) throws FFmpegFrameRecorder.Exception{
    forEachThrowing(frameStream, fc::consume);
}

内容的提问来源于stack exchange，提问作者CopperCableIsolator