【Java】Stream流是什么,如何使用Stream流?

简介: 【Java】Stream流是什么,如何使用Stream流?

Stream流



Stream流

  • Stream流结合了Lambda表达式,简化了集合、数组的操作。

  • 使用步骤:
  • ①得到一条Stream流,并将数据放上去。
  • ②使用中间方法对流水线上的数据进行操作。
  • ③使用终结方法对流水线上的数据进行操作。
  • 小案例:
import java.util.ArrayList;
public class StreamDemo {
  public static void main(String[] args) {
    /*
     * 创建集合、添加元素,使用Stream流,
     * ①将开头为“张”的元素添加进新集合
     * ②之后将长度为3的元素添加进新集合
     * ③遍历
     */
    ArrayList<String> list = new ArrayList<>();
    list.add("张三丰");
    list.add("张无忌");
    list.add("张强");
    list.add("王麻子");
    list.add("小李");
    //获取对象stream流,添加过滤条件,遍历
    list.stream()
        .filter(name -> name.startsWith("张"))
        .filter(name -> name.length() == 3)
        .forEach(name -> System.out.println(name));
  }
}

  • 获取Stream流:
  • default Stream<E> stream():单列集合获取Stream流(Collection的默认方法)
  • public static <T> Stream<T> stream(T[] array):数组获取Stream流(Arrays工具类中的静态方法)
  • public static <T> stream<T> of(T... values):获取一堆零散数据的Stream流(Stream接口中的静态方法,数据需要统一类型)
  • 双列集合无法直接获取Stream流,需要先使用keySet() / entrySet()再对获取到的集合使用stream()获取。

  • Stream流中间方法:
  • Stream<T> filter(Predicate<? super T> predicate):过滤
  • Stream<T> limit(long maxSize):Stream流获取前maxSize个元素
  • Stream<T> skip(long n):跳过前n个元素获取元素
  • Stream<T> distance():元素去重,依赖HashCode() 和 equals()
  • static <T> Stream<T> concat(Stream a,Stream b):将两个流合并为一个流
  • Stream<R> map(Function<T,R> mapper):转换流中的数据类型,参数是函数式的,需重写其方法以设置转换规则,泛型依次是原本类型,转换的类型。
  • 中间方法、返回新的Stream流,流只能使用一次,建议链式编程。
  • 修改Stream流中的数据,原本集合或数组的数据不变。

  • Stream流的终结方法:
  • void forEach(Consumer action):遍历
  • long count():统计
  • toArray():将流中的数据放入数组
  • collect(Collector collector):将流中的数据放入集合
  • Collectors.toList()
  • Collectors.toSet()
  • Collectors.toMap(a,b):a,b两个函数式接口,需要编写匿名内部类,重写方法,指定数据转换规则。
  • 案例:
import java.util.ArrayList;
import java.util.Collections;
import java.util.HashMap;
import java.util.Map;
import java.util.stream.Collector;
import java.util.stream.Collectors;
public class StreamDemo {
  public static void main(String[] args) {  
    /*定义集合,添加数据,留下偶数*/
    ArrayList<Integer> listInt = new ArrayList<>();
    Collections.addAll(listInt, 1,2,3,4,5,6,7,8,9,10);
    listInt.stream().filter(s -> s.intValue() % 2 == 0).forEach(i -> System.out.println(i));
    System.out.println("-------------------------------");
    /*定义集合,添加姓名,年龄数据,保留年龄大于24的人,数据存入Map集合*/
    ArrayList<String> listName = new ArrayList<>();
    Collections.addAll(listName, "张三,18","李四,24","小品,24","小豪,29","张无忌,16","脉哦,22");
    Map<String,Integer> mapName = listName.stream()
            .filter(s -> Integer.parseInt(s.split(",")[1]) >= 24)
            .collect(Collectors.toMap(
                s -> s.split(",")[0] ,
                s -> Integer.parseInt(s.split(",")[1])));
    mapName.entrySet().forEach(s -> System.out.println(s.getKey() + "--" + s.getValue()));
  }
}


目录
相关文章
|
3月前
|
安全 Java API
告别繁琐编码,拥抱Java 8新特性:Stream API与Optional类助你高效编程,成就卓越开发者!
【8月更文挑战第29天】Java 8为开发者引入了多项新特性,其中Stream API和Optional类尤其值得关注。Stream API对集合操作进行了高级抽象,支持声明式的数据处理,避免了显式循环代码的编写;而Optional类则作为非空值的容器,有效减少了空指针异常的风险。通过几个实战示例,我们展示了如何利用Stream API进行过滤与转换操作,以及如何借助Optional类安全地处理可能为null的数据,从而使代码更加简洁和健壮。
109 0
|
20天前
|
Java API 数据处理
探索Java中的Lambda表达式与Stream API
【10月更文挑战第22天】 在Java编程中,Lambda表达式和Stream API是两个强大的功能,它们极大地简化了代码的编写和提高了开发效率。本文将深入探讨这两个概念的基本用法、优势以及在实际项目中的应用案例,帮助读者更好地理解和运用这些现代Java特性。
|
1月前
|
Java 流计算
Flink-03 Flink Java 3分钟上手 Stream 给 Flink-02 DataStreamSource Socket写一个测试的工具!
Flink-03 Flink Java 3分钟上手 Stream 给 Flink-02 DataStreamSource Socket写一个测试的工具!
37 1
Flink-03 Flink Java 3分钟上手 Stream 给 Flink-02 DataStreamSource Socket写一个测试的工具!
|
1月前
|
Java Shell 流计算
Flink-02 Flink Java 3分钟上手 Stream SingleOutputStreamOpe ExecutionEnvironment DataSet FlatMapFunction
Flink-02 Flink Java 3分钟上手 Stream SingleOutputStreamOpe ExecutionEnvironment DataSet FlatMapFunction
23 1
Flink-02 Flink Java 3分钟上手 Stream SingleOutputStreamOpe ExecutionEnvironment DataSet FlatMapFunction
|
2月前
|
存储 Java API
Java——Stream流详解
Stream流是JDK 8引入的概念,用于高效处理集合或数组数据。其API支持声明式编程,操作分为中间操作和终端操作。中间操作包括过滤、映射、排序等,可链式调用;终端操作则完成数据处理,如遍历、收集等。Stream流简化了集合与数组的操作,提升了代码的简洁性
82 11
Java——Stream流详解
|
1月前
|
存储 Java 数据处理
Flink-01 介绍Flink Java 3分钟上手 HelloWorld 和 Stream ExecutionEnvironment DataSet FlatMapFunction
Flink-01 介绍Flink Java 3分钟上手 HelloWorld 和 Stream ExecutionEnvironment DataSet FlatMapFunction
35 1
|
2月前
|
Java API C++
Java 8 Stream Api 中的 peek 操作
本文介绍了Java中`Stream`的`peek`操作,该操作通过`Consumer&lt;T&gt;`函数消费流中的每个元素,但不改变元素类型。文章详细解释了`Consumer&lt;T&gt;`接口及其使用场景,并通过示例代码展示了`peek`操作的应用。此外,还对比了`peek`与`map`的区别,帮助读者更好地理解这两种操作的不同用途。作者为码农小胖哥,原文发布于稀土掘金。
115 9
Java 8 Stream Api 中的 peek 操作
|
2月前
|
Java C# Swift
Java Stream中peek和map不为人知的秘密
本文通过一个Java Stream中的示例,探讨了`peek`方法在流式处理中的应用及其潜在问题。首先介绍了`peek`的基本定义与使用,并通过代码展示了其如何在流中对每个元素进行操作而不返回结果。接着讨论了`peek`作为中间操作的懒执行特性,强调了如果没有终端操作则不会执行的问题。文章指出,在某些情况下使用`peek`可能比`map`更简洁,但也需注意其懒执行带来的影响。
139 2
Java Stream中peek和map不为人知的秘密
|
2月前
|
Java 大数据 API
Java 流(Stream)、文件(File)和IO的区别
Java中的流(Stream)、文件(File)和输入/输出(I/O)是处理数据的关键概念。`File`类用于基本文件操作,如创建、删除和检查文件;流则提供了数据读写的抽象机制,适用于文件、内存和网络等多种数据源;I/O涵盖更广泛的输入输出操作,包括文件I/O、网络通信等,并支持异常处理和缓冲等功能。实际开发中,这三者常结合使用,以实现高效的数据处理。例如,`File`用于管理文件路径,`Stream`用于读写数据,I/O则处理复杂的输入输出需求。
|
2月前
|
Java 程序员 API
Java 8新特性之Lambda表达式与Stream API的探索
【9月更文挑战第24天】本文将深入浅出地介绍Java 8中的重要新特性——Lambda表达式和Stream API,通过实例解析其语法、用法及背后的设计哲学。我们将一探究竟,看看这些新特性如何让Java代码变得更加简洁、易读且富有表现力,同时提升程序的性能和开发效率。