从零开始学习 Java：简单易懂的入门指南之Stream流（二十七）

2023-09-20 08:47:49

Stream流

Stream流

1.体验Stream流

  • 案例需求

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

    • 创建一个集合，存储多个字符串元素
    • 把集合中所有以"张"开头的元素存储到一个新的集合
    • 把"张"开头的集合中的长度为3的元素存储到一个新的集合
    • 遍历上一步得到的集合

  • 原始方式示例代码

    public class MyStream1 {
    public static void main(String[] args) {
        //集合的批量添加
        ArrayList<String> list1 = new ArrayList<>(List.of(c));
        //list.add()

        //遍历list1把以张开头的元素添加到list2中。
        ArrayList<String> list2 = new ArrayList<>();
        for (String s : list1) {
            if(s.startsWith("张")){
                list2.add(s);
            }
        }
        //遍历list2集合，把其中长度为3的元素，再添加到list3中。
        ArrayList<String> list3 = new ArrayList<>();
        for (String s : list2) {
            if(s.length() == 3){
                list3.add(s);
            }
        }
        for (String s : list3) {
            System.out.println(s);
        }      
    }
}

  • 使用Stream流示例代码

    public class StreamDemo {
    public static void main(String[] args) {
        //集合的批量添加
        ArrayList<String> list1 = new ArrayList<>(List.of("张三丰","张无忌","张翠山","王二麻子","张良","谢广坤"));

        //Stream流
        list1.stream().filter(s->s.startsWith("张"))
                .filter(s->s.length() == 3)
                .forEach(s-> System.out.println(s));
    }
}

  • Stream流的好处

    • 直接阅读代码的字面意思即可完美展示无关逻辑方式的语义：获取流、过滤姓张、过滤长度为3、逐一打印
    • Stream流把真正的函数式编程风格引入到Java中
    • 代码简洁

2.Stream流的常见生成方式

  • Stream流的思想

在这里插入图片描述

  • Stream流的三类方法

    • 获取Stream流
      • 创建一条流水线,并把数据放到流水线上准备进行操作
    • 中间方法
      • 流水线上的操作
      • 一次操作完毕之后,还可以继续进行其他操作
    • 终结方法
      • 一个Stream流只能有一个终结方法
      • 是流水线上的最后一个操作

  • 生成Stream流的方式

    • Collection体系集合

      使用默认方法stream()生成流， default Stream stream()

    • Map体系集合

      把Map转成Set集合，间接的生成流

    • 数组

      通过Arrays中的静态方法stream生成流

    • 同种数据类型的多个数据

      通过Stream接口的静态方法of(T… values)生成流

  • 代码演示

    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();

        //数组可以通过Arrays中的静态方法stream生成流
        String[] strArray = {"hello","world","java"};
        Stream<String> strArrayStream = Arrays.stream(strArray);
      
      	//同种数据类型的多个数据可以通过Stream接口的静态方法of(T... values)生成流
        Stream<String> strArrayStream2 = Stream.of("hello", "world", "java");
        Stream<Integer> intStream = Stream.of(10, 20, 30);
    }
}

3.Stream流中间操作方法

  • 概念

    中间操作的意思是,执行完此方法之后,Stream流依然可以继续执行其他操作

  • 常见方法

    方法名说明
    Stream filter(Predicate predicate)用于对流中的数据进行过滤
    Stream limit(long maxSize)返回此流中的元素组成的流，截取前指定参数个数的数据
    Stream skip(long n)跳过指定参数个数的数据，返回由该流的剩余元素组成的流
    static Stream concat(Stream a, Stream b)合并a和b两个流为一个流
    Stream distinct()返回由该流的不同元素（根据Object.equals(Object) ）组成的流

  • filter代码演示

    public class MyStream3 {
    public static void main(String[] args) {
//        Stream<T> filter(Predicate predicate)：过滤
//        Predicate接口中的方法	boolean test(T t)：对给定的参数进行判断，返回一个布尔值

        ArrayList<String> list = new ArrayList<>();
        list.add("张三丰");
        list.add("张无忌");
        list.add("张翠山");
        list.add("王二麻子");
        list.add("张良");
        list.add("谢广坤");

        //filter方法获取流中的 每一个数据.
        //而test方法中的s,就依次表示流中的每一个数据.
        //我们只要在test方法中对s进行判断就可以了.
        //如果判断的结果为true,则当前的数据留下
        //如果判断的结果为false,则当前数据就不要.
//        list.stream().filter(
//                new Predicate<String>() {
//                    @Override
//                    public boolean test(String s) {
//                        boolean result = s.startsWith("张");
//                        return result;
//                    }
//                }
//        ).forEach(s-> System.out.println(s));

        //因为Predicate接口中只有一个抽象方法test
        //所以我们可以使用lambda表达式来简化
//        list.stream().filter(
//                (String s)->{
//                    boolean result = s.startsWith("张");
//                        return result;
//                }
//        ).forEach(s-> System.out.println(s));

        list.stream().filter(s ->s.startsWith("张")).forEach(s-> System.out.println(s));

    }
}

  • limit&skip代码演示

    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(s-> System.out.println(s));
        System.out.println("--------");

        //需求2：跳过3个元素，把剩下的元素在控制台输出
        list.stream().skip(3).forEach(s-> System.out.println(s));
        System.out.println("--------");

        //需求3：跳过2个元素，把剩下的元素中前2个在控制台输出
        list.stream().skip(2).limit(2).forEach(s-> System.out.println(s));
    }
}

  • concat&distinct代码演示

    public class StreamDemo03 {
    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：取前4个数据组成一个流
        Stream<String> s1 = list.stream().limit(4);

        //需求2：跳过2个数据组成一个流
        Stream<String> s2 = list.stream().skip(2);

        //需求3：合并需求1和需求2得到的流，并把结果在控制台输出
//        Stream.concat(s1,s2).forEach(s-> System.out.println(s));

        //需求4：合并需求1和需求2得到的流，并把结果在控制台输出，要求字符串元素不能重复
        Stream.concat(s1,s2).distinct().forEach(s-> System.out.println(s));
    }
}

4.Stream流终结操作方法

  • 概念

    终结操作的意思是,执行完此方法之后,Stream流将不能再执行其他操作

  • 常见方法

    方法名说明
    void forEach(Consumer action)对此流的每个元素执行操作
    long count()返回此流中的元素数

  • 代码演示

    public class MyStream5 {
    public static void main(String[] args) {
        ArrayList<String> list = new ArrayList<>();
        list.add("张三丰");
        list.add("张无忌");
        list.add("张翠山");
        list.add("王二麻子");
        list.add("张良");
        list.add("谢广坤");

        //method1(list);
        
//        long count()：返回此流中的元素数
        long count = list.stream().count();
        System.out.println(count);
    }

    private static void method1(ArrayList<String> list) {
        //  void forEach(Consumer action)：对此流的每个元素执行操作
        //  Consumer接口中的方法void accept(T t)：对给定的参数执行此操作
        //在forEach方法的底层,会循环获取到流中的每一个数据.
        //并循环调用accept方法,并把每一个数据传递给accept方法
        //s就依次表示了流中的每一个数据.
        //所以,我们只要在accept方法中,写上处理的业务逻辑就可以了.
        list.stream().forEach(
                new Consumer<String>() {
                    @Override
                    public void accept(String s) {
                        System.out.println(s);
                    }
                }
        );
      
        System.out.println("====================");
        //lambda表达式的简化格式
        //是因为Consumer接口中,只有一个accept方法
        list.stream().forEach(
                (String s)->{
                    System.out.println(s);
                }
        );
        System.out.println("====================");
        //lambda表达式还是可以进一步简化的.
        list.stream().forEach(s->System.out.println(s));
    }
}

5.Stream流的收集操作

  • 概念

    对数据使用Stream流的方式操作完毕后,可以把流中的数据收集到集合中

  • 常用方法

    方法名说明
    R collect(Collector collector)把结果收集到集合中

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

    方法名说明
    public static Collector toList()把元素收集到List集合中
    public static Collector toSet()把元素收集到Set集合中
    public static Collector toMap(Function keyMapper,Function valueMapper)把元素收集到Map集合中

  • 代码演示

    // toList和toSet方法演示 
public class MyStream7 {
    public static void main(String[] args) {
        ArrayList<Integer> list1 = new ArrayList<>();
        for (int i = 1; i <= 10; i++) {
            list1.add(i);
        }

        list1.add(10);
        list1.add(10);
        list1.add(10);
        list1.add(10);
        list1.add(10);

        //filter负责过滤数据的.
        //collect负责收集数据.
                //获取流中剩余的数据,但是他不负责创建容器,也不负责把数据添加到容器中.
        //Collectors.toList() : 在底层会创建一个List集合.并把所有的数据添加到List集合中.
        List<Integer> list = list1.stream().filter(number -> number % 2 == 0)
                .collect(Collectors.toList());

        System.out.println(list);

    Set<Integer> set = list1.stream().filter(number -> number % 2 == 0)
            .collect(Collectors.toSet());
    System.out.println(set);
}
}
/**
Stream流的收集方法 toMap方法演示
创建一个ArrayList集合，并添加以下字符串。字符串中前面是姓名，后面是年龄
"zhangsan,23"
"lisi,24"
"wangwu,25"
保留年龄大于等于24岁的人，并将结果收集到Map集合中，姓名为键，年龄为值
*/
public class MyStream8 {
	public static void main(String[] args) {
      	ArrayList<String> list = new ArrayList<>();
        list.add("zhangsan,23");
        list.add("lisi,24");
        list.add("wangwu,25");

        Map<String, Integer> map = list.stream().filter(
                s -> {
                    String[] split = s.split(",");
                    int age = Integer.parseInt(split[1]);
                    return age >= 24;
                }

         //   collect方法只能获取到流中剩余的每一个数据.
         //在底层不能创建容器,也不能把数据添加到容器当中

         //Collectors.toMap 创建一个map集合并将数据添加到集合当中

          // s 依次表示流中的每一个数据

          //第一个lambda表达式就是如何获取到Map中的键
          //第二个lambda表达式就是如何获取Map中的值
        ).collect(Collectors.toMap(
                s -> s.split(",")[0],
                s -> Integer.parseInt(s.split(",")[1]) ));

        System.out.println(map);
	}
}

6.Stream流综合练习

  • 案例需求

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

    • 男演员只要名字为3个字的前三人
    • 女演员只要姓林的，并且不要第一个
    • 把过滤后的男演员姓名和女演员姓名合并到一起
    • 把上一步操作后的元素作为构造方法的参数创建演员对象,遍历数据

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

  • 代码实现

    演员类

    public class Actor {
    private String name;

    public Actor(String name) {
        this.name = name;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }
}

    测试类

    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个字的前三人
        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);
  
      	// 将流中的数据封装成Actor对象之后打印
      	stream.forEach(name -> {
            Actor actor = new Actor(name);
            System.out.println(actor);
        }); 
    }
}

后记
👉👉💕💕美好的一天，到此结束，下次继续努力！欲知后续，请看下回分解，写作不易，感谢大家的支持！！ 🌹🌹🌹

更多推荐

Linux中使用selenium截图的文字变为方框的解决方案

一、前言最近在Linux中使用selenium截图时，发现文字都变为了方框：虽然不影响selenium的使用，但有点影响调试，也不好看，后面发现是因为Linux缺少中文字体的缘故，需要安装中文字体就能解决。二、安装中文字体（以centos为例）1）前置检查先检查/usr/share目录下是否有有fonts和fontco

[2023.09.21]:源码已上传，供大家了解Rust Yew的前后端开发

这个资源是Rust的源代码压缩包，供大家了解RustYew的前后端开发。资源中的代码非常简洁易懂，虽然离商用场景还有一段距离，但是涵盖了前端的组件搭建、事件通信和反向代理，以及后端的RestfulAPI的路由、功能实现和数据库访问。此外，还包括了postgres数据库的初始化脚本和docker部署脚本，方便您快速搭建环

前端版本更新提示

前端版本更新提示前言：最近项目发布比较频繁、导致每次都要主动告知用户/测试去刷新清除页面缓存、从而防止发了新功能之后、用户因为没有刷新页面/清除缓存，一直使用的还是旧版本。所以就着手写一个检测到发布了新版本就自动提醒用户去刷新页面的功能。一、思路：我们可以通过每次打包构建(npmrunbuild)之后给包打一个唯一标识

企业为什么做数字化转型？

数字化转型是一个战略性的、势在必行的过程，企业利用技术和数字工具从根本上改变其运营方式，为客户提供价值，并在现代商业环境中保持竞争力。企业踏上数字化转型之旅有几个令人信服的理由：1.提高效率和生产力：数字工具和自动化可以简化流程、减少手动工作并提高整体运营效率。这使得组织能够用更少的资源做更多的事情并更有效地分配资源。

进程同步与互斥

目录进程同步与互斥（1）第一节、进程间相互作用一、相关进程和无关进程二、与时间有关的错误第二节、进程同步与互斥一、进程的同步二、进程的互斥三、临界区进程同步与互斥（2）三、信号量与P、V操作的物理含义四、用P、V操作实现进程间的互斥五、用P、V操作实现进程间的同步六、信号量及P、V操作总结进程同步与互斥（3）第四节经典

MyBatis基础之动态SQL

文章目录动态SQLif元素choose-when-otherwise元素where元素set元素foreach元素动态SQL简而言之，动态SQL就是在Mapper中使用分支、循环等逻辑。常见的动态SQL元素包括：if元素choose-when-otherwise元素where元素set元素foreach元素if元素<i

第二章 物理层

引言如果这篇文章对您有帮助的话，希望您能点赞、收藏、加关注！您的鼓励就是我前进的动力！本文所参考的教材为：谢希仁.计算机网络.北京：电子工业出版社,2021.重要知识点总结三种通信方式：单向通信、双向交替通信、双向同时通信。两大类调制：基带调制（编码），带通调制。常用的四种编码方式：不归零制、归零制、曼彻斯特编码、差分

Jenkins ：添加node权限获取凭据、执行命令

拥有Jenkinsagent权限的账号可以对node节点进行操作，通过添加不同的node可以让流水线项目在不同的节点上运行，安装Jenkins的主机默认作为master节点。1.Jenkins添加node获取明文凭据通过添加node节点，本地监听ssh认证，选则凭据（明文）进行ssh认证，拿到密码。1.新建节点-man

在 Vue3 项目中如何关闭 ESLint

介绍ESLint是一个用于检查JavaScript代码质量的工具，它可以帮助开发者遵循一致的编码规范，并发现潜在的错误和问题。然而，在某些情况下，我们可能希望关闭ESLint，例如在一些小型项目中或者在特定的开发阶段。本文将介绍如何在Vue3项目中关闭ESLint。步骤第一步：找到配置文件在Vue3项目中，ESLint

Android Studio导入aosp源码

1、在Ubuntu系统下，进入源码根目录，运行如下命令：sourcebuild/envsetup.sh#初始化环境变量。lunchsdk_phone_x86_64makeidegen-j6#六核编译idegen模块忽略此命令：mmmdevelopment/tools/idegen/#此命令可以不执行(同makeideg

竞赛 基于机器视觉的行人口罩佩戴检测

简介2020新冠爆发以来，疫情牵动着全国人民的心，一线医护工作者在最前线抗击疫情的同时，我们也可以看到很多科技行业和人工智能领域的从业者，也在贡献着他们的力量。近些天来，旷视、商汤、海康、百度都多家科技公司研发出了带有AI人脸检测算法的红外测温、口罩佩戴检测等设备，依图、阿里也研发出了通过深度学习来自动诊断新冠肺炎的医

热文推荐
  1. Gateway核心架构

    1Gateway核心架构1.1基本概念路由(Route)是gateway中最基本的组件之一，表示一个具体的路由信息载体。主要定义了下面的几个信息:id，路由标识符，区别于其他Route。uri，路由指向的目的地uri，即客户端请求最终被转发到的微服务。order，用于多个Route之间的排序，数值越小排序越靠前，匹配优

  2. Java常用类之 String、StringBuffer、StringBuilder

    Java常用类文章目录一、字符串相关的类1.1、String的不可变性1.2、String不同实例化方式的对比1.3、String不同拼接操作的对比1.4、String的常用方法1.5、String类与其他结构之间的转换1.5.1、String与基本数据类型、包装类之间的转换1.5.2、String与char[]的转换

  3. 多线程知识点整理

    一.线程的状态1.线程创建，2.线程运行，3线程阻塞，4.线程等待，5.timed_waiting6.线程执行完毕publicenumState{//线程刚创建NEW,//在JVM中正在运行的线程RUNNABLE,//线程处于阻塞状态，等待监视锁，可以重新进行同步代码块中执行BLOCKED,//等待状态WAITING,

  4. 腾讯mini项目-【指标监控服务重构】2023-08-06

    今日已办feature/client_traces_profile修改consumer4个阶段的spankind将profile的span作为rootspan，保持与venus的followsfrom的linkfeature/profile-otelclient-metric将metric部分使用新分支pushgo.o

  5. 芯片核数造假，华为不装了，网友直呼这一波赚翻了！

    首先说一下之前以为华为是青岛新恩制作的芯片，但是在最新的一个消息中发现，麒麟芯片其实是华为子公司自主研发生产的。2个重量级消息，华为突破芯片封锁后，美国科技界惊出一身冷汗！华为麒麟9000s是中芯国际做的吗？台积电和三星有没有参与？最终是这家青岛公司扛下了所有。而华为芯片为什么可以确定，而不是之前囤积的呢？其实是因为在

  6. Linux CentOS7 wc命令

    wc命令的功能为统计指定文件中的字节数、字数、行数,并将统计结果显示输出。录入manwc可以查看相关信息基本语法：wc[选项]文件…说明：该命令统计给定文件中的字节数、字数、行数。如果没有给出文件名，则从标准输入读取。wc同时也给出所有指定文件的总统计数。字是由空格字符区分开的最大字符串。该命令常用选项：-l统计行数-

  7. Vue的详细教程--入门

    🥳🥳WelcomeHuihui'sCodeWorld!!🥳🥳接下来看看由辉辉所写的关于Vue的相关操作吧目录🥳🥳WelcomeHuihui'sCodeWorld!!🥳🥳一.Vue是什么二.Vue的特点及优势三.使用Vue的详细步骤1.导入2.定义边界3.创建vue实例四.Vue的基本语法①v-model

  8. 浅谈C++|文件篇

    C++中的文件操作是通过使用文件流来实现的。文件流提供了对文件的输入和输出功能。下面是C++文件操作的基本步骤：1.包含头文件：首先，包含`<fstream>`头文件，它包含了进行文件操作所需的类和函数。2.进行文件读写操作：使用文件流对象的成员函数进行文件读写操作。例如，使用`getline()`函数逐行读取文本内容

  9. 小型水库雨水情测报和大坝安全监测解决方案

    一、建设背景我国小型水库数量众多，大多由农村集体经济组织管理，灌溉、供水、防洪、生态效益突出，是农业生产、农民生活、农村发展和区域防洪的重要基础设施，实施乡村振兴战略和生态文明建设的重要支撑保障。由于小型水库工程存在先天不足等问题，缺陷较多。2021年10月19日，水利部正式印发《小型水库雨水情测报和大坝安全监测设施建