【Java8系列06】Java8数据计算

💝💝💝欢迎来到我的博客，很高兴能够在这里和您见面！希望您在这里可以感受到一份轻松愉快的氛围，不仅可以获得有趣的内容和知识，也可以畅所欲言、分享您的想法和见解。

推荐:kwan 的首页,持续学习,不断总结,共同进步,活到老学到老
导航
檀越剑指大厂系列:全面总结 java 核心技术点,如集合,jvm,并发编程 redis,kafka,Spring,微服务,Netty 等
常用开发工具系列:罗列常用的开发工具,如 IDEA,Mac,Alfred,electerm,Git,typora,apifox 等
数据库系列:详细总结了常用数据库 mysql 技术点,以及工作中遇到的 mysql 问题等
懒人运维系列:总结好用的命令,解放双手不香吗?能用一个命令完成绝不用两个操作
数据结构与算法系列:总结数据结构和算法,不同类型针对性训练,提升编程思维,剑指大厂

非常期待和您一起在这个小小的网络世界里共同探索、学习和成长。💝💝💝 ✨✨ 欢迎订阅本专栏 ✨✨

博客目录

- - 1.汇总数据
  - 2.分组求和
  - 3.内存分页
  - 4.判断集合为空
  - 5.并行处理
  - 6.获取字符中数据
  - 7.判断相同的元素
  - 8.list 是否重复
  - 9.数据去重

1.汇总数据

homeSkuTotal.setTotal7SalQty(tags.stream().mapToInt(item -> Objects.nonNull(item.getTotal7SalQty()) ? item.getTotal7SalQty() : 0).sum());

 if (CollectionUtils.isNotEmpty(homeSkuTotalOrr)) {homeSkuTotalOrr.stream().mapToInt(AdsDayOrrDO::getOrderNotArriveQty).sum();
}

2.分组求和

分组求最大值再求和

 if (CollectionUtils.isNotEmpty(homeSkuTotalOrr)) {final Collection<Optional<AdsDayOrrDO>> values = homeSkuTotalOrr.stream().collect(Collectors.groupingBy(AdsDayOrrDO::getProductKey, Collectors.maxBy(Comparator.comparing(AdsDayOrrDO::getPeriodSdate)))).values();homeSkuTotalDTO.setOrderNotArriveQty(values.stream().mapToInt(item -> item.get().getOrderNotArriveQty()).sum());homeSkuTotalDTO.setReplenishNotArriveQty(values.stream().mapToInt(item -> item.get().getReplenishNotArriveQty()).sum());}

3.内存分页

pageBean.setTotalElements(tags.size());pageBean.setTotalPages(tags.size() / pageQuery.getSize() + (tags.size() % pageQuery.getSize() == 0 ? 0 : 1));pageBean.setSize(pageQuery.getSize());pageBean.setNumber(pageQuery.getPage());pageBean.setContent(tags.stream().skip((pageQuery.getPage() - 1) * pageQuery.getSize()).limit(pageQuery.getSize()).collect(Collectors.toList()));pageBean.setNumberOfElements(CollectionUtils.isNotEmpty(pageBean.getContent()) ? pageBean.getContent().size() : 0L);

4.判断集合为空

CollectionUtils.isNotEmpty({a,b}): true

<dependency><groupId>commons-collections</groupId><artifactId>commons-collections</artifactId><version>3.2.2</version>
</dependency>

5.并行处理

@Test
public void test15() {// 调用 parallelStream 方法即能并行处理List<String> names = properties.parallelStream().filter(p -> p.priceLevel < 4).sorted(Comparator.comparingInt(Property::getDistance)).map(Property::getName).limit(2).collect(Collectors.toList());System.out.println(JSON.toJSONString(names));
}

6.获取字符中数据

//博客浏览量未达成
final int x = message.indexOf("需要");
String str = message.substring(x + 2, x + 7);
for (int i = str.length() - 1; i >= 0; i--) {char lastChar = str.charAt(i);if (Character.isDigit(lastChar)) {// 字符不是数字，舍去最后一位字符str = str.substring(0, i + 1);break;}
}

7.判断相同的元素

public class Java8_06_Stream_Same {public static void main(String[] args) {// 老师集合List<Teacher> teachers = Arrays.asList(new Teacher(1L, "张三"),new Teacher(2L, "李四"),new Teacher(3L, "王五"),new Teacher(4L, "赵六"));// 学生集合List<Student> students = Arrays.asList(new Student(5L, "张三"),new Student(6L, "李四"),new Student(7L, "小红"),new Student(8L, "小明"));// 求同时出现在老师集合和学生集合中的人数,name相同即视为同一个人int size = (int) teachers.stream().map(t -> students.stream().filter(s -> Objects.nonNull(t.getName()) && Objects.nonNull(s.getName()) && Objects.equals(t.getName(), s.getName())).findAny().orElse(null)).filter(Objects::nonNull).count();// 求同时出现在老师集合和学生集合中人的name集合,name相同即视为同一个人List<String> names = teachers.stream().map(t -> students.stream().filter(s -> Objects.nonNull(t.getName()) && Objects.nonNull(s.getName()) && Objects.equals(t.getName(), s.getName())).findAny().orElse(null)).filter(Objects::nonNull).map(Student::getName).collect(Collectors.toList());System.out.println("相同的人数:" + size);System.out.println("相同的人姓名集合:" + names);}
}

8.list 是否重复

public class Java8_13_stream_count {public static void main(String[] args) {List<Integer> list = new ArrayList() {{add(1);add(2);add(1);}};long count = list.stream().distinct().count();boolean isRepeat = count < list.size();System.out.println(count);//输出2System.out.println(isRepeat);//输出true}
}

9.数据去重

//方式一
List<Long> distinctIdList = idList.stream().distinct().collect(Collectors.toList());

//方式二
final List<ProductAllexinfoV1DTO> invSqlSkus = tags.stream().filter(t -> t.getInvQty() > 0 || t.getSalQty() > 0).collect(Collectors.toList());homeSkuTotal.setProductTotal(CollectionUtils.isEmpty(invSqlSkus) ? 0 :invSqlSkus.stream().map(ProductAllexinfoV1DTO::getProductKey).collect(Collectors.toSet()).size());