Java Stream流

一、为什么要引入Stream流

​ 简而言之引入Stream流的目的就是为了简化集合的操作。

二、获取流

1. 根据Collection获取流

​ 所有的 Collection 集合都可以通过 stream() 方法来直接获取流。

2. 根据Map获取流

​ java.util.Map 接口不是 Collection 的子接口，所以获取对应的流需要分key、value或entry等情况：

import java.util.HashMap; 
import java.util.Map; 
import java.util.stream.Stream; 

public class Demo01GetStream { 
	public static void main(String[] args) { 
		Map<String, String> map = new HashMap<>(); 
		// ... 
		Stream<String> keyStream = map.keySet().stream(); 
		Stream<String> valueStream = map.values().stream(); 
		Stream<Map.Entry<String, String>> entryStream = map.entrySet().stream(); 
	} 
}

3. 根据数组获取流

​ 如果使用的是数组，由于数组对象不可能添加默认方法，所以 Stream 接口中提供了静态方法 of ，使用很简单：

import java.util.stream.Stream; 

public class Demo02GetStream { 
	public static void main(String[] args) { 
		String[] array = { "张无忌", "张翠山", "张三丰", "张一元" }; 
		Stream<String> stream = Stream.of(array); 
	} 
}

【注】of 方法的参数其实是一个可变参数，所以支持数组。

三、常用方法

​ Stream流的常用方法可以被分成两种：

• 延迟方法：即返回值类型仍然是 Stream 接口自身类型的方法，因此支持链式调用。（除了终结方法外，其余方法均为延迟方法。）
• 终结方法：即返回值类型不再是 Stream 接口自身类型的方法，因此不再支持链式调用。常用的终结方法包括 count 和 forEach 方法。

1. 逐一处理：forEach()方法

（1）方法签名

void forEach(Consumer<? super T> action);

​ 该方法接收一个 Consumer 接口函数，会将每一个流元素交给该函数进行处理。

（2）Consumer接口

​ java.util.function.Consumer接口是一个消费型接口。

​ Consumer接口中包含抽象方法 void accept(T t); ，意为消费一个指定泛型的数据。

（3）基本使用

import java.util.stream.Stream; 

public class Demo03StreamForEach { 
	public static void main(String[] args) { 
		Stream<String> stream = Stream.of("张无忌", "张三丰", "周芷若"); 	
		stream.forEach(name ‐> System.out.println(name)); 
	} 
}

2. 过滤：filter()方法

​ 可以通过 filter 方法将一个流转换成另一个子集流。

（1）方法签名

Stream<T> filter(Predicate<? super T> predicate);

​ 该方法接收一个 Predicate 函数式接口参数作为筛选条件。

（2）Predicate接口

​ java.util.stream.Predicate 函数式接口，其中唯一的抽象方法为： boolean test(T t);

​ 该方法将会产生一个boolean值结果，代表指定的条件是否满足。如果结果为true，那么Stream流的 filter 方法 将会留用该元素；如果结果为false，那么 filter 方法将会舍弃该元素。

（3）基本使用

import java.util.stream.Stream; 

public class Demo04StreamFilter { 
	public static void main(String[] args) { 
		Stream<String> original = Stream.of("张无忌", "张三丰", "周芷若");
        // 筛选出姓“张”的人
		Stream<String> result = original.filter(s ‐> s.startsWith("张")); 
	} 
}

3. 映射：map()方法

​ 如果需要将流中的元素映射到另一个流中，可以使用 map 方法。

（1）方法签名

<R> Stream<R> map(Function<? super T, ? extends R> mapper);

​ 该接口需要一个 Function 函数式接口参数，可以将当前流中的T类型数据转换为另一种R类型的流。

（2）Function接口

​ java.util.stream.Function 函数式接口，其中唯一的抽象方法为： R apply(T t);

​ 这可以将一种T类型转换成为R类型，而这种转换的动作，就称为“映射”。

（3）基本使用

import java.util.stream.Stream; 

public class Demo05StreamMap { 
	public static void main(String[] args) { 
		Stream<String> original = Stream.of("10", "12", "18"); 
		Stream<Integer> result = original.map(str‐>Integer.parseInt(str)); 
	} 
}

4. 统计个数：count()方法

​ 正如旧集合 Collection 当中的 size 方法一样，流提供 count 方法来数一数其中的元素个数： long count();

​ 该方法返回一个long值代表元素个数（不再像旧集合那样是int值）。

​ 基本使用：

import java.util.stream.Stream; 

public class Demo06StreamCount { 
	public static void main(String[] args) { 
		Stream<String> original = Stream.of("张无忌", "张三丰", "周芷若"); 
		Stream<String> result = original.filter(s ‐> s.startsWith("张")); 
		System.out.println(result.count()); // 2 
	} 
}

5. 取用前几个：limit()方法

​ limit 方法可以对流进行截取，只取用前n个：Stream limit(long maxSize);

​ 参数是一个long类型，如果集合当前长度大于参数则进行截取；否则不进行操作。

​ 基本使用：

import java.util.stream.Stream; 

public class Demo07StreamLimit { 
	public static void main(String[] args) { 
		Stream<String> original = Stream.of("张无忌", "张三丰", "周芷若"); 
		Stream<String> result = original.limit(2); 
		System.out.println(result.count()); // 2 
	} 
}

6. 跳过前几个：skip()方法

​ 如果希望跳过前几个元素，可以使用 skip 方法获取一个截取之后的新流： Stream skip(long n);

​ 如果流的当前长度大于n，则跳过前n个；否则将会得到一个长度为0的空流。

​ 基本使用：

import java.util.stream.Stream; 

public class Demo08StreamSkip { 
	public static void main(String[] args) { 
		Stream<String> original = Stream.of("张无忌", "张三丰", "周芷若"); 
		Stream<String> result = original.skip(2); 
		System.out.println(result.count()); // 1 
	} 
}

7. 组合：concat()方法

​ 如果有两个流，希望合并成为一个流，那么可以使用 Stream 接口的静态方法 concat ：

​ static Stream concat(Stream<? extends T> a, Stream<? extends T> b);

​ 基本使用：

import java.util.stream.Stream; 

public class Demo09StreamConcat { 
	public static void main(String[] args) { 
		Stream<String> streamA = Stream.of("张无忌"); 
		Stream<String> streamB = Stream.of("张翠山"); 
		Stream<String> result = Stream.concat(streamA, streamB); 
	} 
}