目录
一:集合处理数据的弊端
二:Stream流式思想概述
小结 :
三:获取Stream流的两种方式
方式1 : 根据Collection获取流
方式2 : Stream中的静态方法of获取流
小结
四:Stream常用方法和注意事项
Stream常用方法
Stream注意事项(重要)
Stream流的forEach方法
Stream流的count方法
Stream流的fifilter方法
Stream流的limit方法
Stream流的skip方法
Stream流的map方法
Stream流的sorted方法
Stream流的distinct方法
Stream流的match方法
Stream流的fifind方法
Stream流的max和min方法
Stream流的reduce方法
Stream流的map和reduce组合使用
Stream流的mapToInt
Stream流的concat方法
四:Stream综合案例
传统方式
Stream方式
一:集合处理数据的弊端
一个ArrayList集合中存储有以下数据:张无忌,周芷若,赵敏,张强,张三丰
需求:1.拿到所有姓张的 2.拿到名字长度为3个字的 3.打印这些数据 
 public static void main(String[] args) {
// 一个ArrayList集合中存储有以下数据:张无忌,周芷若,赵敏,张强,张三丰
// 需求:1.拿到所有姓张的 2.拿到名字长度为3个字的 3.打印这些数据
ArrayList<String> list = new ArrayList<>();
Collections.addAll(list, "张无忌", "周芷若", "赵敏", "张强", "张三丰");
// 1.拿到所有姓张的
ArrayList<String> zhangList = new ArrayList<>(); // {"张无忌", "张强", "张三丰"}
for (String name : list) {
if (name.startsWith("张")) {
zhangList.add(name);
}
}
// 2.拿到名字长度为3个字的
ArrayList<String> threeList = new ArrayList<>(); // {"张无忌", "张三丰"}
for (String name : zhangList) {
if (name.length() == 3) {
threeList.add(name);
}
}
// 3.打印这些数据
for (String name : threeList) {
System.out.println(name);
}
} 
  public class Demo03StreamFilter {
public static void main(String[] args) {
List<String> list = new ArrayList<>();
list.add("张无忌");
list.add("周芷若");
list.add("赵敏");
list.add("张强");
list.add("张三丰");
list.stream()
.filter(s -> s.startsWith("张"))
.filter(s -> s.length() == 3)
.forEach(System.out::println);
}
} 
   二:Stream流式思想概述

 

Stream API能让我们快速完成许多复杂的操作,如筛选、切片、映射、查找、去除重复,统计,匹配和归约。
小结 :
三:获取Stream流的两种方式
- 所有的 Collection 集合都可以通过 stream 默认方法获取流;
 - Stream 接口的静态方法 of 可以获取数组对应的流。
 
方式1 : 根据Collection获取流
public interface Collection {
default Stream<E> stream()
} 
  import java.util.*;
import java.util.stream.Stream;
public class Demo04GetStream {
public static void main(String[] args) {
// 集合获取流
// Collection接口中的方法: default Stream<E> stream() 获取流
List<String> list = new ArrayList<>();
// ...
Stream<String> stream1 = list.stream();
Set<String> set = new HashSet<>();
// ...
Stream<String> stream2 = set.stream();
Vector<String> vector = new Vector<>();
// ...
Stream<String> stream3 = vector.stream();
}
} 
  import java.util.HashMap;
import java.util.Map;
import java.util.stream.Stream;
public class Demo05GetStream {
public static void main(String[] args) {
// Map获取流
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();
}
} 
  方式2 : Stream中的静态方法of获取流
import java.util.stream.Stream;
public class Demo06GetStream {
public static void main(String[] args) {
// Stream中的静态方法: static Stream of(T... values)
Stream<String> stream6 = Stream.of("aa", "bb", "cc");
String[] arr = {"aa", "bb", "cc"};
Stream<String> stream7 = Stream.of(arr);
Integer[] arr2 = {11, 22, 33};
Stream<Integer> stream8 = Stream.of(arr2);
// 注意:基本数据类型的数组不行,它会将整个数组看做一个元素进行操作
int[] arr3 = {11, 22, 33};
Stream<int[]> stream9 = Stream.of(arr3);
}
} 
  小结
四:Stream常用方法和注意事项
Stream常用方法
|  
       
       方法名 
         |  
       
       方法作用 
         |  
       
       返回值类
         |  
       
       方法种类
         | 
|  
       
        count
         |  
       
       统计个数 
         | long | 终结 | 
|  
       
        forEach 
         | 逐一处理 | void | 终结 | 
|  
       
        fifilter 
         | 过滤 |  
       
       Stream
         | 函数拼接 | 
|  
       
        limit 
         | 取用前几个 | Stream |  
       
       函数拼接
         | 
|  
       
       skip 
         | 跳过前几个 | Stream |  
       
       函数拼接
         | 
|  
       
       map 
         | 映射 | Stream | 函数拼接 | 
|  
       
       concat 
         | 组合 | Stream | 函数拼接 | 
- 终结方法:返回值类型不再是 Stream 类型的方法,不再支持链式调用。本小节中,终结方法包括 count 和 forEach 方法。
 - 非终结方法:返回值类型仍然是 Stream 类型的方法,支持链式调用。(除了终结方法外,其余方法均为非终结方法。)
 
Stream注意事项(重要)
public class Demo03StreamNotice {
    public static void main(String[] args) {
        Stream<String> stream = Stream.of("aa", "bb", "cc");
        // 1. Stream只能操作一次
        // long count = stream.count();
        // long count2 = stream.count();
        // 2. Stream方法返回的是新的流
        // Stream<String> limit = stream.limit(1);
        // System.out.println("stream" + stream);
        // System.out.println("limit" + limit);
        // 3. Stream不调用终结方法,中间的操作不会执行
        stream.filter((s) -> {
            System.out.println(s);
            return true;
        }).count();
    }
} 
   
  Stream流的forEach方法
void forEach(Consumer<? super T> action); 
  @Test
    public void testForEach() {
        List<String> one = new ArrayList<>();
        Collections.addAll(one, "迪丽热巴", "宋远桥", "苏星河", "老子", "庄子", "孙子");
        /*// 得到流
        // 调用流中的方法
        one.stream().forEach((String str) -> {
            System.out.println(str);
        });
        // Lambda可以省略
        one.stream().forEach(str -> System.out.println(str));*/
        // Lambda可以转成方法引用
        one.stream().forEach(System.out::println);
    } 
   
  Stream流的count方法
long count(); 
   @Test
    public void testCount() {
        List<String> one = new ArrayList<>();
        Collections.addAll(one, "迪丽热巴", "宋远桥", "苏星河", "老子", "庄子", "孙子");
        long count = one.stream().count();
        System.out.println(count);
    } 
   
  Stream流的fifilter方法

可以通过 filter 方法将一个流转换成另一个子集流。方法声明:
Stream<T> filter(Predicate<? super T> predicate); 
   @Test
    public void testFilter() {
        List<String> one = new ArrayList<>();
        Collections.addAll(one, "迪丽热巴", "宋远桥", "苏星河", "老子", "庄子", "孙子");
        // 得到名字长度为3个字的人(过滤)
        // filter(Predicate<? super T> predicate)
        /*one.stream().filter((String s) -> {
            return s.length() == 3;
        }).forEach(System.out::println);*/
        // one.stream().filter(s -> s.length() == 3).forEach(System.out::println);
    }
 
   
  Stream流的limit方法

limit 方法可以对流进行截取,只取用前n个。方法签名:
Stream<T> limit(long maxSize); 
   @Test
    public void testLimit() {
        List<String> one = new ArrayList<>();
        Collections.addAll(one, "迪丽热巴", "宋远桥", "苏星河", "老子", "庄子", "孙子");
        // 获取前3个数据
        one.stream()
                .limit(3)
                .forEach(System.out::println);
    } 
   
  Stream流的skip方法

如果希望跳过前几个元素,可以使用 skip 方法获取一个截取之后的新流:
Stream<T> skip(long n); 
  @Test
    public void testSkip() {
        List<String> one = new ArrayList<>();
        Collections.addAll(one, "迪丽热巴", "宋远桥", "苏星河", "老子", "庄子", "孙子");
        // 跳过前两个数据
        one.stream()
                .skip(2)
                .forEach(System.out::println);
    } 
    
  Stream流的map方法
  
如果需要将流中的元素映射到另一个流中,可以使用 map 方法。方法签名:
<R> Stream<R> map(Function<? super T, ? extends R> mapper); 
  @Test
    public void testMap() {
        Stream<String> original = Stream.of("11", "22", "33");
        // Map可以将一种类型的流转换成另一种类型的流
        // 将Stream流中的字符串转成Integer
        /*Stream<Integer> stream = original.map((String s) -> {
            return Integer.parseInt(s);
        });*/
        // original.map(s -> Integer.parseInt(s)).forEach(System.out::println);
        original.map(Integer::parseInt).forEach(System.out::println);
    } 
  Stream流的sorted方法
Stream<T> sorted();
Stream<T> sorted(Comparator<? super T> comparator); 
  @Test
    public void testSorted() {
        // sorted(): 根据元素的自然顺序排序
        // sorted(Comparator<? super T> comparator): 根据比较器指定的规则排序
        Stream<Integer> stream = Stream.of(33, 22, 11, 55);
        // stream.sorted().forEach(System.out::println);
        /*stream.sorted((Integer i1, Integer i2) -> {
            return i2 - i1;
        }).forEach(System.out::println);*/
        stream.sorted((i1, i2) -> i2 - i1).forEach(System.out::println);
    } 
   Stream流的distinct方法

如果需要去除重复数据,可以使用 distinct 方法。方法签名:
Stream<T> distinct(); 
  @Test
    public void testDistinct() {
        Stream<Integer> stream = Stream.of(22, 33, 22, 11, 33);
        stream.distinct().forEach(System.out::println);
        Stream<String> stream1 = Stream.of("aa", "bb", "aa", "bb", "cc");
        stream1.distinct().forEach(System.out::println);
    }
 
  @Test
public void testDistinct2() {
Stream.of(
new Person("刘德华", 58),
new Person("张学友", 56),
new Person("张学友", 56),
new Person("黎明", 52))
.distinct()
.forEach(System.out::println);
} 
  public class Person {
private String name;
private int age;
// 省略其他
} 
    // distinct对自定义对象去除重复
    @Test
    public void testDistinct2() {
        Stream<Person> stream = Stream.of(
                new Person("貂蝉", 18),
                new Person("杨玉环", 20),
                new Person("杨玉环", 20),
                new Person("西施", 16),
                new Person("西施", 16),
                new Person("王昭君", 25)
        );
        stream.distinct().forEach(System.out::println);
    } 
  重写对象的hashCode和equals即可
    @Override
    public boolean equals(Object o) {
        if (this == o) return true;
        if (o == null || getClass() != o.getClass()) return false;
        Person person = (Person) o;
        if (age != person.age) return false;
        return name != null ? name.equals(person.name) : person.name == null;
    }
    @Override
    public int hashCode() {
        int result = name != null ? name.hashCode() : 0;
        result = 31 * result + age;
        return result;
    } 
   
  Stream流的match方法
如果需要判断数据是否匹配指定的条件,可以使用 Match 相关方法。方法签名:
boolean allMatch(Predicate<? super T> predicate);
boolean anyMatch(Predicate<? super T> predicate);
boolean noneMatch(Predicate<? super T> predicate); 
  基本使用
    @Test
    public void testMatch() {
        Stream<Integer> stream = Stream.of(5, 3, 6, 1);
        // boolean b = stream.allMatch(i -> i > 0); // allMatch: 匹配所有元素,所有元素都需要满足条件
        // boolean b = stream.anyMatch(i -> i > 5); // anyMatch: 匹配某个元素,只要有其中一个元素满足条件即可
        boolean b = stream.noneMatch(i -> i < 0); // noneMatch: 匹配所有元素,所有元素都不满足条件
        System.out.println(b);
    } 
   
  Stream流的fifind方法

如果需要找到某些数据,可以使用 find 相关方法。方法签名:
Optional<T> findFirst();
Optional<T> findAny(); 
  @Test
    public void testFind() {
        Stream<Integer> stream = Stream.of(33, 11, 22, 5);
        Optional<Integer> first = stream.findFirst();
        // Optional<Integer> first = stream.findAny();
        System.out.println(first.get());
    } 
    
  Stream流的max和min方法
  
Optional<T> max(Comparator<? super T> comparator);
Optional<T> min(Comparator<? super T> comparator); 
   @Test
    public void testMax_Min() {
        // 获取最大值
        // 1, 3, 5, 6
        Optional<Integer> max = Stream.of(5, 3, 6, 1).max((o1, o2) -> o1 - o2);
        System.out.println("最大值: " + max.get());
        // 获取最小值
        // 1, 3, 5, 6
        Optional<Integer> min = Stream.of(5, 3, 6, 1).min((o1, o2) -> o1 - o2);
        System.out.println("最小值: " + min.get());
    } 
    
  Stream流的reduce方法
  
T reduce(T identity, BinaryOperator<T> accumulator); 
    @Test
    public void testReduce() {
        // T reduce(T identity, BinaryOperator<T> accumulator);
        // T identity: 默认值
        // BinaryOperator<T> accumulator: 对数据进行处理的方式
        // reduce如何执行?
        // 第一次, 将默认值赋值给x, 取出集合第一元素赋值给y
        // 第二次, 将上一次返回的结果赋值x, 取出集合第二元素赋值给y
        // 第三次, 将上一次返回的结果赋值x, 取出集合第三元素赋值给y
        // 第四次, 将上一次返回的结果赋值x, 取出集合第四元素赋值给y
        int reduce = Stream.of(4, 5, 3, 9).reduce(0, (x, y) -> {
            System.out.println("x = " + x + ", y = " + y);
            return x + y;
        });
        System.out.println("reduce = " + reduce); // 21
        // 获取最大值
        Integer max = Stream.of(4, 5, 3, 9).reduce(0, (x, y) -> {
            return x > y ? x : y;
        });
        System.out.println("max = " + max);
    } 
    
Stream流的map和reduce组合使用
    @Test
    public void testMapReduce() {
        // 求出所有年龄的总和
        // 1.得到所有的年龄
        // 2.让年龄相加
        Integer totalAge = Stream.of(
                new Person("刘德华", 58),
                new Person("张学友", 56),
                new Person("郭富城", 54),
                new Person("黎明", 52))
                .map((p) -> p.getAge()).reduce(0, Integer::sum);
        System.out.println("totalAge = " + totalAge);
        // 找出最大年龄
        // 1.得到所有的年龄
        // 2.获取最大的年龄
        Integer maxAge = Stream.of(
                new Person("刘德华", 58),
                new Person("张学友", 56),
                new Person("郭富城", 54),
                new Person("黎明", 52))
                .map(p -> p.getAge())
                .reduce(0, Math::max);
        System.out.println("maxAge = " + maxAge);
        // 统计 a 出现的次数
        //                          1    0     0    1    0    1
        Integer count = Stream.of("a", "c", "b", "a", "b", "a")
                .map(s -> {
                    if (s == "a") {
                        return 1;
                    } else {
                        return 0;
                    }
                })
                .reduce(0, Integer::sum);
        System.out.println("count = " + count);
    }
 
     
   Stream流的mapToInt
IntStream mapToInt(ToIntFunction<? super T> mapper); 
    
  @Test
    public void testNumericStream() {
        // Integer占用的内存比int多,在Stream流操作中会自动装箱和拆箱
        Stream<Integer> stream = Stream.of(1, 2, 3, 4, 5);
        // 把大于3的打印出来
        // stream.filter(n -> n > 3).forEach(System.out::println);
        // IntStream mapToInt(ToIntFunction<? super T> mapper);
        // IntStream: 内部操作的是int类型的数据,就可以节省内存,减少自动装箱和拆箱
        /*IntStream intStream = Stream.of(1, 2, 3, 4, 5).mapToInt((Integer n) -> {
            return n.intValue();
        });*/
        IntStream intStream = Stream.of(1, 2, 3, 4, 5).mapToInt(Integer::intValue);
        intStream.filter(n -> n > 3).forEach(System.out::println);
    } 
     
   Stream流的concat方法
static <T> Stream<T> concat(Stream<? extends T> a, Stream<? extends T> b) 
       @Test
    public void testContact() {
        Stream<String> streamA = Stream.of("张三");
        Stream<String> streamB = Stream.of("李四");
        // 合并成一个流
        Stream<String> newStream = Stream.concat(streamA, streamB);
        // 注意:合并流之后,不能操作之前的流啦.
        // streamA.forEach(System.out::println);
        newStream.forEach(System.out::println);
    } 
       
     四:Stream综合案例
public class DemoArrayListNames {
public static void main(String[] args) {
List<String> one = List.of("迪丽热巴", "宋远桥", "苏星河", "老子", "庄子", "孙子", "洪七
公");
List<String> two = List.of("古力娜扎", "张无忌", "张三丰", "赵丽颖", "张二狗", "张天爱",
"张三");
// ....
}
} 
       public class Person {
private String name;
public Person() {}
public Person(String name) {
this.name = name;
}
@Override
public String toString() {
return "Person{name='" + name + "'}";
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
} 
       传统方式
public class DemoArrayListNames {
public static void main(String[] args) {
List<String> one = List.of("迪丽热巴", "宋远桥", "苏星河", "老子", "庄子", "孙子", "洪七
公");
List<String> two = List.of("古力娜扎", "张无忌", "张三丰", "赵丽颖", "张二狗", "张天爱",
"张三");
// 第一个队伍只要名字为3个字的成员姓名;
List<String> oneA = new ArrayList<>();
for (String name : one) {
if (name.length() == 3) {
oneA.add(name);
}
}
// 第一个队伍筛选之后只要前3个人;
List<String> oneB = new ArrayList<>();
for (int i = 0; i < 3; i++) {
oneB.add(oneA.get(i));
}
// 第二个队伍只要姓张的成员姓名;
List<String> twoA = new ArrayList<>();
for (String name : two) {
if (name.startsWith("张")) {
twoA.add(name);
}
}
// 第二个队伍筛选之后不要前2个人;
List<String> twoB = new ArrayList<>();
for (int i = 2; i < twoA.size(); i++) {
twoB.add(twoA.get(i));
}
// 将两个队伍合并为一个队伍;
List<String> totalNames = new ArrayList<>();
totalNames.addAll(oneB);
totalNames.addAll(twoB);
// 根据姓名创建Person对象;
List<Person> totalPersonList = new ArrayList<>();
for (String name : totalNames) {
totalPersonList.add(new Person(name));
}
// 打印整个队伍的Person对象信息。
for (Person person : totalPersonList) {
System.out.println(person);
}
}
} 
        
      Person{name='宋远桥'}
Person{name='苏星河'}
Person{name='洪七公'}
Person{name='张二狗'}
Person{name='张天爱'}
Person{name='张三'} 
       Stream方式
public class DemoStreamNames {
public static void main(String[] args) {
List<String> one = List.of("迪丽热巴", "宋远桥", "苏星河", "老子", "庄子", "孙子", "洪七
公");
List<String> two = List.of("古力娜扎", "张无忌", "张三丰", "赵丽颖", "张二狗", "张天爱",
"张三");
// 第一个队伍只要名字为3个字的成员姓名;
// 第一个队伍筛选之后只要前3个人;
Stream<String> streamOne = one.stream().filter(s -> s.length() == 3).limit(3);
// 第二个队伍只要姓张的成员姓名;
// 第二个队伍筛选之后不要前2个人;
Stream<String> streamTwo = two.stream().filter(s -> s.startsWith("张")).skip(2);
// 将两个队伍合并为一个队伍;
// 根据姓名创建Person对象;
// 打印整个队伍的Person对象信息。
Stream.concat(streamOne, streamTwo).map(Person::new).forEach(System.out::println);
}
} 
       
     Person{name='宋远桥'}
Person{name='苏星河'}
Person{name='洪七公'}
Person{name='张二狗'}
Person{name='张天爱'}
Person{name='张三'} 
    


















