本月博客排行
-
第1名
Xeden -
第2名
fantaxy025025 -
第3名
bosschen - paulwong
- johnsmith9th
年度博客排行
-
第1名
青否云后端云 -
第2名
宏天软件 -
第3名
gashero - gengyun12
- wy_19921005
- vipbooks
- e_e
- benladeng5225
- wallimn
- ranbuijj
- javashop
- jickcai
- fantaxy025025
- zw7534313
- qepwqnp
- robotmen
- 解宜然
- ssydxa219
- sam123456gz
- zysnba
- sichunli_030
- tanling8334
- arpenker
- gaojingsong
- xpenxpen
- kaizi1992
- wiseboyloves
- jh108020
- xyuma
- ganxueyun
- wangchen.ily
- xiangjie88
- Jameslyy
- luxurioust
- mengjichen
- lemonhandsome
- jbosscn
- nychen2000
- zxq_2017
- lzyfn123
- wjianwei666
- forestqqqq
- ajinn
- siemens800
- hanbaohong
- 狂盗一枝梅
- java-007
- zhanjia
- 喧嚣求静
- Xeden
最新文章列表
springcloud stream binding 源码与使用学习笔记
# 前言
刚看到Stream的功能是对接mq产品,以为就是包装一些mq产品接口,实现自动装配后统一使用。但看了一个简单的demo,是使用rabbitMq产品的binder,还有输入输出接口方法通过配置,来对应不同的mq产品。所以作者实现的功能是在自己的channel与mq产品之间做了一个binder,这样方便的改变配置就使用多个mq,也可以方便的换不同的mq。
但是这些stream的c ...
Kafka流式处理
Kafka Streams
初识流式处理
什么是数据流
数据流(也叫事件流)是无边界数据集的抽象表示。无边界意味着无限和持续增长。无边界数据集之所以是无限的,是因为随着时间的推移,新记录会不断加入进来。数据流除了无边界还有以下特性:
数据流是有序的。事件的发生总是有先后顺序的,如先下单再发货
Spring Cloud(11)——基于RocketMQ的Stream实现
基于RocketMQ的Stream实现
Spring Cloud Stream是一个消息收发的框架,它提供了一套标准,应用程序只需要按照它的标准进行消息的收发,而不用关注具体的实现机制。具体的实现可以基于不同的消息中间件进行不同的实现,比如Kafka的实现、RabbitMQ的实现、RocketMQ的实现等。官方已经提供了Kafka和RabbitMQ的实现,RocketMQ的实现由Alibaba负 ...
Java8 的 Stream 流式操作之王者归来
个人博客地址:http://blog.ouyangsihai.cn/java8-de-stream-liu-shi-cao-zuo-zhi-wang-zhe-gui-lai.html
相对于Java8之前的Java的相关操作简直是天差地别,Java8 的流式操作的出现,也很大程度上改变了开发者对于Java的繁琐的操作的印象,从此,Java也走向了函数式编程的道路!
1 流的创建
1. ...
java8 流操作 List去重
List<String> temp = sList.stream().map(x -> x.getId()).distinct().collect(Collectors.toList());
流操作,前面是展开 map,对指定id进行去重,最后转为list
其中 List<Stu> sList
Stu为对象,id 和name两个字段
其他操作参见:jdk st ...
java8新特性学习笔记
package com.abing;
import org.apache.commons.lang.StringUtils;
import java.util.*;
import java.util.function.Function;
import java.util.stream.Collectors;
/**
* Created on 18/7/31 by bingy ...
List -> Map<String, Map<String, Striing>> demo
package com.ctrip.framework.apollo.demo;
import com.google.common.collect.Lists;
import com.google.common.collect.Maps;
import java.util.List;
import java.util.Map;
import java.util.stream.Co ...
Java8之集合(Collection)遍历 forEach()、stream()
package java8.collections;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import java.util.stream.Collectors;
import org.junit.Before;
import org.junit.Test;
...
[Kotlin]如何关闭stream
众所周知,在java中,在finally代码块中可以使用close()关闭不使用的stream。当然kotlin也可以沿用这种操作,那是否有更简单的操作呢?答案是肯定的。
Closeable.use,只要继承了Closeable的类,都可以使用。通过看use的源码,可以看到最后会调用close方法。
因此只需要这样使用:
BufferedWriter(OutputStreamWrite ...
转:Java 8 中的 Streams API 详解
Java 8 中的 Streams API 详解
Streams 的背景,以及 Java 8 中的使用详解
为什么需要 Stream
Stream 作为 Java 8 的一大亮点,它与 java.io 包里的 InputStream 和 OutputSt ...
JDK8 Stream API 学习
为什么需要 Stream
Stream 作为 Java 8 的一大亮点,它与 Java.io 包里的 InputStream 和 OutputStream 是完全不同的概念。它也不同于 StAX 对 XML 解析的 Stream,也不是 Amazon Kinesis 对大数据实时处理的 Stream。java 8 中的 Stream 是对集合(Collection)对象功能的增强,它专注于对集合 ...
java 8 Stream list to Map key 重复 value合并到Collection
关于把list转换成key value的map有很多博客上都有实现,这里是一个吧value放入到集合中去
List<String> list = Lists.newArrayList("1", "2", "3", "1");
Map<String, List&l ...
Dynamodb专题系列第一讲
dynamodb是aws NOSQL全托管数据库。1.所有的表都是分区的,主键有两种 a》只设置一个partition key b》设置一个partion key和一个range key,相当于联合主键 ...
【转】JAVA8-Stream弥补函数式编程
Java 8新特性:全新的Stream API
廖雪峰 / 编程 / 2014-9-21 22:25 / 阅读: 566
本文已同步发布在InfoQ中文站
Java 8引入了全新的Stream API。这里的
Java8之简单流操作
一、Java8中的Stream
Java8之所以被广大的Java爱好者所喜爱,是因为它提供了一系列的关于集合的Stream操作。集合API是Java API中最重要的部分。基本上每一个java程序都离不开集合。尽管很重要,但是现有的集合处理在很多方面都无法满足需要。
一个原因是,许多其他的语言或者类库以声明的方式来处理特定的数据模型,比如SQL语言,你可以从表中查询, ...