Java Stream中的API你都用過了嗎？

来源:https://www.cnblogs.com/waldron/archive/2023/11/22/17848756.html
-Advertisement-
Play Games

公眾號「架構成長指南」，專註於生產實踐、雲原生、分散式系統、大數據技術分享。 在本教程中，您將通過大量示例來學習 Java 8 Stream API。 Java 在 Java 8 中提供了一個新的附加包，稱為 java.util.stream。該包由類、介面和枚舉組成，允許對元素進行函數式操作。 您 ...


公眾號「架構成長指南」，專註於生產實踐、雲原生、分散式系統、大數據技術分享。

在本教程中，您將通過大量示例來學習 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;
    }

    @Override
    public 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));

        // 列印學生 Map
        for (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;
    }

    @Override
    public 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


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 【題解】HD2016.X1,HD2016.X3,HD2016.X4,HD2016.X5
    [HD2016.X1] 價錢統計 題目描述 夏天到了，超市裡擺滿了各種各樣的應季水果。現在知道：西瓜的價錢是每斤 1.2 元；桃子的價錢是每斤 3.5 元；葡萄的價錢是每斤 4.5 元；蘋果的價錢是每斤 5 元。 現在分別給出上述四種所購買的斤數（均不超過 20），請你編寫程式幫助售貨員阿姨計算並依 ...
  • C語言【指針1】
    Zlib是一個開源的數據壓縮庫，提供了一種通用的數據壓縮和解壓縮演算法。它最初由`Jean-Loup Gailly`和`Mark Adler`開發，旨在成為一個高效、輕量級的壓縮庫，其被廣泛應用於許多領域，包括網路通信、文件壓縮、資料庫系統等。其壓縮演算法是基於`DEFLATE`演算法，這是一種無損數據壓... ...
  • Request 爬蟲的 SSL 連接問題深度解析
    SSL 連接簡介 SSL（Secure Sockets Layer）是一種用於確保網路通信安全性的加密協議，廣泛應用於互聯網上的數據傳輸。在數據爬取過程中，爬蟲需要與使用 HTTPS 協議的網站進行通信，這就牽涉到了 SSL 連接。本文將深入研究 Request 爬蟲中的 SSL 連接問題，並提供解 ...
  • Calendar日曆類型常見方法（必看！！）
    Hi i,m JinXiang ⭐ 前言 ⭐ 本篇文章主要介紹Calendar日曆類型的幾種常見方法以及部分理論知識 🍉歡迎點贊 👍 收藏 ⭐留言評論 📝私信必回喲😁 🍉博主收將持續更新學習記錄獲，友友們有任何問題可以在評論區留言 ⭐什麼是Calendar日曆類型？ Calendar類是一 ...
  • python中常見函數
    filter, reduce, 和 map 是Python中用於對集合數據進行處理和轉換的內置函數。它們分別用於篩選、歸約和映射集合中的元素。 filter 函數： filter(function, iterable) 用於篩選集合中的元素。它接受一個函數 function 和一個可迭代的對象 it ...
  • python多線程中一種錯誤的寫法
    在數據科學計算、機器學習、以及深度學習領域，Python 是最受歡迎的語言。Python 在數據科學領域，有非常豐富的包可以選擇，numpy、scipy、pandas、scikit-learn、matplotlib。 但這些庫都僅僅受限於單機運算，當數據量很大時，比如50GB甚至500GB的數據集， ...
  • python字典中刪除鍵值的方法
    創建資料庫 (xxl-job) 導入相關表 Sql SET NAMES utf8mb4; SET FOREIGN_KEY_CHECKS = 0; -- -- Table structure for xxl_job_group -- DROP TABLE IF EXISTS `xxl_job_grou ...
  • Grok AI 是什麼？
    原文鏈接：https://openaigptguide.com/grok-ai/ Grok AI是由馬斯克推出的一款高級別的人工智慧大語言模型，旨在幫助軟體開發者以不同的口頭語言交流和表達。它是基於多種深度學習大規模固定模型架構，如ELMo、BERT和GPT，以及更多新的模式，使軟體開發者能夠快速設 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類