Java复习13

Java复习13"/>

Java复习13

Stream流

1.体验Stream流

需求：按照下面的要求完成集合的创建和遍历

• 创建一个集合，存储多个字符串元素

• 把集合中所有以“张”开头的元素存储到一个新的集合

• 把“张”开头的集合中的长度为30的元素存储到一个新的集合

• 遍历上一步得到的集合

  package itheima01;import java.util.ArrayList;public class StreamDemo {public static void main(String[] args) {//创建一个集合，存储多个字符串元素ArrayList<String> list = new ArrayList<String>();list.add("林青霞");list.add("张曼玉");list.add("王祖贤");list.add("柳岩");list.add("张敏");list.add("张无忌");//把集合中所有以“张”开头的元素存储到一个新的集合ArrayList<String> zhanglist = new ArrayList<String>();for (String s : list) {if (s.startsWith("张")) {zhanglist.add(s);}}
  //        System.out.println(zhanglist);//把“张”开头的集合中的长度为30的元素存储到一个新的集合ArrayList<String> threelist = new ArrayList<String>();for (String s : zhanglist) {if (s.length() == 3) {threelist.add(s);}}//        System.out.println(threelist);//遍历上一步得到的集合for (String s : threelist) {System.out.println(s);}System.out.println("--------------------------");//Stream流改写list.stream().filter(s -> s.startsWith("张")).filter(s -> s.length()==3).forEach(s -> System.out.println(s));list.stream().filter(s -> s.startsWith("张")).filter(s -> s.length()==3).forEach(System.out::println);//方法引用}
  }
  

  使用Stream流的方式完成过来操作

  • list.stream().filter(s -> s.startsWith(“张”)).filter(s ->s.length()==3).forEach(System.out::println);
  • 直接阅读代码的字面意思即可完美展示无关逻辑方式的语义：生成流、过来姓张、过滤姓张、过滤长度为3、注意打印
  • Stream流把真正的函数式编程风格引入到Java中

2.Stream流的生成方式

Stream流的使用

• 生成流

  通过数据源（集合，数组等）生成流

  list.stream()

• 中间操作

  一个流后面可以跟随零个或多个中间操作，其目的主要是打开流，做出某种程度的数据过滤/映射，然后返回一个新的流，交给下一个操作使用

  filter()

• 终结操作

  一个流只能有一个终结操作，当这个操作执行后，流就被使用“光”了，无法再被操作。所以这必定是流的最后一个操作forEach()

Stream流的常见生成方式

• Collection体系的集合可以使用默认方法stream()生成流

  ​ default Stream stream()

• Map体系的集合简介的生成流

• 数组可以通过Stream接口的静态方法of(T…values)生成

  package itheima02;import java.util.*;
  import java.util.stream.Stream;public class StreamDemo {public static void main(String[] args) {//Collection体系的集合可以使用默认方法stream()生成流List<String> list = new ArrayList<String>();Stream<String> listStream = list.stream();Set<String> set = new HashSet<String>();Stream<String> setStream = set.stream();//- Map体系的集合简介的生成流Map<String, Integer> map = new HashMap<String, Integer>();Stream<String> keyStream = map.keySet().stream();Stream<Integer> valueStream = map.values().stream();Stream<Map.Entry<String, Integer>> entryStream = map.entrySet().stream();//数组可以通过Stream接口的静态方法of(T...values)生成String[] strArray = {"hello", "world", "java"};Stream<String> strArrayStream1 = Stream.of(strArray);Stream<String> strArrayStream2 = Stream.of("hello", "world", "java");Stream<Integer> intStream = Stream.of(10, 20, 30);}
  }
  

3.Stream流的常见中间操作方法

• Stream filter(Predicate predicate):用于对流中的数据进行过滤

  ​ Predicate接口中的方法 boolean test(T t):对给定的参数进行判断，返回一个布尔值

  package itheima03;import java.lang.reflect.Array;
  import java.util.ArrayList;public class StreamDemo {public static void main(String[] args) {//创建一个集合，存储多个字符串元素ArrayList<String> list = new ArrayList<String>();list.add("林青霞");list.add("张曼玉");list.add("王祖贤");list.add("柳岩");list.add("张敏");list.add("张无忌");//需求1：把list集合中以“张”开头的元素再控制台输出
  //        list.stream().filter((String s)->{
  //            return s.startsWith("张");
  //        }).forEach(System.out::println);list.stream().filter(s -> s.startsWith("张")).forEach(System.out::println);System.out.println("--------------");//需求2：把list集合中长度为3的元素在控制台输出list.stream().filter(s -> s.length() == 3).forEach(System.out::println);System.out.println("--------------");//需求3：把list集合中以张开头的，长度为3的元素在控制台输出list.stream().filter(s -> s.startsWith("张")).filter(s -> s.length() == 3).forEach(System.out::println);}
  }
  

• Stream limit(long maxSize):返回此流中的元素组成的流，截取前指定参数个数的数据

• Stream skip(long n):跳过指定参数个数的数据，返回由该流剩余元素组成的流

  package itheima03;import java.util.ArrayList;public class StreamDemo02 {public static void main(String[] args) {//创建一个集合，存储多个字符串元素ArrayList<String> list = new ArrayList<String>();list.add("林青霞");list.add("张曼玉");list.add("王祖贤");list.add("柳岩");list.add("张敏");list.add("张无忌");//需求1：取前3个数据在控制台输出list.stream().limit(3).forEach(System.out::println);System.out.println("--------------");//需求2:跳过3个元素，把剩下的元素在控制台输出list.stream().skip(3).forEach(System.out::println);System.out.println("--------------");//需求3：跳过2个元素，把剩下的元素中前2个在控制台输出list.stream().skip(2).limit(2).forEach(System.out::println);}
  }
  

• static Stream concat(Stream a,Stream b):合并a和b两个流为一个流

• Stream distinct():返回由该流的不同元素(根据Object.equals(Object))组成的流

• Stream sorted():返回由此流的元素组成的流，根据自认顺序排序

• Stream sorted(Comparator):返回由该流的元素组成的流，根据提供的Comparator进行排序

• Stream map(Function mapper):返回由给定函数应用于此流的元素的结果组成的流

• IntStream mapToInt(Function mapper):返回一个IntStream其中包含给定函数应用于此流的元素的结果

4.Stream流的常见终结操作方法

Stream流的常见终结操作方法

• void forEach(Consumer action):对此流的每个元素执行操作

  Consumer接口中的方法 void accept(T t):对给定的参数执行此操作

• long count():返回此流中的元素数

5.Stream流的练习

现在又两个ArrayList集合，分别存储6名男演员名称和6名女演员名称，要求完成如下的操作

• 男演员只要名字为3个字的前3人

• 女演员之一姓林的，并且不要第一个

• 把过滤后的男演员和女演员姓名合并到一起

• 把上一步操作后的元素作为构造方法的参数创建演员对应，遍历数据

  ​ 演员类Actor已经提供，里面有一个成员变量，一个代餐构造方法，以及成员遍历对应的get/set方法

  package itheima05;import java.util.ArrayList;
  import java.util.stream.Stream;public class StreamTest {public static void main(String[] args) {//创建集合ArrayList<String> manList = new ArrayList<String>();manList.add("周润发");manList.add("成龙");manList.add("刘德华");manList.add("吴京");manList.add("周星驰");manList.add("李连杰");ArrayList<String> womanList = new ArrayList<String>();womanList.add("林心如");womanList.add("张曼玉");womanList.add("林青霞");womanList.add("柳岩");womanList.add("林志玲");womanList.add("王祖贤");/*//男演员只要名字为3个字的前3人Stream<String> manStream = manList.stream().filter(s -> s.length() == 3).limit(3);//女演员之一姓林的，并且不要第一个Stream<String> womanStream = womanList.stream().filter(s -> s.startsWith("林")).skip(1);//把过滤后的男演员和女演员姓名合并到一起Stream<String> stream = Stream.concat(manStream, womanStream);//把上一步操作后的元素作为构造方法的参数创建演员对应，遍历数据
  //        stream.map(Actor::new).forEach(System.out::println);stream.map(Actor::new).forEach(p->System.out.println(p.getName()));*///简化代码Stream.concat(manList.stream().filter(s -> s.length() == 3).limit(3),womanList.stream().filter(s -> s.startsWith("林")).skip(1)).map(Actor::new).forEach(p -> System.out.println(p.getName()));}}
  

6.Stream流的收集操作

对数据使用Stream流的方式操作完毕后，如何把流中的数据收集到集合中？

Stream流的收集方法

• R collect(Collector collector)

• 但是这个收集方法的参数是一个Collector接口

工具类Collectors提供了具体的收集方式

• public static Collector toList():把元素收集到List集合中

• public static Collector toSet():把元素收集到Set集合中

• public static Collector toMap(Function KeyMapper,Function valueMapper):把元素收集到Map集合中

  package itheima06;import java.util.*;
  import java.util.stream.Collectors;
  import java.util.stream.Stream;public class CollectDemo {public static void main(String[] args) {//创建集合对象List<String> list = new ArrayList<String>();list.add("林青霞");list.add("张曼玉");list.add("王祖贤");list.add("柳岩");/*//需求1：得到名字为3个字的流Stream<String> listStream = list.stream().filter(s -> s.length() == 3);//需求2：把使用Stream流操作完毕的数据收集到List集合中并遍历List<String> names = listStream.collect(Collectors.toList());for (String name:names){System.out.println(name);}*///创建Set集合对象Set<Integer> set = new HashSet<Integer>();set.add(10);set.add(20);set.add(30);set.add(33);set.add(35);/*//需求3：得到年龄大于25的流Stream<Integer> setStream = set.stream().filter(age -> age > 25);//需求4：把使用Stream流操作完毕的数据收集到Set集合中并遍历Set<Integer> ages = setStream.collect(Collectors.toSet());for (Integer age:ages){System.out.println(age);}*///定义一个字符串数组，每一个字符串数据由姓名数据和年龄数据组合而成String[] strArray = {"林青霞,30", "张曼玉,35", "王祖贤,33", "柳岩,25"};//需求5：得到字符串中年龄数据大于28的流Stream<String> arrayStream = Stream.of(strArray).filter(s -> Integer.parseInt(s.split(",")[1]) > 28);//需求6：把使用Stream流操作完毕的数据收集到Map集合中并遍历，字符串的名字作键，年龄作值Map<String, Integer> map = arrayStream.collect(Collectors.toMap(s -> s.split(",")[0], s -> Integer.parseInt(s.split(",")[1])));Set<String> keySet = map.keySet();for (String key : keySet) {Integer value = map.get(key);System.out.println(key + "," + value);}}
  }