分类：stream

2020
09-27

如何在java 8 map中使用stream

简介Map是java中非常常用的一个集合类型，我们通常也需要去遍历Map去获取某些值，java8引入了Stream的概念，那么我们怎么在Map中使用Stream呢？基本概念Map有key，value还有表示key，value整体的Entry。创建一个Map：Map<String,String>someMap=newHashMap<>();获取Map的entrySet：Set<Map.Entry<String,String>>entries=someMap.entrySet();获取map的key：Set<String>keySet=someMap.keySet();获取map的value：Colle... 继续阅读 >

2020
09-27

如何在java 8 stream表达式实现if/else逻辑

简介在Stream处理中，我们通常会遇到if/else的判断情况，对于这样的问题我们怎么处理呢？还记得我们在上一篇文章lambda最佳实践中提到，lambda表达式应该越简洁越好，不要在其中写臃肿的业务逻辑。接下来我们看一个具体的例子。传统写法假如我们有一个1to10的list，我们想要分别挑选出奇数和偶数出来，传统的写法，我们会这样使用：publicvoidinForEach(){List<Integer>ints=Arrays.asList(1,2,3,4,5,6,7,8,9... 继续阅读 >

2020
09-25

StreamAPI多次消费一个stream代码实例

StreamAPI中的stream不能被重复消费，一旦它被使用，stream就被关闭了，别的地方再消费它就会抛IllegalStateException：streamhasalreadybeenoperateduponorclosed。比如下面的代码中，stream被消费了两次，第二次消费时将会抛异常：@Testpublicvoidstatistics(){IntStreamrange=IntStream.range(0,12);OptionalIntmin=range.min();//第一次消费正常System.out.println(min);longcount=range.count()... 继续阅读 >

2020
09-24

Spring Cloud Stream分区分组原理图解

消息分组通常在生产环境，我们的每个服务都不会以单节点的方式运行在生产环境，当同一个服务启动多个实例的时候，这些实例都会绑定到同一个消息通道的目标主题（Topic）上。默认情况下，当生产者发出一条消息到绑定通道上，这条消息会产生多个副本被每个消费者实例接收和处理，但是有些业务场景之下，我们希望生产者产生的消息只被其中一个实例消费，这个时候我们需要为这些消费者设置消费组来实现这样的功能。当把消费者复制一份... 继续阅读 >

2020
09-24

基于Java8 Stream API实现数据抽取收集

目标&背景我们以“处理订单数据”为例，假设我们的应用是一个分布式应用，有"订单应用"，"物流应用"，"商品应用”等都是独立的服务。本次我们的目的需要展示订单列表完整数据：1.查询订单列表。2.批量查询物流信息。3.将物流信息填充到订单主信息中。假设我们定义了一个订单类，具有几个关键的属性：订单号，状态，订单价，快递信息。如下所示：classOrder{StringorderSeq;Stringstatus;doubletotalPrice;Stringexpre... 继续阅读 >