当前位置: 首页 > news >正文

Java Stream API 中常用方法复习及项目实战示例

在最近的练手项目中,对于stream流的操作愈加频繁,我也越来越感觉stream流在处理数据是的干净利落,因此写博客用来记录最近常用的方法以便于未来的复习。

map() 方法


map()是一个中间操作(intermediate operation),用于将流中的每个元素按照给定的函数进行转换。
常见用法示例:

// 在RoleController中,将Role对象转换为RoleDTO对象
List<RoleDTO> dtos = list.stream().map(Role::toDTO).collect(Collectors.toList());// 在MenuController中,将Menu对象转换为MenuOptionVO对象
List<MenuOptionVO> menus = list.stream().map(MenuOptionVO::new).collect(Collectors.toList());// 在CouponServiceImpl中,将bizId转换为CouponScope对象
List<CouponScope> newScopeList = newScopes.stream().map(bizId -> new CouponScope().setBizId(bizId).setCouponId(couponId)).collect(Collectors.toList());

collect() 方法


collect()是一个终端操作(terminal operation),用于将流中的元素收集到集合或其他数据结构中。


常见的收集器(Collectors)用法:
1. Collectors.toList() - 收集到List中

// 收集为List
List<RoleDTO> dtoList = list.stream().map(Role::toDTO).collect(Collectors.toList());

2. Collectors.toSet() - 收集到Set中

// 在PointsBoardServiceImpl中收集用户ID为Set
Set<Long> userIds = list.stream().map(PointsBoard::getUserId).collect(Collectors.toSet());

3. Collectors.toMap() - 收集到Map中

// 在LearningLessonServiceImpl中,将课程信息收集为Map
Map<Long, CourseSimpleInfoDTO> cMap = cInfoList.stream().collect(Collectors.toMap(CourseSimpleInfoDTO::getId, c -> c));// 在PointsBoardServiceImpl中,将用户信息收集为Map
Map<Long, String> userMap = userDTOS.stream().collect(Collectors.toMap(UserDTO::getId, UserDTO::getName));// 在CartServiceImpl中,将课程信息收集为Map
Map<Long, CourseSimpleInfoDTO> courseMap = courseSimpleInfos.stream().collect(Collectors.toMap(CourseSimpleInfoDTO::getId, c -> c));

4. Collectors.groupingBy() - 按条件分组

// 在CouponServiceImpl中,按优惠券ID分组并统计数量
Map<Long, Long> unUseMap = list.stream().filter(userCoupon -> userCoupon.getStatus() == UserCouponStatus.UNUSED).collect(Collectors.groupingBy(UserCoupon::getCouponId, Collectors.counting()));// 在CourseCatalogueServiceImpl中,按媒资ID分组并统计引用次数
Map<Long, Long> mediaAndCount = courseCatalogues.stream().collect(Collectors.groupingBy(CourseCatalogue::getMediaId, Collectors.counting()));

实际应用示例
让我们看一个更复杂的例子,来自CouponServiceImpl:

// 统计当前用户针对每一个卷已领取且未使用的数量
//filter过滤得到未使用的
Map<Long, Long> unUseMap = list.stream().filter(userCoupon -> userCoupon.getStatus() == UserCouponStatus.UNUSED).collect(Collectors.groupingBy(UserCoupon::getCouponId, Collectors.counting()));

这个例子展示了:
使用filter()进行筛选(只保留未使用的优惠券)
使用collect()结合Collectors.groupingBy()进行分组
使用Collectors.counting()进行计数

=========================================================================

对于stream()的操作,个人认为主要是对于其中的参数难以灵活使用,根据个人使用情况得到以下总结:


map()方法参数选择:
①使用方法引用(如Role::toDTO)当转换逻辑已经在类中存在
②使用Lambda表达式(如bizId -> new CouponScope().setBizId(bizId))当需要创建新对象或进行复杂转换


collect()方法参数选择:
①Collectors.toList() - 当需要保持元素顺序的列表时
②Collectors.toSet() - 当需要去重元素时
③Collectors.toMap(keyMapper, valueMapper) - 当需要键值对结构时
④Collectors.groupingBy(classifier) - 当需要按条件分组时
⑤Collectors.groupingBy(classifier, downstream) - 当需要分组后进一步聚合时

http://www.lryc.cn/news/619817.html

相关文章:

  • AR技术赋能风电组装:效率提升30%,错误率降低50%
  • 华为悦盒EC6108V9-1+4G版-盒子有【蓝色USB接口】的特殊刷机说明
  • UniApp开发常见问题及解决办法
  • RabbitMQ面试精讲 Day 21:Spring AMQP核心组件详解
  • FluxApi - 使用Spring进行调用Flux接口
  • 后端Web实战-MySQL数据库
  • 【SpringBoot系列-01】Spring Boot 启动原理深度解析
  • 力扣121:买卖股票的最佳时机
  • 敲响变革的钟声:AI 如何重塑前端开发的基础认知
  • Java毕业设计选题推荐 |基于SpringBoot的水产养殖管理系统 智能水产养殖监测系统 水产养殖小程序
  • Kubernetes部署apisix的理论与最佳实践(三)
  • 从原材料到成品,光模块 PCB 制造工艺全剖析
  • JavaWeb-XML、HTTP协议和Tomcat服务器
  • 解析Vue3中集成WPS Web Office SDK的最佳实践
  • DAY42 Grad-CAM与Hook函数
  • Spring Boot调用优化版AI推理微服务 集成 NVIDIA NIM指南
  • 利用生成式AI与大语言模型(LLM)革新自动化软件测试 —— 测试工程师必读深度解析
  • Pycharm选好的env有包,但是IDE环境显示无包
  • Appium-移动端自动测试框架详解
  • windows通过共享网络上网
  • 100、【OS】【Nuttx】【构建】cmake 配置保存
  • 2025年跨网文件摆渡系统分析,跨网文件交换系统实现瞬间数据互通
  • Windows基础概略——第一阶段
  • 5种缓存策略解析
  • scikit-learn/sklearn学习|岭回归linear_model.Ridge()函数解读
  • 流处理 or 批处理?大数据架构还需要流批一体吗?
  • USB基础 -- USB2.0设备插入的过程
  • 6 .循环-for
  • MySQL 到 ClickHouse 明细分析链路改造:数据校验、补偿与延迟治理
  • 3.9开发前端常用的几个工具(nvm,json-server,nrm)