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

一. 冷静分析
二. 直接开装

2.1 初级炫
2.2 普通炫
2.3 高级炫
2.4 再炫一波拿到当前key与对应的数量
2.5 Map Reduce炫

文章图片

git仓库直达

List strings = Lists.newArrayList("name=kk", "sex=1", "tel=1111", "email=xx@qq.com","name=ww","name=yy");

一. 冷静分析如上代码,你现在要做一个分组的Map将上面list的值读取出来,然后分组统计类似于Map> 将Key相同的Val全部存到一个list里面

二. 直接开装不会真有人还直接遍历吧,那别人不就看的懂了~ 为了炫技直接装一波
定义封装对象

@Data@Builderstatic class ObiectMap{private String key; private String value; }

2.1 初级炫

System.out.println("map1: "); Map> collect1 = strings.stream().map(e -> { //封装成对象String[] split = e.split("\\=", 2); return ObiectMap.builder().key(split[0]).value(split[1]).build(); }).collect(Collectors.toMap(ObiectMap::getKey,v->Lists.newArrayList(v.getValue()), (List newList, List oldList) -> { // Collectors.toMap(a,b,(n1,n2)) -> a代表Map的key (这里直接用方法引用拿到key) b代表value (n1,n2)代表key相同时value的处理办法,直接合并ListoldList.addAll(newList); return oldList; })); collect1.forEach((k,v)->{System.out.printf(k+" { "); String vList = v.stream().collect(Collectors.joining(",")); //加上逗号,最后一个不加System.out.printf(vList); System.out.printf(" }"); System.out.println(); }); System.out.println();

结果如下

文章图片

【如何用Java|如何用Java Stream写出既高雅又装*的代码】
2.2 普通炫

System.out.println("map2: "); Map> collect2 = strings.stream().map(e -> {String[] split = e.split("\\=", 2); return ObiectMap.builder().key(split[0]).value(split[1]).build(); }).collect(Collectors.groupingBy(ObiectMap::getKey, Collectors.mapping(ObiectMap::getValue, Collectors.toList()))); //Collectors.groupingBy(a,b) a还是通过key来分组 ,b将value收集起来做list valuecollect2.forEach((k,v)->{System.out.printf(k+" { "); String vList = v.stream().collect(Collectors.joining(",")); //加上逗号,最后一个不加System.out.printf(vList); System.out.printf(" }"); System.out.println(); }); System.out.println();

结果如下

文章图片

2.3 高级炫
用Guava来炫

import com.google.common.collect.*

System.out.println("map3: get name List with Multimap"); List collect3 = strings.stream().map(e -> {String[] split = e.split("\\=", 2); return ObiectMap.builder().key(split[0]).value(split[1]).build(); }).collect(Collectors.toList()); Multimap multiMap = ArrayListMultimap.create(); //使用Guava的Multimap来存 value直接是collection,可以随意转换collect3.forEach(c -> multiMap.put(c.getKey(), c.getValue())); System.out.println(multiMap.get("name").stream().collect(Collectors.joining(","))); System.out.println();

结果如下

文章图片

2.4 再炫一波拿到当前key与对应的数量

System.out.println("map4: get name with count"); Map collect4 = strings.stream().map(e -> {String[] split = e.split("\\=", 2); return ObiectMap.builder().key(split[0]).value(split[1]).build(); }).collect(Collectors.groupingBy(ObiectMap::getKey, Collectors.counting())); // 拿到数量collect4.forEach((k,v)->{System.out.printf(k+" { "); System.out.printf("%d",v); System.out.printf(" }"); System.out.println(); }); System.out.println();

结果如下

文章图片

2.5 Map Reduce炫
这个不能处理重复value,只是将单一Map聚合到一个Map

List strings = Lists.newArrayList("name=kk", "sex=1", "tel=1111", "email=xx@qq.com"); Map reduce = strings.stream().map(e -> {String[] split = e.split("\\=", 2); // 正则划分为单mapreturn Collections.singletonMap(split[0], split[1]); }).reduce(new HashMap(), (accMap, singleMap) -> { // reduce(a,(b,c))-> a 为初始值 b为累加值 c为当前值操作返回当前值与累加值后的结果将多个单KV的Map组合成一个MapaccMap.putAll(singleMap); return accMap; }); reduce.forEach((k,v)->{System.out.println(k+" = "+v); });