【学习笔记】Java函数式编程02——Stream流

文章目录

  • 三、Stream流
    • 3.1 概述
    • 3.2 快速入门
      • 3.2.1 数据准备
      • 3.2.2 场景练习
        • 3.2.2.1 场景一、遍历所有作家并打印
          • :star:使用stream()流的forEach方法
        • 3.2.2.2 场景二、打印所以年龄小于18的作家名字，并且注意去重
          • :star:distinct()方法
          • :star:filter()方法
        • 3.2.2.3 场景三、基于题目2，注意实现根据作家名称去重
      • 3.2.3 IDEA的stream流调试功能
    • 3.3 常用操作
      • 3.3.1 创建流
        • 3.3.1.1 单列集合
        • 3.3.1.2 数组
        • 3.3.1.3 双列集合
      • 3.3.2 中间操作
        • 3.3.2.1 filter
        • 3.3.2.2 :star:map
        • 3.3.2.3 distinct
        • 3.3.2.4 :star:sorted
          • 关于：无参sorted()
          • 关于：有参sorted(Comparator)
        • 3.3.2.5 limit
          • 专项练习
        • 3.3.2.6 skip
        • 3.3.2.7 :star:flatMap
      • 3.3.3 终结操作 to be continued...

三、Stream流

3.1 概述

Stream流是JDK8提供的新特性。使用的是函数式编程的模式。

它可以被用来对集合或数组进行链状流式的操作。

和之前的IO流进行区分，IO流是针对文件和数据操作

可以更方便的对集合和数据进行操作。

3.2 快速入门

3.2.1 数据准备

依赖准备：lombok+hutool工具包即可

package com.zhc.demo02.entity;

import cn.hutool.core.lang.Snowflake;
import cn.hutool.core.lang.UUID;
import cn.hutool.core.util.RandomUtil;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.NoArgsConstructor;

import java.util.ArrayList;
import java.util.List;

/**
 * @Author zhuhuacong
 * @Date: 2023/12/12/ 10:40
 * @description 作者
 */
@Data
@AllArgsConstructor
@NoArgsConstructor
@EqualsAndHashCode
public class Author {
    private Long id;
    private String name;
    private Integer age;
    private String intro;
    private List<Book> books;

    public static List<Author> getAuthor(){
        List<Author> authors = new ArrayList<>();
        Snowflake snowflake = new Snowflake();

        for (int i = 0; i < 10; i++) {
            Author author = new Author();
            List<Book> books = new ArrayList<>();
            books.add(getBook(snowflake));
            books.add(getBook(snowflake));
            books.add(getBook(snowflake));
            books.add(getBook(snowflake));
            books.add(getBook(snowflake));
            author.setAge(RandomUtil.randomInt(20,60));
            author.setId(RandomUtil.randomLong());
            author.setName(RandomUtil.randomString(5));
            author.setIntro(RandomUtil.randomString(100));
            author.setBooks(books);
            authors.add(author);
        }

        return authors;
    }

    public static Book getBook(Snowflake snowflake ){
        return new Book(snowflake.nextId(), RandomUtil.randomString(5), RandomUtil.randomString(100), RandomUtil.randomInt(50, 100));

    }
}

package com.zhc.demo02.entity;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.NoArgsConstructor;

/**
 * @Author zhuhuacong
 * @Date: 2023/12/12/ 10:41
 * @description 书
 */
@Data
@AllArgsConstructor
@NoArgsConstructor
@EqualsAndHashCode
public class Book {
    private Long id;
    private String name;
    private String category;
    private Integer score;
}

3.2.2 场景练习

3.2.2.1 场景一、遍历所有作家并打印

方法一、按照原本是方法遍历对象并打印

（略）

方法二、使用stream()流

⭐️使用stream()流的forEach方法

需要注意：

  • java所有的集合类都带有这个stream方法

    default Stream<E> stream() {
    return StreamSupport.stream(spliterator(), false);
}

  • forEach方法需要传入我们前面学到的Consumer(消费者)的实现类

    void forEach(Consumer<? super T> action);

以此记得得出写法如下

List<Author> authors = Author.getAuthor();
authors.stream()    // 集合对象的stream方法
    .forEach(new Consumer<Author>() {
        @Override
        public void accept(Author author) {
            System.out.println(author + "\n");
        }
    });

使用省略规则简化后，得到的写法是

authors.stream()
    .forEach(author ->  System.out.println(author + "\n"));
  • 不难发现，使用lambda简化后，代码简介了非常多
3.2.2.2 场景二、打印所以年龄小于18的作家名字，并且注意去重

为了更好的模拟场景。可以将名字和年龄的生成逻辑进行修改。使用如下的方法。

// 类似
author.setName(RandomUtil.randomString("张王李",2));

同时难度加大

方法一、传统遍历代码

使用传统方法处理逻辑应该是这样的：

  1. 遍历集合先找出符合年龄的作家
  2. 再遍历一次符合条件的作家列表，判断名字是否重复
  3. 最终打印输出作家对象

方法二、使用stream()流

⭐️distinct()方法

使用这个方法可以对元素进行去重处理。需要注意：

  • 该方法的去重逻辑是调用Object.equals(Object)进行判断，所以在判断POJO实体类时，是需要重写equals和hashCode代码的
  • 对于有序流，这个方法是稳定的。如果是无序流，建议先执行sequential()方法后再进行去重
⭐️filter()方法

过滤器，完整方法如下

Stream<T> filter(Predicate<? super T> predicate);

看到了前一章学习的熟悉的方法Predicate（断言，实现这个函数式接口可以判断是否筛选过滤出该对象

代码如下：（最终优化

// 打印所以年龄小于18的作家名字，并且注意去重
List<Author> authors = Author.getAuthor();
authors.stream()
    .distinct()
    .filter(author -> author.getAge() < 18)
    .forEach( a -> System.out.println(a.getName()+"\t"+a.getAge()));
  • 代码非常简介
  • 验证结果——正确
3.2.2.3 场景三、基于题目2，注意实现根据作家名称去重

查看打印的结果可以发现，由于stream的distinct()方法是调用equals进行去重的

image-20231212115533711

其实结合实际生产中，往往需要根据作家名称去重

代码如下，使用到的map()方法，后续会进行研究

authors.stream()
    .filter(a -> a.getAge() < 18)
    .map(Author::getName)
    .distinct()
    .forEach(System.out::println);

3.2.3 IDEA的stream流调试功能

以场景3为例，我们调用了4个不同的stream流方法，打断点进入调试模式后就可以找到对应的“流调试”按钮

image-20231212142629962

进入该模式后就可以看到我们的刚才的操作了

1、转换为stream

image-20231212142716962

2、过滤

image-20231212142733631

3、提取元素

image-20231212142745981

4、去重

image-20231212142754671

5、遍历

这个就不用看了

3.3 常用操作

流在创建好之后，就需要一些中间操作对集合进行修改

操作完成后，需要结束这一次Stream流，必须要有终结操作，前面的代码才能生效

3.3.1 创建流

创建流的核心思想：将集合转换为流

3.3.1.1 单列集合

像列表、链表、Set就是单列集合

语法：集合对象.stream()（在父类collection已经新增了stream这个方法，可以直接转换

3.3.1.2 数组

语法：Arrays.stream(数组)——使用到了数组的工具类Arrays进行转换操作

或者Stream.of()也可以转换数组——注意这个方法的参数是一个【可变参数列表】，在java的低层，可变参就是一个数组。

3.3.1.3 双列集合

Map本身是无法直接转换为Stream流的，需要转换成单列集合后再转换为stream流

map.entrySet().stream()

3.3.2 中间操作

3.3.2.1 filter

可以对流中的元素进行条件过滤，**符合过滤条件（Predicate返回结果为true）**的才能继续留在流中。

前面已经接触过了，就不做赘述

3.3.2.2 ⭐️map

可以对流中的元素进行计算或者转换。

查看map源码，可以发现，maper传入的是一个Function接口，相当于取定义了一个复杂的类型转换（前一章学到的）

<R> Stream<R> map(Function<? super T, ? extends R> mapper);

做个小练习：将集合中每一个author对象转换为JSON字符串

List<Author> authors = Author.getAuthor();
// 匿名内部类式编程
authors.stream()
    .map(new Function<Author, String>() {
        @Override
        public String apply(Author author) {
            return JSON.toJSONString(author);
        }
    })
    .forEach(System.out::println);

// lambda
authors.stream()
    .map(author -> JSON.toJSONString(author))
    .forEach(System.out::println);

// 跟进一步简写（IDEA提供
authors.stream()
    .map(JSON::toJSONString)
    .forEach(System.out::println);

通过这个案例可以发现：

  • 遵循“省略原则”的返回类型是可推导的，那么匿名内部类就可以进行简写
  • IDEA提供的简写方式，进一步简写了传入的参数对象
3.3.2.3 distinct

去除流中的重复元素。

注意：distinct方法是依赖Obiect的equals方法来判断是否是相同对象的。所以需要注意重写equals方法。（前面⭐️distinct()方法提到了，不进行赘述了

3.3.2.4 ⭐️sorted

可以对集合进行排序。

查看源码可以发现sorted方法其实有两种重载的方式：一种是无参，一种是带有函数式接口参数Comparator（比较器）。

关于：无参sorted()

查看源码可知，要求排序的对象去实现Comparable接口，才能进行排序。

如果直接调用，则会抛出异常ClassCastException

举个例子：按作家的年龄进行排序，先使作家类实现Comparable接口，然后添加如下代码

/**
     * 比较
     *
     * @param o o
     * @return int -1、0或1，相当于对象小于、等于或大于指定对象。
     */
@Override
public int compareTo(Object o) {
    if (o instanceof Author){
        Author author = (Author) o;
        return this.age.compareTo(author.getAge());
    }
    return 0;
}

运行验证，通过

authors.stream()
    .sorted()
    .forEach(System.out::println);

关于顺序，其实不需要特意去记忆，只需要进行一次可测试即可。

关于：有参sorted(Comparator)

源码方法Stream<T> sorted(Comparator<? super T> comparator);

从匿名内部类开始简化

authors.stream()
    .sorted(new Comparator<Author>() {
        @Override
        public int compare(Author o1, Author o2) {
            return o1.getAge().compareTo(o2.getAge());
        }
    })
    .forEach(System.out::println);

// lambda简化
authors.stream()
    .sorted((o1, o2) -> o1.getAge().compareTo(o2.getAge()))
    .forEach(System.out::println);
// idea提供简化
authors.stream()
    .sorted(Comparator.comparing(Author::getAge))
    .forEach(System.out::println);

值得一提是idea提供的快捷简写方法。（不一定要会写，但是要懂得看）

3.3.2.5 limit

设置流的最大长度，超出的部分将会被抛弃。

  • 如果超过最大长度，则不会发生截取
专项练习

：对流中的元素按照年龄进行降序排序，并且要求不能有重复的元素,然后打印其中年龄最大的两个作家的姓名。

补充一下题意，为了体现去重的效果，选择补充根据名字+年龄的字段进行去重

// 匿名内部类写法
authors.stream()
    .sorted(new Comparator<Author>() {
        @Override
        public int compare(Author o1, Author o2) {
            return o2.getAge()-o1.getAge();
        }
    })
    .map(new Function<Author, String>() {
        @Override
        public String apply(Author author) {
            return author.getName()+author.getAge();
        }
    })
    .distinct()
    .limit(2)
    .forEach(System.out::println);
// 简化后写法
authors.stream()
    .sorted((o1, o2) -> o2.getAge()-o1.getAge())
    .map(author -> author.getName()+author.getAge())
    .distinct()
    .limit(2)
    .forEach(System.out::println);
3.3.2.6 skip

跳过前面的n个元素，返回剩下的元素。

（顾名思义，不做赘述

3.3.2.7 ⭐️flatMap

flatMap的效果和map类似但也有所不同

  • map只能将一个对象转换为另一个对象后，作为流中的元素
  • 而flatMap可以把一个对象转换成多个对象，作为流中的元素

**如何理解？**比如一个作者拥有多部作品，如果需要从“作家流”取出所有作品book，作为“作品流”，这个时候就可以用到flatMap了。

阅读源码也不难发现，flatMap要求传入的函数式接口Function中唯一的方法，已经定义好的返回的类型Stream

  <R> Stream<R> flatMap(Function<? super T, ? extends Stream<? extends R>> mapper);

举个例子

// 匿名内部类写法
authors.stream()
    .flatMap(new Function<Author, Stream<Book>>() {
        @Override
        public Stream<Book> apply(Author author) {
            return author.getBooks().stream();
        }
    })
    .forEach(new Consumer<Book>() {
        @Override
        public void accept(Book book) {
            System.out.println(book);
        }
    });

匿名内部类在flatMap中是比较繁琐的，因为需要指定 Stream<?>的类型才能保证forEach正常介绍到对象类型

// 简化后
authors.stream()
    .flatMap(author -> author.getBooks().stream())
    .forEach(System.out::println);

3.3.3 终结操作 to be continued…

终结操作另起一文！

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：/a/260499.html

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

【数据结构和算法】定长子串中元音的最大数目

【数据结构和算法】定长子串中元音的最大数目

其他系列文章导航 Java基础合集数据结构与算法合集 设计模式合集 多线程合集 分布式合集 ES合集 文章目录 其他系列文章导航 文章目录 前言 一、题目描述 二、题解 2.1 方法一&#xff1a;滑动窗口 2.2 方法二&#xff1a;滑动窗口优化版 三、代码 3.1 方法一&#xf…
阅读更多...
Python-基于fastapi实现SSE流式返回（类似GPT）

Python-基于fastapi实现SSE流式返回（类似GPT）

最近在做大模型对话相关功能&#xff0c;需要将对话内容流式返回给前端页面&#xff08;类似GPT的效果&#xff09;。下面直接说下如何实现&#xff1a; 1.首先导入fastapi和sse流式返回所需要的包 from fastapi import APIRouter, Response, status from sse_starlette.sse …
阅读更多...
【数据结构和算法】子数组最大平均数 I

【数据结构和算法】子数组最大平均数 I

其他系列文章导航 Java基础合集数据结构与算法合集 设计模式合集 多线程合集 分布式合集 ES合集 文章目录 其他系列文章导航 文章目录 前言 一、题目描述 二、题解 2.1 滑动窗口含义 2.2 滑动窗口一般解法 2.3 方法一&#xff1a;滑动窗口 三、代码 3.1 方法一&#…
阅读更多...
数据挖掘体系介绍

数据挖掘体系介绍

数据挖掘是什么&#xff1f; 简而言之&#xff0c;对数据进行挖掘&#xff0c;从中提取出有效的信息。一般我们会把这种信息通过概念、规则、规律、模式等有组织的方式展示出来&#xff0c;形成所谓的知识。特别是在这个大数据时代&#xff0c;当数据多到一定程度&#xff0c;…
阅读更多...
Jenkins 执行远程脚本的插件—SSH2 Easy

Jenkins 执行远程脚本的插件—SSH2 Easy

SSH2 Easy 是什么&#xff1f; SSH2 Easy 是一个 Jenkins 插件&#xff0c;它用于在 Jenkins 构建过程中通过 SSH2 协议与远程服务器进行交互。通过该插件&#xff0c;用户可以在 Jenkins 的构建过程中执行远程命令、上传或下载文件、管理远程服务器等操作。 以下是 SSH2 Eas…
阅读更多...
用户管理第2节课--idea 2023.2 后端--实现基本数据库操作(操作user表)

用户管理第2节课--idea 2023.2 后端--实现基本数据库操作(操作user表)

一、模型user对象>和数据库的字段关联 & 自动生成 【其中涉及删除表数据&#xff0c;一切又从零开始】 二、模型user对象>和数据库的字段关联 2.1在model文件夹下&#xff0c;新建 user对象 2.1.1 概念 大家可以想象我们现在的数据是存储在数据库里的&…
阅读更多...
HOT 100 最难的题居然是游戏厂的最爱

HOT 100 最难的题居然是游戏厂的最爱

写在前面 翻看 网易 历年笔面题单的时候&#xff0c;发现一道有意思的题目。 该题评论区&#xff0c;网易 的踪影很少&#xff0c;反而被那些在 4399 笔试中遇到的同学所攻陷&#xff1a; 好嘛&#xff0c;所以这道题还是「游戏厂」的最爱&#xff1f;&#xff01;&#x1f923…
阅读更多...
Ubuntu 常用命令之 fdisk 命令用法介绍

Ubuntu 常用命令之 fdisk 命令用法介绍

fdisk 是一个用于处理磁盘分区的命令行工具，它在 Linux 系统中广泛使用。fdisk 命令可以创建、删除、更改、复制和显示硬盘分区，以及更改硬盘的分区 ID。 fdisk 命令的常用参数如下 -l：列出所有分区表-b：设置扇区大小，如果不设置，默认为 512 字节-u：改变显示/输入单位-…
阅读更多...
亚马逊鲲鹏系统引爆广告点击率提升秘籍

亚马逊鲲鹏系统引爆广告点击率提升秘籍

在竞争激烈的电商市场&#xff0c;提高广告点击率成为各大卖家争相追求的目标。而如今&#xff0c;亚马逊鲲鹏系统的强大功能再次为卖家们打开了广告优化的新大门。其中&#xff0c;搜索广告功能更是成为提高关键词排名的利器。本文将详细介绍如何通过亚马逊鲲鹏系统实现点击广…
阅读更多...
全球知名的五款JavaScript混淆加密工具详解

全球知名的五款JavaScript混淆加密工具详解

​ 现在市场上有很多好用的混淆加密工具&#xff0c;其中一些比较流行且受欢迎的工具包括&#xff1a; 1、UglifyJS&#xff08;罗马尼亚&#xff09;&#xff1a;UglifyJS是一个非常流行的 JavaScript工具库&#xff0c;它可以压缩、混淆、美化和格式化 JavaScript 代码。使用…
阅读更多...
A01、关于jvm执行子系统

A01、关于jvm执行子系统

1、Class 类文件结构 1.1、Java跨平台的基础 各种不同平台的虚拟机与所有平台都统一使用的程序存储格式——字节码&#xff08;ByteCode&#xff09;是构成平台无关性的基石&#xff0c;也是语言无关性的基础。Java虚拟机不和包括Java在内的任何语言绑定&#xff0c;它只与 “…
阅读更多...
新三板炒股开户需要满足哪些条件？交易规则有哪些？

新三板炒股开户需要满足哪些条件？交易规则有哪些？

新三板是全国中小企业股份转让系统&#xff0c;属于场外市场&#xff0c;不能满足在主板上市的中小企业就可以申请在新三板挂牌交易。 一、新三板开通条件 新三板分为2个层级&#xff1a; 创新层&#xff1a;开通前10个交易日日均资产100万及以上&#xff0c;两年的股票交易经…
阅读更多...
Jenkins 构建触发器指南

Jenkins 构建触发器指南

目录 触发远程构建 (例如&#xff0c;使用脚本) 描述 配置步骤 安全令牌 在其他项目构建完成后触发构建 描述 配置步骤 定时触发构建 描述 配置步骤 GitHub钩子触发GITScm轮询 描述 配置步骤 Poll SCM - 轮询版本控制系统 描述 触发远程构建 (例如&#xff0c;使…
阅读更多...
基于SSM的双减后初小教育课外学习生活活动平台的设计与实现

基于SSM的双减后初小教育课外学习生活活动平台的设计与实现

末尾获取源码 开发语言&#xff1a;Java Java开发工具&#xff1a;JDK1.8 后端框架&#xff1a;SSM 前端&#xff1a;Vue 数据库&#xff1a;MySQL5.7和Navicat管理工具结合 服务器&#xff1a;Tomcat8.5 开发软件&#xff1a;IDEA / Eclipse 是否Maven项目&#xff1a;是 目录…
阅读更多...
基于EasyDarwin、ffmpeg实现rtsp推流

基于EasyDarwin、ffmpeg实现rtsp推流

目录 1 安装EasyDarwin 2 编译安装ffmpeg 3 启动EasyDarwin 4 ffmepg推流 5 百度网盘备份 某项目中测试时需要用到推流&#xff0c;于是用EasyDarwin、ffmpeg实现了RTSP推流&#xff0c;简单记录下过程&#xff0c; 1 安装EasyDarwin 这个可以去官网下载&#xff1a;Eas…
阅读更多...
SearchWP WordPress高级网站内容搜索插件

SearchWP WordPress高级网站内容搜索插件

点击阅读SearchWP WordPress高级网站内容搜索插件原文 SearchWP WordPress高级网站内容搜索插件是一个非常强大的工具&#xff0c;可以显着增强您网站的搜索功能。通过向网站访问者提供高度相关和精确的搜索结果&#xff0c;它可以有效地简化他们的搜索过程&#xff0c;促进发…
阅读更多...
快速能访问服务器的文件

快速能访问服务器的文件

1、背景 访问ubuntu上的文件 2、方法 python3 -m http.server 8081 --directory /home/ NAS 共享访问协议 — NFS、SMB、FTP、WebDAV 各有何优势&#xff1f;http://1 Ubuntu 搭建文件服务器&#xff08;Nginx&#xff09;
阅读更多...
SCA面面观 | SCA关键技术深度解析

SCA面面观 | SCA关键技术深度解析

数字时代的软件开发普遍遵循敏捷实践&#xff0c;发布和部署周期都很短&#xff0c;开发团队非常依赖开源来加速创新迭代速度。因此&#xff0c;对团队项目中包含的每个开源组件进行跟踪非常重要&#xff0c;可以避免法律风险&#xff0c;保持强大的安全态势。 在DevSecOps环境…
阅读更多...
[c]用指针进行四个数排序

[c]用指针进行四个数排序

#include<stdio.h> void swap(int*p1,int*p2)//定义函数&#xff0c;实现两个数值交换 {int temp;temp*p1;*p1*p2;*p2temp; } void psort( int *pa, int *pb,int *pc,int *pd) {int i1;for(i1;i<3;i)//对四个数排序&#xff0c;至少3次循环&#xff0c;交换过后是升序…
阅读更多...
Observability：客户为什么选择 Elastic 做日志？

Observability：客户为什么选择 Elastic 做日志？

作者&#xff1a;Ty Bekiares Elastic 正在改变日志体验以满足现代工作流程的需求。 在没有其他可观察信号的情况下&#xff0c;通常基础设施中的所有内容&#xff08;硬件、软件和服务&#xff09;都会发出日志行。 然而&#xff0c;日志通常是根据开发人员的想法构建的&…
阅读更多...
最新文章

Copyright @ 2022~2023