Java Stream中的API你都用过了吗？

公众号「架构成长指南」，专注于生产实践、云原生、分布式系统、大数据技术分享。

在本教程中，您将通过大量示例来学习 Java 8 Stream API。

Java 在 Java 8 中提供了一个新的附加包，称为 java.util.stream。该包由类、接口和枚举组成，允许对元素进行函数式操作。 您可以通过在程序中导入 java.util.stream包来使用流。

Stream提供以下功能：

Stream不存储元素。它只是通过计算操作的管道传送来自数据结构、数组或 I/O 通道等源的元素。

Stream本质上是函数式的，对流执行的操作不会修改其源。例如，过滤从集合获取的 Stream 会生成一个没有过滤元素的新 Stream，而不是从源集合中删除元素。

Stream是惰性的，仅在需要时才计算代码，在流的生命周期中，流的元素仅被访问一次。

与迭代器一样，必须生成新流才能重新访问源中的相同元素。
您可以使用 Stream 来 过滤、收集、打印以及 从一种数据结构转换为其他数据结构等。

Stream API 示例

1. 创建一个空的Stream

在创建空流时，应使用 empty() 方法：

Stream<String> stream = Stream.empty();
stream.forEach(System.out::println);

通常情况下，在创建时会使用 empty() 方法，以避免在没有元素的流中返回 null：

public Stream<String> streamOf(List<String> list) {return list == null || list.isEmpty() ? Stream.empty() : list.stream();
}
2.从集合中创建流
import java.io.IOException;
import java.util.Arrays;
import java.util.Collection;
import java.util.HashSet;
import java.util.List;
import java.util.Set;
import java.util.stream.Stream;public class StreamCreationExamples {public static void main(String[] args) throws IOException {Collection<String> collection = Arrays.asList("JAVA", "J2EE", "Spring", "Hibernate");Stream<String> stream2 = collection.stream();stream2.forEach(System.out::println);List<String> list = Arrays.asList("JAVA", "J2EE", "Spring", "Hibernate");Stream<String> stream3 = list.stream();stream3.forEach(System.out::println);Set<String> set = new HashSet<>(list);Stream<String> stream4 = set.stream();stream4.forEach(System.out::println);}
}

输出

JAVA
J2EE
Spring
Hibernate
JAVA
J2EE
Spring
Hibernate
JAVA
Hibernate
J2EE
Spring
3. 从数组中创建流对象

数组可以是流的源，也可以从现有数组或数组的一部分创建数组：

import java.util.Arrays;
import java.util.stream.Stream;public class StreamCreationExample {public static void main(String[] args) {// 使用Arrays.stream()创建流int[] numbers = {1, 2, 3, 4, 5};Stream<Integer> stream1 = Arrays.stream(numbers);System.out.println("Using Arrays.stream():");stream1.forEach(System.out::println);// 使用Stream.of()创建流String[] names = {"Alice", "Bob", "Charlie"};Stream<String> stream2 = Stream.of(names);System.out.println("Using Stream.of():");stream2.forEach(System.out::println);// 使用Stream.builder()创建流String[] colors = {"Red", "Green", "Blue"};Stream.Builder<String> builder = Stream.builder();for (String color : colors) {builder.add(color);}Stream<String> stream3 = builder.build();System.out.println("Using Stream.builder():");stream3.forEach(System.out::println);}
}

输出

Using Arrays.stream():
1
2
3
4
5
Using Stream.of():
Alice
Bob
Charlie
Using Stream.builder():
Red
Green
Blue
4. 使用Stream过滤一个集合示例

在下面的示例中，我们不使用流过滤数据，看看代码是什么样的，同时我们在给出一个使用stream过滤的示例，对比一下

不使用Stream过滤一个集合示例

import java.util.ArrayList;
import java.util.List;public class FilterWithoutStreamExample {public static void main(String[] args) {List<Integer> numbers = new ArrayList<>();numbers.add(10);numbers.add(20);numbers.add(30);numbers.add(40);numbers.add(50);List<Integer> filteredNumbers = new ArrayList<>();for (Integer number : numbers) {if (number > 30) {filteredNumbers.add(number);}}System.out.println("Filtered numbers (without Stream):");for (Integer number : filteredNumbers) {System.out.println(number);}}
}

输出：

Filtered numbers (without Stream):
40
50

使用 Stream 过滤集合示例：

import java.util.ArrayList;
import java.util.List;public class FilterWithStreamExample {public static void main(String[] args) {List<Integer> numbers = new ArrayList<>();numbers.add(10);numbers.add(20);numbers.add(30);numbers.add(40);numbers.add(50);List<Integer> filteredNumbers = numbers.stream().filter(number -> number > 30).toList();System.out.println("Filtered numbers (with Stream):");filteredNumbers.forEach(System.out::println);}
}

输出：

Filtered numbers (with Stream):
40
50

前后我们对比一下，可以看到，使用 Stream 进行集合过滤可以更加简洁和直观，减少了手动迭代和添加元素的步骤。它提供了一种声明式的编程风格，使代码更易读、可维护和可扩展。

5. 使用Stream过滤和遍历集合

在下面的示例中，我们使用 filter() 方法进行过滤，使用 forEach() 方法对数据流进行迭代：

import java.util.ArrayList;
import java.util.List;public class FilterAndIterateWithStreamExample {public static void main(String[] args) {List<String> names = new ArrayList<>();names.add("Alice");names.add("Bob");names.add("Charlie");names.add("David");names.add("Eve");System.out.println("Filtered names starting with 'A':");names.stream().filter(name -> name.startsWith("A")).forEach(System.out::println);}
}

输出

Filtered names starting with 'A':
Alice

在上述示例中，我们有一个字符串列表 names，其中包含了一些名字。
我们使用 Stream 进行过滤和迭代操作以查找以字母 “A” 开头的名字。

6.使用Collectors方法求和

我们还可以使用Collectors计算数值之和。

在下面的示例中，我们使用Collectors类及其指定方法计算所有产品价格的总和。

import java.util.ArrayList;
import java.util.List;
import java.util.stream.Collectors;public class SumByUsingCollectorsMethods {public static void main(String[] args) {List < Product > productsList = new ArrayList < Product > ();productsList.add(new Product(1, "HP Laptop", 25000f));productsList.add(new Product(2, "Dell Laptop", 30000f));productsList.add(new Product(3, "Lenevo Laptop", 28000f));productsList.add(new Product(4, "Sony Laptop", 28000f));productsList.add(new Product(5, "Apple Laptop", 90000f));double totalPrice3 = productsList.stream().collect(Collectors.summingDouble(product -> product.getPrice()));System.out.println(totalPrice3);}
}

输出

201000.0
7. 使用Stream查找年龄最大和最小的学生

假设有一个 Student 类具有 name 和 age 属性。我们可以使用 Stream 来查找学生集合中年龄的最大和最小值，并打印出相应的学生信息。以下是一个示例：

import java.util.ArrayList;
import java.util.Comparator;
import java.util.List;
import java.util.Optional;public class StudentStreamExample {public static void main(String[] args) {List<Student> students = new ArrayList<>();students.add(new Student("Alice", 20));students.add(new Student("Bob", 22));students.add(new Student("Charlie", 19));students.add(new Student("David", 21));// 查找年龄最大的学生Optional<Student> maxAgeStudent = students.stream().max(Comparator.comparingInt(Student::getAge));// 查找年龄最小的学生Optional<Student> minAgeStudent = students.stream().min(Comparator.comparingInt(Student::getAge));// 打印最大和最小年龄的学生信息System.out.println("Student with maximum age:");maxAgeStudent.ifPresent(System.out::println);System.out.println("Student with minimum age:");minAgeStudent.ifPresent(System.out::println);}
}class Student {private String name;private int age;public Student(String name, int age) {this.name = name;this.age = age;}public String getName() {return name;}public int getAge() {return age;}@Overridepublic String toString() {return "Student{" +"name='" + name + '\'' +", age=" + age +'}';}
}

输出：

Student with maximum age:
Student{name='Bob', age=22}
Student with minimum age:
Student{name='Charlie', age=19}
8. 使用Stream转换List为Map
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;public class StudentStreamToMapExample {public static void main(String[] args) {List<Student> students = new ArrayList<>();students.add(new Student("Alice", 20));students.add(new Student("Bob", 22));students.add(new Student("Charlie", 19));students.add(new Student("David", 21));// 将学生列表转换为 Map，以姓名为键，学生对象为值Map<String, Student> studentMap = students.stream().collect(Collectors.toMap(Student::getName, student -> student));// 打印学生 Mapfor (Map.Entry<String, Student> entry : studentMap.entrySet()) {System.out.println(entry.getKey() + ": " + entry.getValue());}}
}class Student {private String name;private int age;public Student(String name, int age) {this.name = name;this.age = age;}public String getName() {return name;}public int getAge() {return age;}@Overridepublic String toString() {return "Student{" +"name='" + name + '\'' +", age=" + age +'}';}
}

输出

David: Student{name='David', age=21}
Bob: Student{name='Bob', age=22}
Charlie: Student{name='Charlie', age=19}
Alice: Student{name='Alice', age=20}

在上面示例中，我们使用Collectors.toMap() 方法将学生列表转换为 Map。我们指定了键提取器 Student::getName，将学生的姓名作为键。对于值提取器，我们使用了一个匿名函数 student -> student，它返回学生对象本身作为值。

9. 使用Stream把List对象转换为另一个List对象

假设我们有一个 Person 类，其中包含姓名和年龄属性。我们可以使用 Stream 来将一个 List 对象转换为另一个 List 对象，其中只包含人员的姓名。以下是一个示例：

  import java.util.ArrayList;
import java.util.List;
import java.util.stream.Collectors;public class ListTransformationExample {public static void main(String[] args) {List<Person> persons = new ArrayList<>();persons.add(new Person("Alice", 20));persons.add(new Person("Bob", 22));persons.add(new Person("Charlie", 19));// 将 Person 列表转换为只包含姓名的 String 列表List<String> names = persons.stream().map(Person::getName).collect(Collectors.toList());// 打印转换后的姓名列表System.out.println(names);}
}class Person {private String name;private int age;public Person(String name, int age) {this.name = name;this.age = age;}public String getName() {return name;}public int getAge() {return age;}
}

输出：

  [Alice, Bob, Charlie]

在上述示例中，我们有一个 Person 类，其中包含姓名和年龄属性。我们创建了一个 persons 列表，并添加了几个 Person 对象。

使用Stream，我们通过调用 map() 方法并传入一个方法引用 Person::getName，最后，我们使用 collect() 方法和 Collectors.toList() 将转换后的姓名收集到一个新的列表中。

API

https://docs.oracle.com/javase/8/docs/api/java/util/stream/package-summary.html

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

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

AIGC创作系统ChatGPT网站系统源码，支持最新GPT-4-Turbo模型

AIGC创作系统ChatGPT网站系统源码，支持最新GPT-4-Turbo模型

一、AI创作系统 SparkAi创作系统是基于OpenAI很火的ChatGPT进行开发的Ai智能问答系统和Midjourney绘画系统&#xff0c;支持OpenAI-GPT全模型国内AI全模型。本期针对源码系统整体测试下来非常完美&#xff0c;可以说SparkAi是目前国内一款的ChatGPT对接OpenAI软件系统。那么如…
阅读更多...
万宾科技智能井盖的效果怎么样？

万宾科技智能井盖的效果怎么样？

日常出行过程中&#xff0c;人们最不想看到交通拥堵或者道路维修等现象&#xff0c;因为这代表出行受到影响甚至会导致不能按时赴约等。所以城市路面的安全和稳定&#xff0c;是市民朋友非常关心的话题。骑行在路上的时候&#xff0c;如果经过井盖时发出异常声响&#xff0c;骑…
阅读更多...
Apache配置文件详解

Apache配置文件详解

引言： Apache是一种功能强大的Web服务器软件，通过配置文件可以对其行为进行高度定制。对于初学者来说，理解和正确配置Apache的配置文件是非常重要的。本文将详细解释Apache配置文件的各个方面，并给出一些入门指南，帮助读者快速上手。 1、主配置文件（httpd.conf）： 主…
阅读更多...
jQuery【菜单功能、淡入淡出轮播图(上)、淡入淡出轮播图(下)、折叠面板】(五)-全面详解（学习总结---从入门到深化）

jQuery【菜单功能、淡入淡出轮播图(上)、淡入淡出轮播图(下)、折叠面板】(五)-全面详解（学习总结---从入门到深化）

目录 菜单功能 淡入淡出轮播图(上) 淡入淡出轮播图(下) 折叠面板 菜单功能 <!DOCTYPE html> <html lang"en"> <head><meta charset"UTF-8"><meta http-equiv"X-UA-Compatible" content"IEedge"><…
阅读更多...
这是大学生就业网站最基础的布局。

这是大学生就业网站最基础的布局。

<!DOCTYPE html> <html> <head> <title>大学生就业网站</title> <style> /* Reset default margin and padding */ *, *::before, *::after { margin: 0; padding: 0; box-s…
阅读更多...
SpingBoot原理

SpingBoot原理

目录 配置优先级Bean管理 (掌握)Bean的获取 ApplicationContext.getBeanBean的作用域 Scope("prototype") Lazy第三方Bean Bean Configuration SpringBoot底层原理 起步依赖与自动配置(无需手撸但面试高频知识点)自动配置引入第三方依赖常见方案方案1&#xff1a;Com…
阅读更多...
Java引用和内部类

Java引用和内部类

引用 引用变量 引用相当于一个 “别名”, 也可以理解成一个指针. 创建一个引用只是相当于创建了一个很小的变量, 这个变量保存了一个整数, 这个整数表示内存中的一个地址. new 出来的数组肯定是在堆上开辟的空间,那么在栈中存放的就是引用,引用存放的的就是一个对象的地址,代表…
阅读更多...
格式化名称节点，启动Hadoop

格式化名称节点，启动Hadoop

1.循环删除hadoop目录下的tmp文件&#xff0c;记住在hadoop目录下进行 rm tmp -rf 使用上述命令&#xff0c;hadoop目录下为&#xff1a; 2.格式化名称节点 # 格式化名称节点 ./bin/hdfs namenode -format 3.启动所有节点 ./sbin/start-all.sh 效果图&#xff1a; 4.查看节…
阅读更多...
HCIP-五、OSPF-1 邻居状态机和 DR 选举

HCIP-五、OSPF-1 邻居状态机和 DR 选举

五、OSPF-1 邻居状态机和 DR 选举 实验拓扑实验需求及解法1.如图所示&#xff0c;配置设备 IP 地址。2.配置 OSPF3. 按照以下步骤观察 R1 与 R2 的邻居关系建立过程 实验拓扑 实验需求及解法 通过本次实验&#xff0c;验证 OSPF 邻居状态机变化过程&#xff0c;以及 DR 选举过…
阅读更多...
今日定音，博通以610亿美元成功收购VMware | 百能云芯

今日定音，博通以610亿美元成功收购VMware | 百能云芯

博通&#xff08;Broadcom&#xff09;日前宣布&#xff0c;已获得中国监管机构的批准&#xff0c;将于今日完成对云计算公司VMware的收购交易。这意味着&#xff0c;610亿美元的收购案正式收关。 据悉&#xff0c;中国市场监管总局在11月21日晚发布了有关附加限制性条件批准博…
阅读更多...
Python-大数据分析之常用库

Python-大数据分析之常用库

Python-大数据分析之常用库 1. 数据采集与第三方数据接入 1-1. Beautiful Soup ​ Beautiful Soup 是一个用于解析HTML和XML文档的库&#xff0c;非常适用于网页爬虫和数据抓取。可以提取所需信息&#xff0c;无需手动分析网页源代码&#xff0c;简化了从网页中提取数据的过…
阅读更多...
排序算法--冒泡排序

排序算法--冒泡排序

实现逻辑 ① 比较相邻的元素。如果第一个比第二个大&#xff0c;就交换他们两个。 ②对每一对相邻元素作同样的工作&#xff0c;从开始第一对到结尾的最后一对。在这一点&#xff0c;最后的元素应该会是最大的数。 ③针对所有的元素重复以上的步骤&#xff0c;除了最后一个。 ④…
阅读更多...
centos7 网卡聚合bond0模式配置

centos7 网卡聚合bond0模式配置

提示&#xff1a;文章写完后&#xff0c;目录可以自动生成&#xff0c;如何生成可参考右边的帮助文档 文章目录 一、什么是网卡bond二、网卡bond的模式三、配置bond0 一、什么是网卡bond 所谓bond&#xff0c;就是把多个物理网卡绑定成一个逻辑上的网卡&#xff0c;使用同一个…
阅读更多...
威胁攻击层出不穷，信息化负责人该如何增强对抗与防御能力？

威胁攻击层出不穷，信息化负责人该如何增强对抗与防御能力？

11月15日&#xff0c;以“加快推进智慧校园建设 赋能为党育才为党献策”为主题的2023年华东地区党校&#xff08;行政学院&#xff09;信息化和图书馆工作高质量发展专题研讨班顺利举办。 作为国内云原生安全领导厂商&#xff0c;安全狗受邀出席活动。 厦门服云信息科技有限公…
阅读更多...
腾讯云服务器99元一年是真的吗？假的！

腾讯云服务器99元一年是真的吗？假的！

腾讯云服务器99元一年是真的吗&#xff1f;假的&#xff0c;不用99元&#xff0c;只要88元即可购买一台2核2G3M带宽的轻量应用服务器&#xff0c;99元太多了&#xff0c;88元就够了&#xff0c;腾讯云百科活动 txybk.com/go/txy 活动打开如下图&#xff1a; 腾讯云轻量服务器 腾…
阅读更多...
扒一扒Bean注入到Spring的那些姿势

扒一扒Bean注入到Spring的那些姿势

这篇文章我准备来扒一扒Bean注入到Spring的那些姿势。 其实关于Bean注入Spring容器的方式网上也有很多相关文章&#xff0c;但是很多文章可能会存在以下常见的问题 注入方式总结的不全 没有分析可以使用这些注入方式背后的原因 没有这些注入方式在源码中的应用示例 ... 所…
阅读更多...
Navicat 下载

Navicat 下载

1 中文网站 Navicat 中国 | 支持 MySQL、Redis、MariaDB、MongoDB、SQL Server、SQLite、Oracle 和 PostgreSQL 的数据库管理 下载链接&#xff1a; https://download.navicat.com.cn/download/navicat163_premium_cs_x86.exe 2 下载其他版本(找到发行说明--版本号--替换版本…
阅读更多...
spring boot项目未将resource目录标志为资源目录导致配置文件无效因而运行报错问题

spring boot项目未将resource目录标志为资源目录导致配置文件无效因而运行报错问题

能编译&#xff0c;但不能运行。感觉配置文件没有生效。 将程序代码发给同事&#xff0c;我自己能跑&#xff0c;他不能跑&#xff0c;提示无法构造redis对象。redis的链接写在配置文件里&#xff0c;其实是可以连接的。然后从GIT库下载代码&#xff0c;也同样不能跑。同事的操…
阅读更多...
某高品质房产企业：借助NineData平台，统一数据库访问权限，保障业务安全

某高品质房产企业：借助NineData平台，统一数据库访问权限，保障业务安全

该企业是中国领先的优质房产品开发及生活综合服务供应商。在 2022 年取得了亮眼的业绩表现&#xff0c;销售额市场占有率跻身全国前五。业务涵盖房产开发、房产代建、城市更新、科技装修等多个领域。 2023 年&#xff0c;该企业和玖章算术&#xff08;浙江&#xff09;科技有限…
阅读更多...
连线长光卫星：吉林一号的在线产品与生态体系！

连线长光卫星：吉林一号的在线产品与生态体系！

我们在《连线长光卫星&#xff1a;探索卫星应用的更多可能&#xff01;》一文中&#xff0c;通过直播连线嘉宾的分享&#xff0c;让大家了解到了长光卫星的生产基地、三次技术飞跃、亚米级影像产品、150公里大幅宽卫星、卫星在灾害监测及经济分析等多个场景中的应用。 这里我们…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023