- 我的技术博客：https://nezha.github.io，https://nezhaxiaozi.coding.me
- 我的简书地址：https://www.jianshu.com/u/a5153fbb0434
本文的代码地址：GitHub Java8
Stream 常见操作
- Stream中间操作
image.png
filter
filter 方法用于通过设置的条件过滤出元素。以下代码片段使用 filter 方法过滤掉空字符串：
List<String> strings = Arrays.asList("Hollis", "", "HollisChuang", "H", "hollis");
strings.stream().filter(string -> !string.isEmpty()).forEach(System.out::println);
map
map 方法用于映射每个元素到对应的结果，以下代码片段使用 map 输出了元素对应的平方数：
List<Integer> numbers = Arrays.asList(3, 2, 2, 3, 7, 3, 5);
numbers.stream().map( i -> i*i).forEach(System.out::println);
limit/skip
limit 返回 Stream 的前面 n 个元素；skip 则是扔掉前 n 个元素。以下代码片段使用 limit 方法保理4个元素：
List<Integer> numbers = Arrays.asList(3, 2, 2, 3, 7, 3, 5);
numbers.stream().limit(4).forEach(System.out::println);
sorted
sorted 方法用于对流进行排序。以下代码片段使用 sorted 方法进行排序：
List<Integer> numbers = Arrays.asList(3, 2, 2, 3, 7, 3, 5);
numbers.stream().sorted().forEach(System.out::println);
distinct
distinct主要用来去重，以下代码片段使用 distinct 对元素进行去重：
List<Integer> numbers = Arrays.asList(3, 2, 2, 3, 7, 3, 5);
numbers.stream().distinct().forEach(System.out::println);
接下来我们通过一个例子和一张图，来演示下，当一个Stream先后通过filter、map、sort、limit以及distinct处理后会发生什么。
代码如下：
List<String> stringList = Arrays.asList("Hollis", "HollisChuang", "hollis", "Hello", "HelloWorld", "Hollis");
Stream s = stringList.stream().filter(string -> string.length()<= 6).map(String::length).sorted().limit(3).distinct();
s.forEach(System.out::println);
- 过程及每一步得到的结果如下图：
image.png
- Stream最终操作
常用的最终操作如下图：
image.png
forEach
Stream 提供了方法 'forEach' 来迭代流中的每个数据。以下代码片段使用 forEach 输出了10个随机数：
Random random = new Random();
random.ints().limit(10).forEach(System.out::println);
count
count用来统计流中的元素个数。
List<String> strings = Arrays.asList("Hollis", "HollisChuang", "hollis","Hollis666", "Hello", "HelloWorld", "Hollis");
System.out.println(strings.stream().count());
collect
collect就是一个归约操作，可以接受各种做法作为参数，将流中的元素累积成一个汇总结果：
List<String> strings = Arrays.asList("Hollis", "HollisChuang", "hollis","Hollis666", "Hello", "HelloWorld", "Hollis");
strings = strings.stream().filter(string -> string.startsWith("Hollis")).collect(Collectors.toList());
System.out.println(strings);
实例讲解
@Slf4j
public class StudentsOps {
public void useStudentStream(){
List<Student> students = new ArrayList<>();
students.add(new Student(111L, "aaa", "男", 1));
students.add(new Student(222L, "bbb", "女", 3));
students.add(new Student(333L, "ccc", "男", 2));
students.add(new Student(444L, "ddd", "女", 4));
students.add(null);
log.info("\n>>>>初始化的student是：{}", students);
//1.Optional防空利器
Optional.ofNullable(students).orElse(Collections.emptyList()).forEach(System.out::println);
log.info("\n>>>>>>>filter>>>>>>");
//2.filter
students.stream().filter(Objects::nonNull).forEach(student -> {
System.out.println(student.getName());
});
log.info("\n>>>>>>>map>>>>>>");
//3.map
List<Long> studentIdList = students.stream().filter(Objects::nonNull).map(Student::getId).collect(Collectors.toList());
studentIdList.forEach(System.out::println);
log.info("\n>>>>>>list转换map>>>>>.");
//4.list转换map
Map<Long, Student> studentMap = students.stream().filter(Objects::nonNull).collect(Collectors.toMap(Student::getId, s -> s));
log.info(JSON.toJSONString(studentMap));
log.info("\n>>>>>>limit的使用>>>>>.");
//5.limit的使用
List<String> names = students.stream().limit(3).map(Student::getName).collect(Collectors.toList());
names.forEach(System.out::println);
log.info("\n>>>>>>skip的使用,下面是取第2条数据后面2条，可以实现分页功能啦>>>>>.");
//6.skip 的使用
List<String> names2 = students.stream().skip(2).limit(2).map(Student::getName).collect(Collectors.toList());
names2.forEach(System.out::println);
log.info("\n>>>>>>集合排序,默认是递增>>>>>.");
//7.集合排序
List<Student> studentsSorted = students.stream().filter(Objects::nonNull).collect(Collectors.toList());
Collections.sort(studentsSorted, Comparator.comparing(Student::getAge).reversed());
studentsSorted.forEach(System.out::println);
log.info("\n>>>>>>parallelStream，并行流>>>>>.");
//8.parallelStream
students.parallelStream().filter(Objects::nonNull).forEach(System.out::println);
}
}
参考文献
1.程序员进新公司 团队都用java8函数式语法 开始内心是拒绝的
