Stream流的中间方法
方法
- 中间方法指的是调用完成后会返回新的Stream流，可以继续使用(支持链式编程)。
案例演示
需求1：找出成绩大于等于60分的数据，并升序后，再输出。
public class streamTest3 { public static void main(String[] args) { List<Double> scores = new ArrayList<>(); Collections.addAll(scores,88.5,100.0,60.0,99.0,9.5,99.6,25.0); //需求1：找出成绩大于等于60分的数据，并升序后，再输出。 scores.stream().filter(s -> s >= 60).sorted().forEach(s -> System.out.println(s)); } }
运行结果：
需求2：找出年龄大于等于23，且年龄小于等于30岁的学生，并按照年龄降序输出。
public class streamTest3 { public static void main(String[] args) { List<Student> students = new ArrayList<>(); Student s1 = new Student("蜘蛛精", 172.5,26 ); Student s2 = new Student("蜘蛛精",172.5,26); Student s3 = new Student("紫霞",167.6,23); Student s4 = new Student("白晶晶",169.0,25); Student s5 = new Student("牛魔王",183.3,35); Student s6 = new Student("牛夫人",168.5,34); Collections.addAll(students,s1,s2,s3,s4,s5,s6); //需求2：找出年龄大于等于23，且年龄小于等于30岁的学生，并按照年龄降序输出。 students.stream().filter(s -> s.getAge() >= 23 && s.getAge() <= 30) .sorted((o1,o2) -> o2.getAge() - o1.getAge()) //重载的sort方法 .forEach(s -> System.out.println(s)); } }
运行结果：
需求3：取出身高最高的前3名学生，并输出。
//需求3：取出身高最高的前3名学生，并输出。 students.stream().sorted((o1,o2) -> Double.compare(o2.getHeight(),o1.getHeight())) .limit(3).forEach(s -> System.out.println(s));
运行结果：
再简化输出语句：
需求4：取出身高倒数的2名学生
//需求4：取出身高倒数的2名学生 students.stream().sorted((o1,o2) -> Double.compare(o2.getHeight(),o1.getHeight())) .skip(students.size() - 2).forEach(System.out::println);
运行结果：
需求5：找出身高超过168的学生叫什么名字，要求去除重复的名字，再输出。
//需求5：找出身高超过168的学生叫什么名字，要求去除重复的名字，再输出。 students.stream().filter(s -> s.getHeight() > 168) .map(Student::getName /* s->s.getName()*/ ) .distinct().forEach(System.out::println);
运行结果：
concat的使用
Stream<String> st1 = Stream.of("张三","李四"); Stream<String> st2 = Stream.of("张三2","李四2","王五"); Stream<String> allSt = Stream.concat(st1,st2); allSt.forEach(System.out::println);
运行结果：
Stream流的终结方法
方法
- 终结方法指的是调用完成后，不会返回新Stream了，没法继续使用流了。
-
案例演示1
需求1：计算出身高超过168的学生有几人
public class streamTest4 { public static void main(String[] args) { List<Student> students = new ArrayList<>(); Student s1 = new Student("蜘蛛精", 172.5,26 ); Student s2 = new Student("蜘蛛精",172.5,26); Student s3 = new Student("紫霞",167.6,23); Student s4 = new Student("白晶晶",169.0,25); Student s5 = new Student("牛魔王",183.3,35); Student s6 = new Student("牛夫人",168.5,34); Collections.addAll(students,s1,s2,s3,s4,s5,s6); //需求1：计算出身高超过168的学生有几人 long size = students.stream().filter(s -> s.getHeight() > 168).count(); System.out.println(size); } }
运行结果：
需求2：请找出身高最高的学生对象，并输出
//需求2：请找出身高最高的学生对象，并输出 Student s = students.stream().max((o1,o2) -> Double.compare(o1.getHeight(),o2.getHeight())).get(); System.out.println(s);
运行结果：
需求3：请找出身高最矮的学生对象，并输出
//需求3：请找出身高最矮的学生对象，并输出 Student ss = students.stream().min((o1,o2) -> Double.compare(o1.getHeight(),o2.getHeight())).get(); System.out.println(ss);
运行结果：
收集
- 收集Stream流：就是把Stream流操作后的结果转回到集合或者数组中去返回。
Stream流：方便操作集合/数组的手段；集合/数组：才是开发中的目的。
| Stream提供的常用终结方法 | 说明 |
| R collect(Collector collector) | 把流处理后的结果收集到一个指定的集合中去 |
| Object[] toArray() | 把流处理后的结果收集到一个数组中去 |
案例演示2
需求4：请找出身高超过170的学生对象，并放到一个新集合中去返回
//需求4：请找出身高超过170的学生对象，并放到一个新集合中去返回 List<Student> students1 = students.stream().filter(a -> a.getHeight() > 170).collect(Collectors.toList()); System.out.println(students1); System.out.println("-----------------------"); Set<Student> students2 = students.stream().filter(a -> a.getHeight() > 170).collect(Collectors.toSet()); System.out.println(students2);
运行结果：
注意：流只能收集一次 （就像是水喝光了，或者是迭代器的指针指到了最后的位置）
例如：
需求5：请找出身高超过170的学生对象，并把学生对象的名字和身高，存入到一个Map集合返回。
（需要手动去重）
//需求5：请找出身高超过170的学生对象，并把学生对象的名字和身高，存入到一个Map集合返回。 Map<String,Double> map = students.stream().filter(a -> a.getHeight() > 170) .distinct().collect(Collectors.toMap(a -> a.getName(),a -> a.getHeight())); System.out.println(map);
运行结果：
Stream流收集为数组
Object[] arr1 = students.stream().filter(a -> a.getHeight() > 170).toArray(); //如果不想要Object类型，则 Student[] arr2 = students.stream().filter(a -> a.getHeight() > 170).toArray(len -> new Student[len]); System.out.println(Arrays.toString(arr2));
运行结果：
END
