java的stream流式编程

• 1. stream流的3个特性
• • (1) stream流不存储数据
  • (2) stream不改变数据源
  • (3) stream不可重复使用
• 2. 生成流的方式
• • (1) Array.stream()
  • (2) Stream.of()
  • (3) 对象.stream()
• 3. 中间节点(懒节点)与终值节点
• • (1) 中间节点/懒节点的使用示例
  • (2) 懒节点+终值节点
  • (3) 区分中间节点与终值节点的方法
• 4. stream流的使用示例及特性
• • (1) 节点的责任链模式
  • • ① 执行每个节点方法：peek()
    • ② 执行最后一个节点：foreach()
  • (2) 上一个节点会影响下一个节点
  • • ① 过滤：filter()
    • ② 转换/映射：map()
    • ③ 去重：distinct()
• 5. Stream的采集功能

stream流式编程

1. stream流的3个特性

(1) stream流不存储数据

(2) stream不改变数据源

stream可以看作一根管道，用于数据的转换，所以不会存储数据，也不会影响原来的数据

除了过滤、排序、采集外，还有分组等等功能，这也就是stream流式编程提供的功能

(3) stream不可重复使用

因为stream是一根管道，不可重复使用就是stream用完一次之后，数据就输出了

示例

Stream stream1 = Stream.of(1,2,3);
        
 //创建stream2过滤stream1
 Stream stream2 =  stream1.filter(s->s.equals(1));

 //下句代码会出错，因为stream1流用过一次，消失了
 Stream stream3 =  stream1.filter(s->s.equals(1));
           

2. 生成流的方式

(1) Array.stream()

Array的静态方法

例如

Arrays.stream(new int[]{1,2,3}); //使用Array的静态方法创建流

(2) Stream.of()

Stream的静态方法，可以传入任何类型

(3) 对象.stream()

stream()方法是Collection接口里的默认方法 ，所以Collection所有的子类和子接口都可以使用.stream()

例如

Collection collection  = new ArrayList();

collection.stream(); // 使用Collection类里的成员方法stream()方式创建流
           

3. 中间节点(懒节点)与终值节点

(1) 中间节点/懒节点的使用示例

懒节点不会自动执行，所以下例代码不会打印hello

public static void main(String[] args) {
        List list = new ArrayList();

        Stream.of(list).filter(a->{
            System.out.println("hello");
            return true;
        }); //没有打印结果
}
           

(2) 懒节点+终值节点

这时在最后加了.toArray()方法，相当于加上了终值节点，那么此时终值节点+前面的节点都会执行

public static void main(String[] args) {
        List list = new ArrayList();

        Stream.of(list).filter(a->{
            System.out.println("hello");
            return true;
        }).toArray(); //打印输出hello
}
           

(3) 区分中间节点与终值节点的方法

进入Stream流的源码，按快捷键ctrl+f12

只要方法返回的是Stream，基本都是中间节点，其余就是终值节点

4. stream流的使用示例及特性

@Data
@AllArgsConstructor
@NoArgsConstructor
public class AppleStore {
    int id; //编号
    String color; //颜色
    double weight; //重量
    String origin; //产地
}
           

(1) 节点的责任链模式

① 执行每个节点方法：peek()

节点会挨个执行，也称作责任链模式

public class StreamTest {
    private static List<AppleStore> appleStores = new ArrayList();

    static {
        appleStores.add(new AppleStore(1,"red",1.2,"重庆"));
        appleStores.add(new AppleStore(2,"red",1.5,"四川"));
        appleStores.add(new AppleStore(3,"yellow",2.6,"重庆"));
        appleStores.add(new AppleStore(4,"yellow",2.9,"四川"));
        appleStores.add(new AppleStore(5,"red",3.2,"杭州"));
    }
    public static void main(String[] args) {

        //peek()是执行每个节点的方法
        //peek里的方法会挨个执行，也就是节点会挨个执行，也称作责任链模式
        appleStores.stream().peek(appleStore -> System.out.println(appleStore.getColor())) //打印苹果的颜色
                .peek(appleStore -> System.out.println(appleStore.getWeight())) //打印苹果的重量
                .peek(appleStore -> appleStore.getOrigin()) //打印苹果的产地
                .toArray();
    }
}
           

② 执行最后一个节点：foreach()

foreach功能和peek相同，不同是foreach是终值节点，也就是不能再往下继续执行

appleStores.stream().peek(apple -> System.out.println(apple.getId())) //打印苹果编号
                .peek(apple -> System.out.println(apple.getColor())) //打印苹果颜色
                .forEach(sout-> System.out.println("节点一次遍历执行完毕"));
           

(2) 上一个节点会影响下一个节点

影响方式：过滤、转换/映射、去重

① 过滤：filter()

appleStores.stream().filter(appleStore -> appleStore.getColor().equals("red")) //过滤出红色的苹果
                .peek(appleStore -> System.out.println(appleStore)) //到第二个节点只有红色苹果的数据了
                .toArray();
           

② 转换/映射：map()

//此时数据全部变成了String字符串 因为map中的方法是getColor()，映射成为的是String
        appleStores.stream().map(appleStore -> appleStore.getColor()) //获取苹果的颜色
                .peek(color -> System.out.println(color))
                .toArray();
           

③ 去重：distinct()

appleStores.stream().map(appleStore -> appleStore.getColor()) //获取苹果的颜色
                .distinct() //去重
                .peek(color -> System.out.println(color))
                .toArray();
           

5. Stream的采集功能

Stream采集功能分为List、map、group by、数组、求最大值、求任意值等，这里就不一一列举了

用一个综合例子来说明其余功能

List<Integer> collect = appleStores.stream() // 获取appleStores的流
                .map(appleStore -> appleStore.getId()) // 转换功能：获取id，从List<AppleStore>转换成了List<int>
                .sorted() // 从小到大排序 (本质是调用compareTo()方法，所以类要实现CompareAble接口)
                .limit(3) // 取前三个元素
                .collect(Collectors.toList()); //将stream流转回List集合
           

stream流的常用方法