浅谈java8 stream flatMap流的扁平化操作_Java

概念：

steam 是java8 提出的一个新概念，不是输入输出的 stream 流，而是一种用函数式编程方式在集合类上进行复杂操作的工具。简而言之，是以内部迭代的方式处理集合数据的操作，内部迭代可以将更多的控制权交给集合类。stream 和 iterator 的功能类似，只是 iterator 是以外部迭代的形式处理集合数据的操作。

在java8以前，对集合的操作需要写出处理的过程，如在集合中筛选出满足条件的数据，需要一一遍历集合中的每个元素，再把每个元素逐一判断是否满足条件，最后将满足条件的元素保存返回。而stream 对集合筛选的操作提供了一种更为便捷的操作，只需将实现函数接口的筛选条件作为参数传递进来，stream会自行操作并将合适的元素同样以stream 的方式返回，最后进行接收即可。

2种操作：

1.intermediate operation 中间操作：中间操作的结果是刻画、描述了一个stream，并没有产生一个新集合，这种操作也叫做惰性求值方法。

2.terminal operation 终止操作：最终会从stream中得到值。

如何区分这2种操作呢？可以根据操作的返回值类型判断，如果返回值是stream，则该操作是中间操作，如果返回值是其他值或者为空，则该操作是终止操作。

flatmap 中间操作:

可用 stream 替换值，并将多个 stream 流合并成一个 stream 流。

将含有一串数字的两个流合并为一个流，

 @test
 public void flapmaptest() {
 list<integer> list = (list<integer>) stream.of(arrays.aslist(1, 2, 3, 4, 5, 6), arrays.aslist(8, 9, 10, 11, 12))
  .flatmap(test -> test.stream()).collect(collectors.tolist());
 
 for (int i = 0, length = list.size(); i < length; i++) {
  system.out.println(list.get(i));
 }
 
 }

flatmap的用法和含义住要通过一个案例来讲解，

案例：对给定单词列表 ["hello","world"],你想返回列表["h","e","l","o","w","r","d"]

第一种方式

string[] words = new string[]{"hello","world"}; 
list<string[]> a = arrays.stream(words)
 
.map(word -> word.split("")) 
.distinct() 
.collect(tolist()); 
a.foreach(system.out::print);

代码输出为：

[ljava.lang.string;@12edcd21[ljava.lang.string;@34c45dca

（返回一个包含两个string[]的list）

这个实现方式是由问题的，传递给map方法的lambda为每个单词生成了一个string[](string列表)。因此，map返回的流实际上是stream<string[]> 类型的。你真正想要的是用stream<string>来表示一个字符串。

下方图是上方代码stream的运行流程

第二种方式：flatmap（对流扁平化处理）

string[] words = new string[]{"hello","world"}; 
list<string> a = arrays.stream(words)
 
.map(word -> word.split("")) 
.flatmap(arrays::stream) 
.distinct() 
.collect(tolist()); 
a.foreach(system.out::print);

结果输出：helowrd

使用flatmap方法的效果是，各个数组并不是分别映射一个流，而是映射成流的内容，所有使用map(array::stream)时生成的单个流被合并起来，即扁平化为一个流。

下图是运用flatmap的stream运行流程，

示例：

import java.util.arraylist;
import java.util.arrays;
import java.util.list;
import java.util.stream.collectors;
 
public class flatmap {
  public static void main(string[] args) {
    //扁平化流
    //找出数组中唯一的字符
    string[] strarray = {"hello", "world"};
 
    //具体实现
    list<string> res = arrays.stream(strarray)
        .map(w -> w.split(""))
        .flatmap(arrays::stream)
        .distinct()
        .collect(collectors.tolist());
    system.out.println(res);
 
    //todo 案例
    system.out.println("--------------------------------");
    //demo1:给定数组，返回数组平方和(直接使用映射)
    //[1,2,3,4]=>[1,4,9,16]
    integer[] nums1 = {1, 2, 3, 4};
    list<integer> nums1list = arrays.aslist(nums1);
    list<integer> res1 = nums1list.stream().map(i -> i * i).collect(collectors.tolist());
    system.out.println(res1);
 
    system.out.println("--------------------------------");
    //demo2:给定两数组，返回数组对
    //[1,2,3],[3,4]=>[1,3],[1,4],[2,3],[2,4],[3,3],[3,4]
    integer[] nums2 = {1, 2, 3};
    integer[] nums3 = {3, 4};
    list<integer> nums2list = arrays.aslist(nums2);
    list<integer> nums3list = arrays.aslist(nums3);
 
    //使用2个map嵌套过滤
    list<int[]> res2 = nums2list.stream().flatmap(i -> nums3list.stream().map(j -> new int[]{i, j})).collect(collectors.tolist());
    system.out.println(res2.size());
 
    system.out.println("--------------------------------");
    //demo3:针对demo2和demo1组合返回总和能被3整除的数对
    //(2,4)和(3,3)是满足条件的
    list<int[]> res3 = nums2list.stream().flatmap(i -> nums3list.stream().filter(j -> (i + j) % 3 == 0).map(j -> new int[]{i, j})).collect(collectors.tolist());
    system.out.println(res3.size()); 
  }
}

控制台输出结果：

补充知识：java 之 stream流中map和flatmap的区别

我们先来看 map。如果你熟悉 scala 这类函数式语言，对这个方法应该很了解，它的作用就是把 input stream 的每一个元素，映射成 output stream 的另外一个元素。

转换大写

list<string> output = wordlist.stream().
map(string::touppercase).
collect(collectors.tolist());

这段代码把所有的单词转换为大写。

平方数

list<integer> nums = arrays.aslist(1, 2, 3, 4);
list<integer> squarenums = nums.stream().
map(n -> n * n).
collect(collectors.tolist());

这段代码生成一个整数 list 的平方数 {1, 4, 9, 16}。

从上面例子可以看出，map 生成的是个 1:1 映射，每个输入元素，都按照规则转换成为另外一个元素。还有一些场景，是一对多映射关系的，这时需要 flatmap。

一对多

stream<list<integer>> inputstream = stream.of(
 arrays.aslist(1),
 arrays.aslist(2, 3),
 arrays.aslist(4, 5, 6)
 );
stream<integer> outputstream = inputstream.
flatmap((childlist) -> childlist.stream());

flatmap 把 inpustream 中的层级结构扁平化，就是将最底层元素抽出来放到一起，最终 output 的新 stream 里面已经没有 list 了，都是直接的数字。

以上这篇浅谈java8 stream flatmap流的扁平化操作就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持移动技术网。