Java8 Stream的各种使用姿势

2024-06-23 12:48
文章标签 java stream 姿势 使用

本文主要是介绍Java8 Stream的各种使用姿势，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

Stream简介

  Java 8 API添加了一个新的抽象称为流(Stream)，它可以让你以一种声明的方式处理数据。这种风格将要处理的元素集合看作一种流，流在管道中传输，并且可以在管道的节点上进行处理，比如筛选，排序，聚合等。

概括来说：Stream的出生就是为了代码好看、为了性能高

如何Debug

  在IDEA的Debug窗口找到Trace Current Stream Chain按钮，点击打开就行啦。

Stream常用到的方法

List<TestRes> list = Arrays.asList(new TestRes().setId(1L).setSiteId(1L),new TestRes().setId(2L).setSiteId(1L),new TestRes().setId(3L).setSiteId(2L),new TestRes().setId(4L).setSiteId(2L),new TestRes().setId(5L).setSiteId(2L),new TestRes().setId(6L).setSiteId(2L)
);// 1. map(), 维度不变, 一一映射
// List<Long> idList = list.stream().map(e -> {
//     return e.getId();
// }).collect(Collectors.toList());
List<Long> idList = list.stream().map(TestRes::getId).collect(Collectors.toList());// 2. reduce(), 降维处理, 允许默认值
Integer result = Arrays.stream(new Integer[]{1, 2, 3, 4, 5, 6, 7, 8, 9}
).reduce(0, Integer::sum);// 3. filter(), 过滤器
// List<TestRes> resList = list.stream().filter(e -> {
//     return e.getId() >= 3L;
// }).collect(Collectors.toList());
List<TestRes> resList = list.stream().filter(e -> e.getId() >= 3L
).collect(Collectors.toList());// 4. limit(), 限制流数量
List<TestRes> limitResList = list.stream().limit(3).collect(Collectors.toList());// 5. count(), 计数
long count = list.stream().filter(Objects::nonNull).count();// 6. sort(), 排序, 可自定义比较器
List<Integer> sortList = Arrays.stream(new Integer[]{9, 8, 7, 6, 5, 4, 3, 2, 1}
).sorted().collect(Collectors.toList());

根据Map的Value排序

Map<Long, TestRes> map = new HashMap<>();
map.put(1L, new TestRes().setId(1L).setHits(3));
map.put(2L, new TestRes().setId(2L).setHits(5));
map.put(3L, new TestRes().setId(3L).setHits(2));
map.put(4L, new TestRes().setId(4L).setHits(4));
map.put(5L, new TestRes().setId(5L).setHits(1));List<TestRes> sortResult = new ArrayList<>();
map.entrySet().stream().sorted(Comparator.comparingInt(o -> o.getValue().getHits())
).forEachOrdered(entry -> {sortResult.add(entry.getValue());
});

其他操作：
.distinct() 去重;
.flatMap() 流的扁平化操作;
.forEach() 遍历, void式操作; .peek() 遍历, 返回新的流;
.findFirst() 查找第一个满足条件的元素; .findAny() 查找任一满足条件的元素
.anyMatch() 有无匹配元素; .allMatch() 是否全部匹配; .noneMatch() 是否无一匹配;
.max() 找最大值, 可自定义比较器; .min() 找最小值, 可自定义比较器;

Stream常用到的收集器

// 1. toList()
// 2. groupingBy()
Map<Long, List<TestRes>> listMap = list.stream().collect(Collectors.groupingBy(TestRes::getSiteId, Collectors.toList())
);// 3. toMap()
Map<Long, TestRes> resMap = list.stream().collect(Collectors.toMap(TestRes::getId, Function.identity())
);// 4. toSet()
Set<String> set = Arrays.stream(new String[]{"Java", "Python", "C", "Java"}
).collect(Collectors.toSet());// 5. joining()
String join = list.stream().map(e -> e.getId().toString()
).collect(Collectors.joining(","));

Stream使用时性能隐患注意点

处理N+1查询

/*************************************************************************
* 【需求：查询所有站点下的全部资源，并打印所有资源及其所属站点】
*************************************************************************/
List<Site> sites = siteService.selectByExample(Example.builder(Site.class).andWhere(Sqls.custom().andIn("id", Arrays.asList(58L, 49L, 76L, 91L, 81L))).build()
);/******************************** old  ********************************/
long to1 = Instant.now().toEpochMilli();
sites.forEach(site -> {List<TestRes> resList = resService.select(new TestRes().setSiteId(site.getId()));resList.forEach(res -> {// System.out.println(//     String.format("%s, res from ==> %s", res.getName(), site.getName())// );});
});
log.info("old method complete in ==> {}", Instant.now().toEpochMilli() - to1);
// old method complete in ==> 627/******************************** new  ********************************/
long tn1 = Instant.now().toEpochMilli();
// 批量查询所有资源
List<Long> siteIds = fors.stream().map(Site::getId).collect(Collectors.toList());
List<TestRes> resList = resService.selectByExample(Example.builder(TestRes.class).andWhere(Sqls.custom().andIn("siteId", siteIds)).build()
);// 构造站点映射集
Map<Long, Site> siteMap = sites.stream().collect(Collectors.toMap(Site::getId, Function.identity())
);// 根据站点映射集查找词条所属站点
resList.forEach(res -> {Site site = siteMap.getOrDefault(res.getSiteId(), new Site().setName("-"));// System.out.println(//     String.format("%s, page from ==> %s", res.getName(), site.getName())// );
});
log.info("new method complete in ==> {}", Instant.now().toEpochMilli() - tn1);
// new method complete in ==> 86

结果显示，老方法耗时627ms, 使用IN查询+映射集只需要86ms

树形结构建立

/*************************************************************************
* 【需求：将某篇资源的所有评论整理成树形结构（root 10个元素，2层树形）】
*************************************************************************/
/******************************** old  ********************************/
long to2 = Instant.now().toEpochMilli();
// 查询一级评论
List<Comment> parentComments = commentService.selectByExample(Example.builder(Comment.class).andWhere(Sqls.custom().andEqualTo("sourceId", 1L).andIsNull("childOfId")).orderByDesc("createdAt").build()
);// 遍历一级评论构造子评论列表
List<List<Comment>> resultOld = parentComments.stream().map(parentComment -> {List<Comment> childs = commentService.select(new Comment().setSourceId(parentComment.getSourceId()).setChildOfId(parentComment.getId()));// do somethingreturn childs;
}).collect(Collectors.toList());
log.info("old tree build in ==> {}", Instant.now().toEpochMilli() - to2);
// old tree build in ==> 1219/******************************** new  ********************************/
long tn2 = Instant.now().toEpochMilli();
// 查询所有评论
List<Comment> comments = commentService.selectByExample(Example.builder(Comment.class).andWhere(Sqls.custom().andEqualTo("sourceId", 1L)).orderByDesc("createdAt").build()
);// 根据评论父ID分组
Map<Long, List<Comment>> commentsMap = comments.stream().filter(e -> null != e.getChildOfId()
).collect(Collectors.groupingBy(Comment::getChildOfId, Collectors.toList())
);// 筛选一级评论
List<Comment> rootComments = comments.stream().filter(e -> null == e.getChildOfId()
).collect(Collectors.toList());// 遍历一级评论，查找映射集中的子评论列表
List<List<Comment>> resultNew = rootComments.stream().map(e -> {List<Comment> childs = commentsMap.getOrDefault(e.getId(), Collections.emptyList());// do somethingreturn childs;
}).collect(Collectors.toList());
log.info("new tree build in ==> {}", Instant.now().toEpochMilli() - tn2);
// new tree build in ==> 98

结果显示，老方法耗时1219ms, 使用新方法构造树只需要98ms

结论

  尽量避免在stream中间函数做数据库查询，若情况合适，利用流式特性直接在内存进行筛选分组等操作，以此优化性能。

这篇关于Java8 Stream的各种使用姿势的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1087202。

相关文章

C语言中联合体union的使用

C语言中联合体union的使用

本文编辑整理自： http://bbs.chinaunix.net/forum.php?mod=viewthread&tid=179471 一、前言 “联合体”(union）与“结构体”(struct)有一些相似之处。但两者有本质上的不同。在结构体中,各成员有各自的内存空间, 一个结构变量的总长度是各成员长度之和。而在“联合”中,各成员共享一段内存空间, 一个联合变量
阅读更多...
Java五子棋之坐标校正

Java五子棋之坐标校正

上篇针对了Java项目中的解构思维，在这篇内容中我们不妨从整体项目中拆解拿出一个非常重要的五子棋逻辑实现：坐标校正，我们如何使漫无目的鼠标点击变得有序化和可控化呢？ 目录 一、从鼠标监听到获取坐标 1.MouseListener和MouseAdapter 2.mousePressed方法 二、坐标校正的具体实现方法 1.关于fillOval方法 2.坐标获取 3.坐标转换 4.坐
阅读更多...
Spring Cloud：构建分布式系统的利器

Spring Cloud：构建分布式系统的利器

引言 在当今的云计算和微服务架构时代，构建高效、可靠的分布式系统成为软件开发的重要任务。Spring Cloud 提供了一套完整的解决方案，帮助开发者快速构建分布式系统中的一些常见模式（例如配置管理、服务发现、断路器等）。本文将探讨 Spring Cloud 的定义、核心组件、应用场景以及未来的发展趋势。 什么是 Spring Cloud Spring Cloud 是一个基于 Spring
阅读更多...
Tolua使用笔记（上）

Tolua使用笔记（上）

目录   1.准备工作 2.运行例子 01.HelloWorld：在C#中，创建和销毁Lua虚拟机 和 简单调用。 02.ScriptsFromFile：在C#中，对一个lua文件的执行调用 03.CallLuaFunction：在C#中，对lua函数的操作 04.AccessingLuaVariables：在C#中，对lua变量的操作 05.LuaCoroutine：在Lua中，
阅读更多...
Javascript高级程序设计(第四版)--学习记录之变量、内存

Javascript高级程序设计(第四版)--学习记录之变量、内存

原始值与引用值 原始值：简单的数据即基础数据类型，按值访问。 引用值：由多个值构成的对象即复杂数据类型，按引用访问。 动态属性 对于引用值而言，可以随时添加、修改和删除其属性和方法。 let person = new Object();person.name = 'Jason';person.age = 42;console.log(person.name,person.age);//'J
阅读更多...
java8的新特性之一（Java Lambda表达式）

java8的新特性之一（Java Lambda表达式）

1：Java8的新特性 Lambda 表达式： 允许以更简洁的方式表示匿名函数（或称为闭包）。可以将Lambda表达式作为参数传递给方法或赋值给函数式接口类型的变量。 Stream API： 提供了一种处理集合数据的流式处理方式，支持函数式编程风格。 允许以声明性方式处理数据集合（如List、Set等）。提供了一系列操作，如map、filter、reduce等，以支持复杂的查询和转
阅读更多...
Vim使用基础篇

Vim使用基础篇

本文内容大部分来自 vimtutor，自带的教程的总结。在终端输入vimtutor 即可进入教程。 先总结一下，然后再分别介绍正常模式，插入模式，和可视模式三种模式下的命令。 目录 看完以后的汇总 1.正常模式（Normal模式） 1.移动光标 2.删除 3.【:】输入符 4.撤销 5.替换 6.重复命令【. ; ,】 7.复制粘贴 8.缩进 2.插入模式 INSERT
阅读更多...
Java面试八股之怎么通过Java程序判断JVM是32位还是64位

Java面试八股之怎么通过Java程序判断JVM是32位还是64位

怎么通过Java程序判断JVM是32位还是64位 可以通过Java程序内部检查系统属性来判断当前运行的JVM是32位还是64位。以下是一个简单的方法： public class JvmBitCheck {public static void main(String[] args) {String arch = System.getProperty("os.arch");String dataM
阅读更多...
详细分析Springmvc中的@ModelAttribute基本知识（附Demo）

详细分析Springmvc中的@ModelAttribute基本知识（附Demo）

目录 前言1. 注解用法1.1 方法参数1.2 方法1.3 类 2. 注解场景2.1 表单参数2.2 AJAX请求2.3 文件上传 3. 实战4. 总结 前言 将请求参数绑定到模型对象上，或者在请求处理之前添加模型属性 可以在方法参数、方法或者类上使用 一般适用这几种场景： 表单处理：通过 @ModelAttribute 将表单数据绑定到模型对象上预处理逻辑：在请求处理之前
阅读更多...
eclipse运行springboot项目，找不到主类

eclipse运行springboot项目，找不到主类

解决办法尝试了很多种，下载sts压缩包行不通。最后解决办法如图： help--->Eclipse Marketplace--->Popular--->找到Spring Tools 3---->Installed。
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2