Java:Stream 流式操作
Posted
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Java:Stream 流式操作相关的知识,希望对你有一定的参考价值。
介绍
Java8对集合操作功能的增强,专注于对集合的各种高效、便利、优雅的聚合操作。记录一下Stream流的一些用法。
获取list某个字段组装新List
List<Integer> userIdList = userList.stream().map(e -> e.getUserId()).collect(Collectors.toList());
根据指定字段分组
Map<String, List<User>> mapByName = list.stream().collect(Collectors.groupingBy(User::getName));
去重
List<Integer> numList = Lists.newArrayList(1, 5, 3, 3, 6);
numList = numList.stream().distinct().collect(Collectors.toList());
// 根据指定字段去重
list = list.stream().collect(Collectors.collectingAndThen(Collectors.toCollection(() -> new TreeSet<>(Comparator.comparing(User::getId))), ArrayList::new));
条件过滤
// 只要包含有“张三”的数据
list = list.stream().filter(e -> e.getName().equals("张三")).collect(Collectors.toList());
求和
// 基本类型
int sumAge = userList.stream().mapToInt(User::getAge).sum();
// 其他 -- 若bigDecimal对象为null,可filter()过滤掉空指针
BigDecimal totalMemberNum = userList.stream().map(User::getMemberNum).reduce(BigDecimal.ZERO, BigDecimal::add);
最大值/最小值
Date minDate = userList.stream().map(User::getCreateTime).min(Date::compareTo).get();
Date maxDate = userList.stream().map(User::getCreateTime).max(Date::compareTo).get();
User maxUp = userList.stream().max(Comparator.comparingInt(User::getAge)).get();
差值(新增/删除)
List<Integer> userIdListNew = Lists.newArrayList(1, 2, 3, 5, 6);
List<Integer> userIdListOld = Lists.newArrayList(1, 2, 3, 4);
// 删除人员 [4]
List<Integer> removeUserIdList = userIdListOld.stream().filter(userIdOld -> !userIdListNew.contains(userIdOld)).collect(Collectors.toList());
// 新增人员 [5, 6]
List<Integer> addUserIdList = userIdListNew.stream().filter(userIdNew -> !userIdListOld.contains(userIdNew)).collect(Collectors.toList());
分类统计数量
// 多字段统计 -- ex: 统计相同name下相同age的个数
Map<String, Map<Integer, Long>> map = list.stream().collect(
Collectors.groupingBy(User::getName, Collectors.groupingBy(User::getAge, Collectors.counting()))
);
// 单字段统计 [LongSummaryStatistics中包含总数、最小值、最大值、平均值等信息] -- ex: 根据名称去统计
Map<String, LongSummaryStatistics> map = list.stream()
.collect(
Collectors.groupingBy(User::getName, Collectors.summarizingLong(User::getAge))
);
求list重复元素值
@Test
public void test02() throws Exception
List<Integer> list = Lists.newArrayList(1, 2, 3, 4, 5, 6, 1, 6, 6);
List<Integer> repeatDataList = list.stream()
.collect(Collectors.toMap(e -> e, e -> 1, Integer::sum))
.entrySet().stream()
.filter(entry -> entry.getValue() > 1)
.map(Map.Entry::getKey)
.collect(Collectors.toList());
System.out.println(repeatDataList); // [1, 6]
// 求list对象中某一个字段的重复值
List<String> repeatValueDataList = dictList
.stream().map(e -> e.getValue()).collect(Collectors.toList())
.stream().collect(Collectors.toMap(e -> e, e -> 1, Integer::sum))
.entrySet().stream()
.filter(entry -> entry.getValue() > 1)
.map(Map.Entry::getKey)
.collect(Collectors.toList());
public <T> List<T> getRepeatDataList(List<T> list)
return list.stream()
// 获得元素出现频率的 Map,键为元素,值为元素出现的次数
.collect(Collectors.toMap(e -> e, e -> 1, Integer::sum))
// Set<Entry>转换为Stream<Entry>
.entrySet().stream()
// 过滤出元素出现次数大于 1 的 entry
.filter(entry -> entry.getValue() > 1)
// 获得 entry 的键(重复元素)对应的 Stream
.map(Entry::getKey)
// 转化为 List
.collect(Collectors.toList());
以上是关于Java:Stream 流式操作的主要内容,如果未能解决你的问题,请参考以下文章
Java8—Stream流式编程Optional容器的详细介绍两万字