分类：stream

2022
05-15

如何用Java Stream写出既高雅又装*的代码

目录一.冷静分析二.直接开装2.1初级炫2.2普通炫2.3高级炫2.4再炫一波拿到当前key与对应的数量2.5MapReduce炫git仓库直达List<String>strings=Lists.newArrayList("name=kk","sex=1","tel=1111","email=xx@qq.com","name=ww","name=yy");一.冷静分析如上代码,你现在要做一个分组的Map将上面list的值读取出来,然后分组统计类似于Map<String,List<String>>将Key相同的Val全部存到一个list里面二.直接开装不会真有... 继续阅读 >

2021
11-07

Spring Cloud Stream简单用法

目录简单使用SpringCloudStream构建基于RocketMQ的生产者和消费者生产者消费者Stream其他特性消息发送失败的处理消费者错误处理SpringCloudStream对SpringCloud体系中的Mq进⾏了很好的上层抽象，可以让我们与具体消息中间件解耦合，屏蔽掉了底层具体MQ消息中间件的细节差异，就像Hibernate屏蔽掉了具体数据库（Mysql/Oracle⼀样）。如此⼀来，我们学习、开发、维护MQ都会变得轻松。⽬前SpringCloud... 继续阅读 >

2021
09-07

解析Java8 Stream原理

目录一、前言二、Stream流水线解决方案2.1、操作如何记录2.2、操作如何叠加2.3、叠加之后的操作如何执行一、前言首先我们先看一个使用StreamAPI的示例，具体代码如下：这是个很简单的一个Stream使用例子，我们过滤掉空字符串后，转成int类型并计算出最大值，这其中包括了三个操作：filter、mapToInt、sum。相信大多数人再刚使用StreamAPI的时候都会有个疑问，Stream是指怎么实现的，是每一次函数调用就执行一次迭代吗？答案肯定... 继续阅读 >

2021
08-23

java8 Stream list to Map key 重复 value合并到Collectio的操作

java8StreamlisttoMapkey重复value合并到Collectio关于把list转换成keyvalue的map有很多博客上都有实现，这里是一个把value放入到集合中去List<String>list=Lists.newArrayList("1","2","3","1");Map<String,List<String>>map=list.stream().collect(Collectors.toMap(key->key,value->Lists.newArrayList(value),(List<String>newValueList,List<String>oldVal... 继续阅读 >

2021
08-06

详解Java中的reactive stream协议

目录背景什么是reactivestream深入了解java版本的reactivestreamPublisherSubscriberSubscriptionProcessorJDK中reactivestream的实现总结背景每个数据流都有一个生产者一个消费者。生产者负责产生数据，而消费者负责消费数据。如果是同步系统，生产一个消费一个没什么问题。但是如果在异步系统中，就会产生问题。因为生产者无法感知消费者的状态，不知道消费者到底是繁忙状态还是空闲状态，是否有能力去消费更多的数据。一般来... 继续阅读 >

2021
07-04

IntelliJ IDEA 老司机居然还没用过 Stream Trace功能(问题小结)

前言自从Java8开始，作为程序员的我们都离不开Stream相关功能的使用，书写起来那叫一个流畅（这个feel～～）。但总是有一些时候，我们对stream的操作所要的结果和预期不符，这就需要我们逐步调试，定位问题常规调试先来看下面这段代码：publicstaticvoidmain(String[]args){Object[]res=Stream.of(1,2,3,4,5,6,7,8).filter(i->i%2==0).filter(i->i>3).toArray();System.out.println(Arrays.toString(r... 继续阅读 >

2021
05-25

Java8新特性之Stream API详解

一、前言StreamAPI在Java8版本中使用，关注的是对数据的筛选、查找、存储等它可以做的事情有：过滤、排序、映射、归约二、使用流程Stream实例化中间操作（过滤、排序、映射、规约）终止操作（匹配查找、归约、收集）三、案例演示publicclassEmployeeData{publicstaticList<Employee>getEmployees(){List<Employee>list=newArrayList<>();list.add(newEmployee(1001,"马化腾",34,6000.38));... 继续阅读 >

2021
04-07

SpringCloud Stream使用解析

SpringCloudStream官方定义SpringCloudStream是一个构建消息驱动微服务的框架。应用通过inputs和outputs来与SpringCloudStream中binder对象交互。通过我们配置来binding（绑定），而SpringCloudStream中的binder对象负责与消息中间件交互。所以，我们只需要搞清楚如何与SpringCloudStream交互就可以方便使用消息驱动的方式。通过使用SpringIntegration来连接消息代理中间件以及实现消息事件驱动。目前仅支持RabbitMQ和k... 继续阅读 >

2021
03-05

SpringCloud Stream消息驱动实例详解

1.消息驱动概述1.1是什么在实际应用中有很多消息中间件，比如现在企业里常用的有ActiveMQ、RabbitMQ、RocketMQ、Kafka等，学习所有这些消息中间件无疑需要大量时间经历成本，那有没有一种技术，使我们不再需要关注具体的消息中间件的细节，而只需要用一种适配绑定的方式，自动的在各种消息中间件内切换呢？消息驱动就是这样的技术，它能屏蔽底层消息中间件的差异，降低切换成本，统一消息的编程模型。SpringCloudStream是一个... 继续阅读 >

2021
03-05

利用stream sorted进行降序排序

根据value值的大小进行降序排序，并进行截取。publicstaticvoidmain(String[]args){List<Map<String,Object>>list=Lists.newArrayList();Map<String,Object>map=Maps.newHashMap();map.put("id",1);map.put("value",20);list.add(map);map=Maps.newHashMap();map.put("id",2);map.put("value",80);list.add(map);map=Maps.newHashMap();map.put("id",3);map.put("value",21);lis... 继续阅读 >

2021
02-20

Java8 实现stream将对象集合list中抽取属性集合转化为map或list

首先新建一个实体类Person@DatapublicclassPerson{/**编码*/privateStringcode;/**名字*/privateStringname;publicPerson(Stringcode,Stringname){this.code=code;this.name=name;}}实例化三个对象放入list集合中publicstaticvoidmain(String[]args){Personperson1=newPerson("001","张三");Personperson2=newPerson("002","李四");Personperson3=newPerson("002","王五");... 继续阅读 >

2020
12-10

5分钟让你快速掌握java8 stream常用开发技巧

前言如果有些朋友以前没有使用过java8stream这种链式编程方式做开发，想学习一下。如果有些朋友只学习了一部分用法，想学习更多。如果有些朋友想看看有没有好的示例适用于实际工作当中。那么恭喜你，这篇文章非常适合你。首先，我们一起看看stream的继承关系：Stream、IntStream、LongStream、DoubleStream的父接口都是BaseStream。BaseStream的四个子接口方法都差不多，只是IntStream、LongStream、DoubleStream直接存储基本类型... 继续阅读 >

2020
11-25

java8 Stream API之reduce使用说明

本篇我们只讲reduce。reduce的作用是把stream中的元素给组合起来。至于怎么组合起来：它需要我们首先提供一个起始种子，然后依照某种运算规则使其与stream的第一个元素发生关系产生一个新的种子，这个新的种子再紧接着与stream的第二个元素发生关系产生又一个新的种子，就这样依次递归执行，最后产生的结果就是reduce的最终产出，这就是reduce的算法最通俗的描述；那么结合实际的业务场景来说，运用reduce我们可以做sum,min,max,av... 继续阅读 >

2020
10-10

java8 stream sort自定义复杂排序案例

java8自定义排序需求今天在项目中遇到个需求，按照对象中的三个属性进行排序。具体要求：前提：对象Obj[a=a,b=b,c=c]1、优先级为a>b>c2、a属性为中文，固定排序规则为：政府，合作，基金……3、b的为BigDecimal类型，固定的排序规则为：降序排序4、c为java.util.Date类型，规则为：降序排序其实看这个需求，第3点和第4点不是什么问题，但是第1点，会考虑下怎么实现好。直接上方案吧！方案一新建一张排序表，至少要有... 继续阅读 >

2020
10-10

Java Stream的基本概念以及创建方法

前言相信很多人(包括我自己)，在很长一段时间内虽然使用了JDK1.8，却从来没有使用过自1.8开始增加的Stream这一强大使用的新特性，本文则将先从如何创建Stream开始，逐步去学会Stream的使用。本文不会涉及对流中数据的操作，而只讨论创建流的几种方法，以及一些基础概念，关于流的实用操作将会在后续文章中一一介绍。Stream与Collection的区别1.用途与关注点不同Collection主要关注于对象的存储方面，通过使用List、... 继续阅读 >

2020
10-10

JAVA8 stream中三个参数的reduce方法对List进行分组统计操作

背景平时在编写前端代码时，习惯使用lodash来编写‘野生'的JavaScript;lodash提供来一套完整的API对JS对象（Array,Object,Collection等）进行操作，这其中就包括_.groupBy和_.reduce，即分组和'聚合'（reduce不知道该怎么翻译合适）。使用这些‘野生'的API能够极大的提高我本人编写JS代码的效率。而JAVA8开始支持stream和lambda表达式，这些和lodash的API有很多类似的功能。因此我在熟悉lodash的前提下尝试使用JAVA8的新特性减少... 继续阅读 >