Java Stream如何处理Stream中的异常

在Java中，Stream API本身并不直接支持异常处理。但是，你可以通过以下几种方法来处理Stream中的异常：

1. 使用map操作符将可能抛出异常的函数封装在一个try-catch块中。这样，当异常发生时，你可以捕获它并进行相应的处理。例如：

List<String> input = Arrays.asList("1", "2", "three", "4");

List<Integer> output = input.stream()
    .map(s -> {
        try {
            return Integer.parseInt(s);
        } catch (NumberFormatException e) {
            // 处理异常，例如返回一个默认值或记录错误
            return -1;
        }
    })
    .collect(Collectors.toList());

2. 使用flatMap操作符将可能抛出异常的函数封装在一个try-catch块中。这样，当异常发生时，你可以捕获它并进行相应的处理。例如：

List<String> input = Arrays.asList("1", "2", "three", "4");

List<Integer> output = input.stream()
    .flatMap(s -> {
        try {
            return Stream.of(Integer.parseInt(s));
        } catch (NumberFormatException e) {
            // 处理异常，例如返回一个空Stream
            return Stream.empty();
        }
    })
    .collect(Collectors.toList());

3. 使用自定义的Collector来处理异常。在这种情况下，你需要实现Collector接口，并在accumulate和merge方法中处理异常。例如：

List<String> input = Arrays.asList("1", "2", "three", "4");

List<Integer> output = input.stream()
    .collect(new Collector<String, Integer, List<Integer>>() {
        @Override
        public Supplier<Integer> supplier() {
            return () -> new ArrayList<>();
        }

        @Override
        public BiConsumer<Integer, String> accumulator() {
            return (acc, s) -> {
                try {
                    acc.add(Integer.parseInt(s));
                } catch (NumberFormatException e) {
                    // 处理异常，例如记录错误
                }
            };
        }

        @Override
        public BinaryOperator<Integer> combiner() {
            return (acc1, acc2) -> {
                acc1.addAll(acc2);
                return acc1;
            };
        }

        @Override
        public Function<Integer, Integer> finisher() {
            return i -> i;
        }

        @Override
        public Set<Characteristics> characteristics() {
            return Collections.emptySet();
        }
    });

请注意，这些方法都是在Stream API的每个操作完成后处理的异常。如果你需要在流的中间处理异常，你可能需要考虑使用其他方法，例如使用peek操作符来执行副作用操作（如记录错误或返回默认值）。