浅聊一下Stream流

通过stream获取集合中指定数据：

获取流：

stream流中的foreach方法：

stream流中的filter方法：

stream流中的limit方法：

stream流中的skip方法：

Stream流中的map方法：

stream流中的sorted方法：

Stream流中的distinct方法：

Stream流的match方法：

Stream流的find方法：

Stream流中的max和min方法：

Stream流的reduce方法：

Stream的concat方法：

Stream小练习：

将流中的数据收集到集合中：

将流中的数据收集到数组中：

对流中数据进行聚合运算：

对流中数据进行分组：

多级分组：

对流中数据进行拼接：

Optional类的基本使用：

参考：https://www.bilibili.com/video/BV1zJ411R7uQ/?vd_source=c75e68fd099206ad9761f2134ce79ce2

推荐博客：恕我直言，我怀疑你没怎么用过Stream流

我的是直接实战演示，大家想要知道概念什么的话可以参考一下上面的博客。

下面的内容写的可能比较混乱

通过stream获取集合中指定数据：

package com.jdktest01.day02;import java.util.ArrayList;
import java.util.Collections;/*** @author a1002*/
public class StreamTest01 {public static void main(String[] args) {ArrayList<String> list = new ArrayList<>();Collections.addAll(list, "张无忌", "周芷若", "赵敏", "张三丰", "师太", "韦小宝", "康熙");ArrayList<String> zhangList = new ArrayList<>();list.stream().filter((s) -> {return s.startsWith("张");}).filter((s) -> {return s.length() == 3;})//遍历.forEach((s) -> {System.out.println(s);System.out.println(s.length());//添加到集合中zhangList.add(s);});System.out.println("=========================");//拿到所有姓张的且长度为3的//集合遍历System.out.println(zhangList);System.out.println("---------------------------");list.forEach(System.out::println);}
}

获取流：

package com.jdktest01.day02;import java.util.*;
import java.util.stream.Stream;/*** @author a1002*/
public class StreamTest03 {public static void main(String[] args) {// 方式1 : 根据Collection获取流// 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();Map<String, String> map = new HashMap<>();Stream<String> stream3 = map.keySet().stream();Stream<String> stream4 = map.values().stream();Stream<Map.Entry<String, String>> stream5 = map.entrySet().stream();// 方式2 : Stream中的静态方法of获取流// static<T> Stream<T> of(T... values)Stream<String> stream6 = Stream.of("aa", "bb", "cc");String[] strs = {"aa", "bb", "cc"};Stream<String> stream7 = Stream.of(strs);// 基本数据类型的数组行不行?不行的,会将整个数组看做一个元素进行操作.int[] arr = {11, 22, 33};Stream<int[]> stream8 = Stream.of(arr);}
}

stream流中的foreach方法：

package com.jdktest01.day02;import java.util.ArrayList;
import java.util.Collections;
import java.util.List;/*** @author a1002*/
public class StreamTest04 {public static void main(String[] args) {List<String> one = new ArrayList<>();Collections.addAll(one, "迪丽热巴", "周雨彤", "马思纯", "肖战", "老子", "庄子");one.stream().forEach((String str) -> {System.out.println(str);});System.out.println("-------------------------");one.stream().forEach(System.out::println);System.out.println("-------------------------");one.forEach(System.out::println);}
}

stream流中的filter方法：

//过滤

List<String> one = new ArrayList<>();Collections.addAll(one, "迪丽热巴", "周雨彤", "马思纯", "肖战", "老子", "庄子");one.stream().filter((String s) -> {return s.length() == 3;}).forEach(System.out::println);System.out.println("---------------------");//简化one.stream().filter(s -> s.length() == 3).forEach(System.out::println);System.out.println("---------------------");

stream流中的limit方法：

//限制输出数据数量

            one.stream().limit(3).forEach(System.out::println);

stream流中的skip方法：

List<String> one = new ArrayList<>();Collections.addAll(one, "迪丽热巴", "周雨彤", "马思纯", "肖战", "老子", "庄子");//跳过指定的前两个数据one.stream().skip(2).forEach(System.out::println);

从下面可以看到skip指定类型是long，所以不能指定跳过某一个String。

Stream流中的map方法：

@Testpublic void testMap() {//Map可以将一种类型的流转为另一种类型的流Stream<String> original = Stream.of("11", "22", "33");//将stream流中的字符串转为Integer//参数就是你原本的类型
//        original.map((String s) -> {
//            return Integer.parseInt(s);
//        });System.out.println("---------------------");//简化//      original.map(s -> Integer.parseInt(s)).forEach(System.out::println);//再简化original.map(Integer::parseInt).forEach(System.out::println);}

stream流中的sorted方法：

//排序

@Testpublic void testSorted() {// sorted(): 根据元素的自然顺序排序// sorted(Comparator<? super T> comparator): 根据比较器指定的规则排序Stream<Integer> stream = Stream.of(33, 22, 11, 55);//升序stream.sorted().forEach(System.out::println);System.out.println("------------------------");//降序stream.sorted((Integer i1, Integer i2) -> {return i2 - i1;}).forEach(System.out::println);System.out.println("------------------------");//降序简化stream.sorted((i1, i2) -> i2 - i1).forEach(System.out::println);}

Stream流中的distinct方法：

// distinct对自定义对象去除重复@Testpublic void testDistinct() {Stream<Integer> stream = Stream.of(33, 22, 11, 55, 88, 33, 22, 22, 88, 34, 23);stream.distinct().forEach(System.out::println);Stream<String> stream1 = Stream.of("a", "b", "c", "a", "b");stream1.distinct().forEach(System.out::println);}

对Person类中的equals和hashcode方法进行重写，stream中的数据再运行时就会被去重

@Testpublic void testDistinct01() {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);}

重写Person类中的equals和hashcode方法：

运行结果：

Stream流的match方法：

@Testpublic void testMatch() {Stream<Integer> stream = Stream.of(33, 22, 11, 55, 88, 33, 22, 22, 88, 34, 23);//allMatch需要所有的元素都满足才返回true//allMatch：匹配所有元素，所有的元素都需要满足条件boolean b = stream.allMatch((Integer i) -> {return i > 22;});System.out.println(b);Stream<Integer> stream1 = Stream.of(11, 2, 4, 5);//allMatch需要所有的元素都满足才返回trueboolean b1 = stream1.allMatch((Integer i) -> {return i > 0;});System.out.println(b1);//anyMatch: 匹配某个元素,只要有其中一个元素满足条件即可Stream<Integer> stream3 = Stream.of(33, 22, 11, 55, 88, 33, 22, 22, 88, 34, 23);boolean b2 = stream3.anyMatch((Integer i) -> {return i > 22;});System.out.println(b2);//noneMatch: 匹配所有元素,所有元素都不满足条件Stream<Integer> stream4 = Stream.of(33, 22, 11, 55, 88, 33, 22, 22, 88, 34, 23);boolean b3 = stream4.noneMatch(i -> i > 0);System.out.println(b3);}

Stream流的find方法：

@Testpublic void testFind() {Stream<Integer> stream = Stream.of(33, 22, 11, 55, 88, 33, 22, 22, 88, 34, 23);Optional<Integer> optional = stream.findFirst();System.out.println(optional.get());}

Stream流中的max和min方法：

@Testpublic void testMax() {//获取最大值Stream<Integer> stream = Stream.of(33, 22, 11, 55, 88, 33, 22, 22, 88, 34, 23);Optional<Integer> max = stream.max((o1, o2) -> o1 - o2);System.out.println(max.get());//获取最小值Optional<Integer> min = Stream.of(5, 6, 3, 1).min((o1, o2) -> o1 - o2);System.out.println(min.get());}

输出：

Stream流的reduce方法：

        // T reduce(T identity, BinaryOperator<T> accumulator);// T identity: 默认值// BinaryOperator<T> accumulator: 对数据进行处理的方式// reduce如何执行?// 第一次, 将默认值赋值给x, 取出集合第一元素赋值给y// 第二次, 将上一次返回的结果赋值x, 取出集合第二元素赋值给y// 第三次, 将上一次返回的结果赋值x, 取出集合第三元素赋值给y// 第四次, 将上一次返回的结果赋值x, 取出集合第四元素赋值给y//以此类推
@Testpublic void testReduce() {int reduce = Stream.of(4, 5, 7, 2, 9).reduce(0, (x, y) -> {System.out.println("x = " + x + " y = " + y);return x + y;});System.out.println(reduce);}

有点类似于js的特性。

27即为数据和。

找出最大值：

int max = Stream.of(4, 5, 7, 2, 9).reduce(0, (x, y) -> {return x > y ? x : y;});System.out.println(max);

对stream里面封装对象里的某一个数据进行求和：

@Testpublic void testReduce01() {Integer totalAge = Stream.of(new Person("刘德华", 58),new Person("张学友", 56),new Person("郭富城", 54),new Person("黎明", 52)).map((p) -> {return p.getAge();}).reduce(0, (x, y) -> {return x + y;});System.out.println("totalAge= " + totalAge);}

求stream内封装对象某一个属性最大值

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出现的次数Integer count = Stream.of("a", "b", "a", "d", "a").map(s -> {if (s == "a") {return 1;} else {return 0;}}).reduce(0, Integer::sum);System.out.println("count=" + count);