Java 8引入的Stream API为数据处理提供了一种全新的方式，它可以帮助开发者以声明性方式编写高效且简洁的代码。本文将深入探索Java Stream API，展示其强大的功能和使用技巧。

1. 什么是Stream API？

Stream API是Java 8引入的一种用于处理数据序列的抽象。它支持对集合数据进行高效的聚合操作，如过滤、映射和归约。Stream操作分为两种类型：中间操作和终端操作。

中间操作

中间操作返回一个新的Stream，常见的中间操作包括filter、map、sorted等。

终端操作

终端操作会触发Stream的处理，常见的终端操作包括forEach、collect、reduce等。

2. 创建Stream

Stream可以从多种数据源创建，如集合、数组、文件等。

import java.util.stream.Stream;
import java.util.List;
import java.util.Arrays;

public class StreamCreationExample {
    public static void main(String[] args) {
        // 从集合创建Stream
        List<String> list = Arrays.asList("a", "b", "c");
        Stream<String> streamFromList = list.stream();

        // 从数组创建Stream
        String[] array = {"x", "y", "z"};
        Stream<String> streamFromArray = Arrays.stream(array);

        // 从值创建Stream
        Stream<String> streamFromValues = Stream.of("1", "2", "3");
    }
}

3. 中间操作示例

过滤（filter）

filter用于筛选符合条件的元素。

import java.util.stream.Stream;

public class FilterExample {
    public static void main(String[] args) {
        Stream.of("apple", "banana", "cherry", "date")
              .filter(s -> s.startsWith("b"))
              .forEach(System.out::println); // 输出: banana
    }
}

映射（map）

map用于将元素转换为另一种形式。

import java.util.stream.Stream;

public class MapExample {
    public static void main(String[] args) {
        Stream.of("apple", "banana", "cherry")
              .map(String::toUpperCase)
              .forEach(System.out::println); // 输出: APPLE, BANANA, CHERRY
    }
}

排序（sorted）

sorted用于对元素进行排序。

import java.util.stream.Stream;

public class SortedExample {
    public static void main(String[] args) {
        Stream.of("cherry", "banana", "apple")
              .sorted()
              .forEach(System.out::println); // 输出: apple, banana, cherry
    }
}

4. 终端操作示例

收集（collect）

collect用于将Stream的元素收集到集合中。

import java.util.List;
import java.util.stream.Collectors;
import java.util.stream.Stream;

public class CollectExample {
    public static void main(String[] args) {
        List<String> list = Stream.of("apple", "banana", "cherry")
                                  .collect(Collectors.toList());
        System.out.println(list); // 输出: [apple, banana, cherry]
    }
}

归约（reduce）

reduce用于将元素组合起来，生成一个值。

import java.util.stream.Stream;

public class ReduceExample {
    public static void main(String[] args) {
        int sum = Stream.of(1, 2, 3, 4, 5)
                        .reduce(0, Integer::sum);
        System.out.println(sum); // 输出: 15
    }
}

遍历（forEach）

forEach用于遍历Stream的每个元素。

import java.util.stream.Stream;

public class ForEachExample {
    public static void main(String[] args) {
        Stream.of("apple", "banana", "cherry")
              .forEach(System.out::println);
    }
}

5. 并行流

并行流通过并行处理来提高性能，特别适用于大数据量的处理。

import java.util.List;
import java.util.Arrays;

public class ParallelStreamExample {
    public static void main(String[] args) {
        List<String> list = Arrays.asList("apple", "banana", "cherry", "date", "elderberry");
        list.parallelStream()
            .filter(s -> s.length() > 5)
            .forEach(System.out::println); // 输出可能是乱序的
    }
}

6. 实战案例：数据分析

使用Stream API进行数据分析，可以大大简化代码并提高效率。以下是一个分析销售数据的示例。

import java.util.Arrays;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;

public class SalesDataAnalysis {
    static class Sale {
        String product;
        double amount;

        Sale(String product, double amount) {
            this.product = product;
            this.amount = amount;
        }

        public String getProduct() {
            return product;
        }

        public double getAmount() {
            return amount;
        }
    }

    public static void main(String[] args) {
        List<Sale> sales = Arrays.asList(
            new Sale("Apple", 100),
            new Sale("Banana", 150),
            new Sale("Cherry", 200),
            new Sale("Apple", 300),
            new Sale("Banana", 100)
        );

        // 计算每种产品的总销售额
        Map<String, Double> totalSales = sales.stream()
            .collect(Collectors.groupingBy(
                Sale::getProduct,
                Collectors.summingDouble(Sale::getAmount)
            ));

        totalSales.forEach((product, total) -> System.out.println(product + ": " + total));
        // 输出:
        // Apple: 400.0
        // Banana: 250.0
        // Cherry: 200.0
    }
}

7. 总结

Java Stream API为数据处理提供了一种高效且简洁的方式。通过掌握Stream API的基础和进阶用法，可以编写出更具表现力和可读性的代码，从而提高开发效率和程序性能。希望本文能够帮助你深入理解并应用Java Stream API。

私人微信