在 java stream 中处理异常，核心做法是将可能抛出受检异常的函数式接口（如 predicate、function）包装为不抛异常的无受检版本，并在内部捕获异常后通过 optional 或自定义结果对象传递状态。具体实现时，定义一个静态工具方法接收原始函数和异常处理逻辑，返回新的函数实例，从而让 filter、map 等操作能无缝接入。
如何封装带异常的 Predicate 用于过滤？
直接回答：将抛出异常的判断逻辑包裹在 try-catch 块中，利用 Optional 区分正常匹配与异常拦截。对于 filter 操作，若业务要求“遇到异常则跳过该元素”，可返回 Optional.empty()；若要求“中断流”，则需抛出运行时异常。以下代码展示了如何将 Integer::parseInt 这种会抛 NumberFormatException 的方法适配到 filter 中，仅保留解析成功的数字。
import java.util.Arrays;
import java.util.List;
import java.util.Optional;
import java.util.function.Predicate;
import java.util.stream.Collectors;
public class StreamExceptionDemo {
// 通用适配器：将可能抛异常的 Predicate 转为安全的 Predicate
public static <T> Predicate<T> safePredicate(PredicateWithException<T> predicate, ExceptionHandler handler) {
return t -> {
try {
return predicate.test(t);
} catch (Exception e) {
handler.handle(e, t);
return false; // 异常时默认不匹配，跳过该元素
}
};
}
@FunctionalInterface
interface PredicateWithException<T> {
boolean test(T t) throws Exception;
}
@FunctionalInterface
interface ExceptionHandler {
void handle(Exception e, Object value);
}
public static void main(String[] args) {
List<String> data = Arrays.asList("1", "abc", "3", "xyz", "5");
// 使用适配器进行过滤
List<String> result = data.stream()
.filter(safePredicate(s -> Integer.parseInt(s) > 2, (e, val) -> System.out.println("Skip invalid: " + val)))
.collect(Collectors.toList());
System.out.println(result); // [3, 5]
}
}
如何在 Map 操作中处理转换异常并保留上下文？
直接回答：在 map 阶段，使用 Optional 作为中间载体。如果转换成功，返回 Optional.of(result)；如果发生异常，记录日志或错误信息，返回 Optional.empty()。随后通过 flatMap(Optional::stream) 或 filter(Optional::isPresent) 清理空值。这种方法特别适用于数据清洗场景，其中部分数据格式错误不应导致整个流终止。
掌握 ES6+ 特性，包括 async/await、解构、扩展运算符、箭头函数、Promise、模块、迭代器、生成器以及函数式编程模式，编写简洁高效的 Java
立即学习“Java免费学习笔记（深入）”；
import java.util.Arrays;
import java.util.List;
import java.util.Optional;
import java.util.stream.Collectors;
import java.util.stream.Stream;
public class StreamMapExceptionDemo {
public static void main(String[] args) {
List<String> input = Arrays.asList("10", "20.5", "invalid", "30");
List<Double> result = input.stream()
.map(StreamMapExceptionDemo::safeParseDouble)
.filter(Optional::isPresent)
.map(Optional::get)
.collect(Collectors.toList());
System.out.println(result); // [10.0, 20.5, 30.0]
}
private static Optional<Double> safeParseDouble(String s) {
try {
return Optional.of(Double.parseDouble(s));
} catch (NumberFormatException e) {
System.err.println("Failed to parse: " + s);
return Optional.empty();
}
}
}
当 Stream 中某个元素触发异常时，程序的实际执行流程是怎样的？
直接回答：若未进行特殊包装，受检异常无法直接在 Lambda 中抛出，会导致编译错误；若使用非受检异常且未捕获，流会立即终止并向上抛出 RuntimeException。通过上述 safePredicate 或 safeParseDouble 模式，异常被局部捕获，程序继续处理下一个元素，不会中断整个流。实际执行中，每个元素独立经过包装后的函数，异常状态被转化为布尔值或 Optional 的存在性，从而实现容错处理。
