Java进阶-Java Stream API详解与使用

Java进阶-Java Stream API详解与使用

本文全面介绍了 Java Stream API 的概念、功能以及如何在 Java 中有效地使用它进行集合和的处理。通过详细解释和示例,文章展示了 Java Stream API 在简化代码、提高效率以及支持函数式编程方面的优势。文中还比较了 Java Stream API 与其他集合处理库的异同,强调了其在现代 Java 开发中的重要性和实用性。

www.zeeklog.com - Java进阶-Java Stream API详解与使用

一、Java Stream API介绍

1. Java Stream API简述

Java Stream API 是Java 8中引入的一项功能,它允许程序员以声明式方式处理数据集合。通过Stream API,可以对数据执行复杂的查询操作,而不必编写冗余的代码。Stream 不是数据结构,它更像是一个高级版本的Iterator。单次使用,数据只能遍历一次,遍历过程中你可以对数据进行过滤、排序、聚合等操作。


2. Java Stream API支持的功能
功能描述
filter过滤流中的元素,根据条件只留下满足条件的元素
map将流中的每个元素映射成其他形式,结果是一个包含映射后结果的新流
sorted确保流中的元素在消费时的顺序按照自然顺序或自定义Comparator排序
collect将流转换为其他形式,如List、Set或Map,或者是自定义的收集器
forEach遍历流中的每个元素并执行给定的操作
reduce通过重复处理其元素来将流减少到单个汇总结果
anyMatch检查流中的元素是否有一个满足给定的条件
allMatch检查流中的元素是否全部满足给定条件
noneMatch检查流中的元素是否没有满足给定条件的
findFirst返回流中的第一个元素,如果流为空,则返回空的Optional
limit截断流,使其最大长度不超过给定数量
skip跳过流中的前n个元素,返回包含余下元素的新流

3. 使用Java Stream API的优势
功能Java Stream API传统集合操作
数据处理模式声明式,支持函数式编程命令式,代码较为复杂
内存效率更高,因为它是在流上直接操作低,需要复制到新的数据结构
并发处理内建支持并发处理手动处理并发
可读性高,流操作可链式调用低,循环和条件判断多
使用场景数据集合操作,大数据处理小数据量操作

二、常用的Java Stream API功能

下面是针对每个Java Stream API函数的示例代码:

1. filter

过滤流中的元素,根据条件只留下满足条件的元素。

List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5, 6); List<Integer> evenNumbers = numbers.stream() .filter(n -> n % 2 == 0) .collect(Collectors.toList()); System.out.println(evenNumbers); // 输出 [2, 4, 6] 
2. map

将流中的每个元素映射成其他形式,结果是一个包含映射后结果的新流。

List<String> words = Arrays.asList("hello", "world", "java", "stream"); List<Integer> wordLengths = words.stream() .map(String::length) .collect(Collectors.toList()); System.out.println(wordLengths); // 输出 [5, 5, 4, 6] 
3. sorted

确保流中的元素在消费时的顺序按照自然顺序或自定义Comparator排序。

List<Integer> numbers = Arrays.asList(4, 3, 6, 1, 5, 2); List<Integer> sortedNumbers = numbers.stream() .sorted() .collect(Collectors.toList()); System.out.println(sortedNumbers); // 输出 [1, 2, 3, 4, 5, 6] 
4. collect

将流转换为其他形式,如List、Set或Map,或者是自定义的收集器。

List<String> names = Arrays.asList("Alice", "Bob", "Charlie", "David"); Set<String> nameSet = names.stream() .collect(Collectors.toSet()); System.out.println(nameSet); // 输出 [Alice, Bob, Charlie, David] 
5. forEach

遍历流中的每个元素并执行给定的操作。

List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5); names.stream() .forEach(System.out::println); // 依次输出 1、2、3、4、5 
6. reduce

通过重复处理其元素来将流减少到单个汇总结果。

List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5); int sum = numbers.stream() .reduce(0, Integer::sum); System.out.println("Sum: " + sum); // 输出 Sum: 15 
7. anyMatch

检查流中的元素是否有一个满足给定的条件。

List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5); boolean hasEven = numbers.stream() .anyMatch(n -> n % 2 == 0); System.out.println("Has even numbers: " + hasEven); // 输出 Has even numbers: true 
8. allMatch

检查流中的元素是否全部满足给定条件。

List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5); boolean allEven = numbers.stream() .allMatch(n -> n % 2 == 0); System.out.println("All are even: " + allEven); // 输出 All are even: false 
9. noneMatch

检查流中的元素是否没有满足给定条件的。

List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5); boolean noneMultipleOfTen = numbers.stream() .noneMatch(n -> n % 10 == 0); System.out.println("None are multiples of ten: " + noneMultipleOfTen); // 输出 None are multiples of ten: true 
10. findFirst

返回流中的第一个元素,如果流为空,则返回空的Optional。

List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5); Optional<Integer> first = numbers.stream() .findFirst(); System.out.println("First number: " + first.orElse(-1)); // 输出 First number: 1 
11. limit

截断流,使其最大长度不超过给定数量。

List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5); List<Integer> limited = numbers.stream() .limit(3) .collect(Collectors.toList()); System.out.println(limited); // 输出 [1, 2, 3] 
12. skip

跳过流中的前n个元素,返回包含余下元素的新流。

List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5); List<Integer> skipped = numbers.stream() .skip(3) .collect(Collectors.toList()); System.out.println(skipped); // 输出 [4, 5] 

这些示例展示了Java Stream API的多样化和强大功能,使得处理集合数据更加灵活和


三、Java Stream API和类似包比较的优势

Java Stream API 作为Java 8及以后版本的核心特性,对集合和数据流的处理提供了强大的支持。除了Java自带的Stream API,还有一些其他的库或框架也提供了类似的功能,用于处理集合或者数据流。

1. 常见的Java集合处理库
  1. Java Stream API - 内置于Java 8及以上版本,提供了一种高级的处理集合的方法,支持函数式编程。
  2. Apache Commons Collections - 提供了丰富的集合操作工具,但主要是针对Java集合框架之前的版本设计。
  3. Google Guava - 提供了许多核心Java库没有的集合类型和工具,包括对集合的操作和新的集合类型。
  4. Vavr(之前称为Javaslang)- 提供了不可变的集合类型和其他函数式编程的工具,以提高代码的健壮性。
  5. Eclipse Collections(之前称为GS Collections)- 提供了一套丰富的集合库,以及各种性能优化和内存优化的集合类型。

2. 集合处理库之间的比较
特性 / 库Java Stream APIApache Commons CollectionsGoogle GuavaVavrEclipse Collections
主要优势内置支持,无需额外依赖丰富的集合操作工具强大的集合工具和新集合类型不可变集合和函数式编程支持高性能、丰富的集合类型
集合不可变性不提供不提供提供部分不可变集合所有集合默认不可变提供不可变和可变集合
函数式编程支持有限支持有限支持完全支持有限支持
并发支持并发流处理不专门针对并发优化提供并发集合不提供提供优化的并发集合
类型安全和检查类型安全类型安全类型安全类型安全类型安全
学习曲线中等中等中等
与Java版本兼容性Java 8+Java 1.2+Java 1.6+Java 8+Java 5+
扩展集合类型提供额外集合操作提供新的集合类型提供函数式集合类型提供丰富的集合类型

每个库都有其独特的优点和用途。Java Stream API是Java开发中的标准选项,无需额外依赖且与现代Java应用高度兼容。对于需要在老版本Java上工作的开发者,Apache Commons Collections提供了后向兼容。Google Guava和Eclipse Collections提供了高性能的集合操作,而Vavr则为喜欢的开发者提供了很好的支持。选择哪个库取决于具体的项目需求、团队的熟悉度以及对库特性的需求。


四、Java Stream API使用总结

Java Stream API 是一个功能强大的工具,适用于处理集合和数据流。它提供了一种简洁而高效的方法来操作数据,尤其是在处理大量数据时。这个API优化了数据处理逻辑,使开发者能够以更少的代码执行复杂的数据转换和聚合操作。利用Java Stream API,可以轻松实现数据过滤、排序、转换及汇总,极大地提升了代码的可读性和可维护性。同时,Stream API 的函数式编程特性有助于减少错误和侧效应,使得并发程序的编写更为安全。通过使用Java Stream API,开发者可以写出更简洁、更高效、更易于维护的代码,同时享受到函数式编程带来的好处。

Read more

Flutter for OpenHarmony:web3dart 连接以太坊区块链,构建去中心化应用(DApp 开发与智能合约调用深度实战)深度解析与鸿蒙适配指南

Flutter for OpenHarmony:web3dart 连接以太坊区块链,构建去中心化应用(DApp 开发与智能合约调用深度实战)深度解析与鸿蒙适配指南

欢迎加入开源鸿蒙跨平台社区:https://openharmonycrossplatform.ZEEKLOG.net 前言 随着 Web3.0 概念的普及,区块链技术已从早期的极客玩具逐渐走向主流应用。无论是 DeFi(去中心化金融)、NFT(非同质化代币)还是 DAO(去中心化组织),都离不开与区块链网络的交互。 以太坊 (Ethereum) 作为目前最成熟的智能合约平台,其客户端通信协议 JSON-RPC 是行业标准。要在移动端(Flutter/OpenHarmony)与以太坊网络通信,我们不可能手动构造那些复杂的十六进制数据包。 web3dart 是 Dart 生态中唯一的、功能完备的 Web3 客户端库。它可以让你: 1. 管理账户:生成私钥、助记词,导入 keystore。 2. 发送交易:转账 ETH,部署合约。

跨平台字体渲染方案:Web字体性能优化的技术实践与效益分析

跨平台字体渲染方案:Web字体性能优化的技术实践与效益分析 【免费下载链接】PingFangSCPingFangSC字体包文件、苹果平方字体文件,包含ttf和woff2格式 项目地址: https://gitcode.com/gh_mirrors/pi/PingFangSC 在Web开发中,字体渲染的一致性与性能优化一直是前端工程师面临的重要挑战。不同操作系统对字体的支持差异,常常导致设计稿在Mac上完美呈现,而在Windows或Linux系统中出现字体缺失、样式偏差等问题。本文将深入探讨跨平台字体渲染的核心痛点,解析创新的技术解决方案,并通过实际案例展示其在企业官网和移动应用场景中的应用价值,帮助开发者实现高性能、高一致性的Web字体体验。 核心痛点解析:跨平台字体渲染的三大技术瓶颈 跨平台字体渲染面临着诸多技术难题,这些问题直接影响着用户体验和开发效率。首先,字体兼容性问题是最突出的痛点之一。苹果的PingFangSC字体在非Mac系统中往往无法正常显示,导致设计稿与实际效果产生偏差。其次,字体文件体积过大会严重影响页面加载速度,特别是在移动网络环境下,大体积的字体文件可

用一篇文章带你搞懂 WebRTC + Java 信令服务器 + Vue 实时视频聊天

很多同学用过微信、QQ 视频聊天,但一问到底层怎么实现,十有八九只会说一句:“应该是 WebSocket / WebRTC 吧?”——但是: * WebRTC 到底负责什么? * WebSocket / Netty 在里面干嘛? * STUN / ICE / SDP 是啥?为什么一上来就一堆名词? 这篇文章会用一套完整的小项目,从 0 到 1 带你实现一个: 基于 WebRTC + Java(SpringBoot + Netty)+ Vue 的点对点视频聊天 Demo 重点是: 不是只给你一堆代码,而是把每个概念都讲清楚,让小白也能看懂、改得动、举一反三。 一、整体架构总览:谁负责干什么? 先看一张逻辑图(可以脑补成 PPT): ┌────────────────────────────────────────────┐ │ 后端(Java) │ │ │ │ SpringBoot 负责:

Flutter for OpenHarmony:web_socket 纯 Dart 标准 WebSocket 客户端(跨平台兼容性之王) 深度解析与鸿蒙

Flutter for OpenHarmony:web_socket 纯 Dart 标准 WebSocket 客户端(跨平台兼容性之王) 深度解析与鸿蒙

欢迎加入开源鸿蒙跨平台社区:https://openharmonycrossplatform.ZEEKLOG.net 前言 虽然 dart:io 提供了 WebSocket 类,dart:html 也提供了 WebSocket 类,但这种“分裂”的 API 设计让编写跨平台(同时支持 Mobile/Web/Desktop)的代码变得异常痛苦。你需要使用条件导入 (if (dart.library.io) ...) 来分别处理。 web_socket 库就是为了解决这个问题而诞生的。它提供了一个统一的、平台无关的WebSocket 接口。 无论你的代码运行在 Android、iOS、Web 还是 OpenHarmony 上,它都会自动选择最底层的实现(在鸿蒙上通常是 dart:io)