Java Stream 处理分组后取每组最大&Stream流之list转map、分组取每组第一条&Java 8 Collectors：reducing 示例(List分组取最值) |
您所在的位置：网站首页 › cnk的最大值 › Java Stream 处理分组后取每组最大&Stream流之list转map、分组取每组第一条&Java 8 Collectors：reducing 示例(List分组取最值) |
Java Stream 处理分组后取每组最大&Stream流之list转map、分组取每组第一条&Java 8 Collectors：reducing 示例(List分组取最值)
|
Java Stream 处理分组后取每组最大
有一个需求功能：先按照某一字段分组，再按照另外字段获取最大的那个 Map configMap = configList.parallelStream().collect( Collectors.groupingBy(HitRuleConfig::getAppId, // 先根据appId分组 Collectors.collectingAndThen( Collectors.reducing(( c1, c2) -> c1.getVersionSort() > c2.getVersionSort() ? c1 : c2), Optional::get)));先根据appId分组，然后根据versionSort取最大. 【编程技巧】Stream流之list转map、分组取每组第一条 前言JDK1.8推出的stream流能极大的简化对集合的操作，让代码更美观，老规矩，直接上代码。 一、list转map取list中对象的某个属性作为唯一key，对象作为value形成一个map集合，能够便于在后续业务中取值而不用遍历list集合，使代码更优雅。 代码如下（示例）： public class StreamSkill { public static void main(String[] args) { List list = new ArrayList(); TestData.TestDataBuilder builder = TestData.builder(); builder.id(1).name("老王").age(50).address("隔壁"); list.add(builder.build()); builder.id(2).name("司马老贼").age(45).address("许昌"); list.add(builder.build()); System.out.println(list); Map map = list.stream().collect(Collectors.toMap(TestData::getId, Function.identity())); System.out.println(map.get(1)); } } @Data @Builder class TestData{ private Integer id; private String name; private Integer age; private String address; }运行结果: 通过分组取每组第一条数据的操作可以在很多场景适用，比如取多条数据中最新的一条数据等场景。 代码如下（示例）： public class StreamSkill { public static void main(String[] args) { List list = new ArrayList(); TestData.TestDataBuilder builder = TestData.builder(); builder.id(1).name("老王").age(50).address("隔壁"); list.add(builder.build()); builder.id(2).name("司马老贼").age(45).address("许昌"); list.add(builder.build()); builder.id(3).name("曹贼").age(43).address("许昌"); list.add(builder.build()); builder.id(4).name("大耳朵").age(52).address("益州"); list.add(builder.build()); builder.id(5).name("燕人").age(58).address("益州"); list.add(builder.build()); System.out.println(list); Map map = list.stream().collect( Collectors.groupingBy(TestData::getAddress, Collectors.collectingAndThen( Collectors.reducing((t1, t2) -> t1.getAge() > t2.getAge() ? t1 : t2), Optional::get )) ); System.out.println(map); } } @Data @Builder class TestData{ private Integer id; private String name; private Integer age; private String address; }运行结果： 实际业务中根据业务合理利用stream流能够很大程度的简化代码，但是这种写法在出现bug的时候排查较为复杂，建议不要在使用stream流的时候在其中写太复杂的逻辑。 Java 8 Collectors：reducing 示例(List分组取最值) 简介Java 8 Collectors.reducing 利用Comparator(比较器)和BinaryOperator(二元运算符)进行减少流中的元素。 Collectors.reducing返回带有Optional数据的Collector(收集器)。 Collectors.reducing 在Java Doc 的方法语法如下。 public static Collector reducing(BinaryOperator op)Collectors.reducing返回一个Optional类的收集器。 我们需要传递BinaryOperator(二元运算符)的BinaryOperator.maxBy 或BinaryOperator.minBy方法。 BinaryOperator(二元运算符)将Comparator(比较器)作为参数。 根据该Comparator(比较器)和BinaryOperator(二元运算符)，流元素被减少，最后可以作为一个组来收集。 使用场景Collectors.reducing 主要用于取List列表中的某一类型中的最大或最小的一个元素，例如下列代码，取出各个班级中年龄最大的学生信息。 注：如果最值相同，取列表顺序最先出现的一个。 代码示例Student.java package com.concretepage.util; public class Student { private String name; private Integer age; private String className; public Student(String name,Integer age, String className){ this.name=name; this.age=age; this.className = className; } public String getName() { return name; } public Integer getAge() { return age; } public String getClassName() { return className; } }ReducingDemo.java package com.concretepage.util; import java.util.Arrays; import java.util.Comparator; import java.util.List; import java.util.Map; import java.util.Optional; import java.util.function.BinaryOperator; import java.util.stream.Collectors; public class ReducingDemo { public static void main(String[] args) { Student s1 = new Student("Shyam", 22,"A"); Student s2 = new Student("Ram",23,"A"); Student s3 = new Student("Mohan",22,"B"); Student s4 = new Student(null,21,"B"); List list = Arrays.asList(s1,s2,s3,s4); Comparator ageComparator = Comparator.comparing(Student::getAge); Map eldestByClass = list.stream().collect(Collectors.groupingBy(Student::getClassName, Collectors.reducing(BinaryOperator.maxBy(ageComparator)))); eldestByClass.forEach((k,v)->System.out.println("Class:"+k+" Age:"+ ((Optional)v).get().getAge()+" Name:"+((Optional)v).get().getName())); } }输出 Class:A Age:23 Name:Ram Class:B Age:22 Name:Mohan |
从运行结果可以看出，根据address分组后取每组年龄最大的对象信息仅需要 小小的几行代码就可以搞定【本文地址】