講透JAVA Stream的collect用法與原理,遠比你想象的更強大

来源:https://www.cnblogs.com/softwarearch/archive/2022/07/18/16490440.html
-Advertisement-
Play Games

大家好,又見面了。 在我前面的文章《吃透JAVA的Stream流操作,多年實踐總結》中呢,對Stream的整體情況進行了細緻全面的講解,也大概介紹了下結果收集器Collectors的常見用法 —— 但遠不是全部。 本篇文章就來專門剖析collect操作,一起解鎖更多高級玩法,讓Stream操作真正的 ...


大家好,又見面了。

在我前面的文章《吃透JAVA的Stream流操作,多年實踐總結》中呢,對Stream的整體情況進行了細緻全面的講解,也大概介紹了下結果收集器Collectors的常見用法 —— 但遠不是全部。

本篇文章就來專門剖析collect操作,一起解鎖更多高級玩法,讓Stream操作真正的成為我們編碼中的神兵利器

初識Collector

先看一個簡單的場景:

現有集團內所有人員列表,需要從中篩選出上海子公司的全部人員

假定人員信息數據如下:

姓名 子公司 部門 年齡 工資
大壯 上海公司 研發一部 28 3000
二牛 上海公司 研發一部 24 2000
鐵柱 上海公司 研發二部 34 5000
翠花 南京公司 測試一部 27 3000
玲玲 南京公司 測試二部 31 4000

如果你曾經用過Stream流,或者你看過我前面關於Stream用法介紹的文章,那麼藉助Stream可以很輕鬆的實現上述訴求:

public void filterEmployeesByCompany() {
    List<Employee> employees = getAllEmployees().stream()
            .filter(employee -> "上海公司".equals(employee.getSubCompany()))
            .collect(Collectors.toList());
    System.out.println(employees);
}

上述代碼中,先創建流,然後通過一系列中間流操作(filter方法)進行業務層面的處理,然後經由終止操作(collect方法)將處理後的結果輸出為List對象。

但我們實際面對的需求場景中,往往會有一些更複雜的訴求,比如說:

現有集團內所有人員列表,需要從中篩選出上海子公司的全部人員,並按照部門進行分組

其實也就是加了個新的分組訴求,那就是先按照前面的代碼實現邏輯基礎上,再對結果進行分組處理就好咯:

public void filterEmployeesThenGroup() {
    // 先 篩選
    List<Employee> employees = getAllEmployees().stream()
            .filter(employee -> "上海公司".equals(employee.getSubCompany()))
            .collect(Collectors.toList());
    // 再 分組
    Map<String, List<Employee>> resultMap = new HashMap<>();
    for (Employee employee : employees) {
        List<Employee> groupList = resultMap
                .computeIfAbsent(employee.getDepartment(), k -> new ArrayList<>());
        groupList.add(employee);
    }
    System.out.println(resultMap);
}

似乎也沒啥毛病,相信很多同學實際編碼中也是這麼處理的。但其實我們也可以使用Stream操作直接完成:

public void filterEmployeesThenGroupByStream() {
    Map<String, List<Employee>> resultMap = getAllEmployees().stream()
            .filter(employee -> "上海公司".equals(employee.getSubCompany()))
            .collect(Collectors.groupingBy(Employee::getDepartment));
    System.out.println(resultMap);
}

兩種寫法都可以得到相同的結果:

{
    研發二部=[Employee(subCompany=上海公司, department=研發二部, name=鐵柱, age=34, salary=5000)], 
    研發一部=[Employee(subCompany=上海公司, department=研發一部, name=大壯, age=28, salary=3000), 
             Employee(subCompany=上海公司, department=研發一部, name=二牛, age=24, salary=2000)]
}

上述2種寫法相比而言,第二種是不是代碼上要簡潔很多?而且是不是有種自註釋的味道了?

通過collect方法的合理恰當利用,可以讓Stream適應更多實際的使用場景,大大的提升我們的開發編碼效率。下麵就一起來全面認識下collect、解鎖更多高級操作吧。

collect\Collector\Collectors區別與關聯

剛接觸Stream收集器的時候,很多同學都會被collect,Collector,Collectors這幾個概念搞的暈頭轉向,甚至還有很多人即使已經使用Stream好多年,也只是知道collect裡面需要傳入類似Collectors.toList()這種簡單的用法,對其背後的細節也不甚瞭解。

這裡以一個collect收集器最簡單的使用場景來剖析說明下其中的關係:


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

-Advertisement-
Play Games
更多相關文章
  • 一、字典、元組的多重嵌套 例 1:記錄全班學生的成績。 分析:定義一個 SimpleGradebook類, 學生名是字典self._grades的鍵,成績是字典self._grades的值。 class SimpleGradebook(): def __init__(self): self._gra ...
  • Django python網路編程回顧 之前我們介紹過web應用程式和http協議,簡單瞭解過web開發的概念。Web應用程式的本質 接收並解析HTTP請求,獲取具體的請求信息 處理本次HTTP請求,即完成本次請求的業務邏輯處理 構造並返回處理結果——HTTP響應 import socket ser ...
  • 三、SpringAMQP SpringAMQP是基於RabbitMQ封裝的一套模板,並且還利用SpringBoot對其實現了自動裝配,使用起來非常方便 SpringAMQP的官方地址 https://spring.io/projects/spring-amqp AMQP Spring AMQP Sp ...
  • 在本篇文章當中主要跟大家介紹併發的基礎知識,從最基本的問題出發層層深入,幫助大家瞭解併發知識,並且打好併發的基礎!!! ...
  • 1、應用場景 電商商城,商家上架了一個秒殺活動,早上10點開始,商品A參與秒殺,一共有20個庫存,預計10W的人去搶。 2、面臨問題 高併發、庫存不可超賣 3、問題解決 1)高併發,我們不能把所有的請求都去資料庫查商品詳情,查商品庫存,這樣資料庫會頂不住,很容易的我們就想到了用Redis解決; 2) ...
  • 歡迎關註公眾號:bin的技術小屋,本文圖片載入不出來的話可查看公眾號原文 本系列Netty源碼解析文章基於 4.1.56.Final版本 寫在前面..... 本文是筆者肉眼盯 Bug 系列的第三彈,前兩彈分別是: 抓到Netty一個Bug,順帶來透徹地聊一下Netty是如何高效接收網路連接的 ,在這 ...
  • 本篇文章主要介紹了1、Java 中的異常2、如何處理函數拋出的異常3、處理異常的原則4、異常處理時,性能開銷大的地方 ...
  • 二、Seata學習 2.1、Seata介紹 ###2.1.1、Seata背景 Seata是 2019 年 1 月份螞蟻金服和阿裡巴巴共同開源的==分散式事務解決方案==。致力於提供高性能和簡單易用的分散式事務服務,為用戶打造一站式的分散式解決方案 官網地址:http://seata.io/,其中的文 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 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 ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...