Java8의 새로운 기능 Stream을 사용하는 방법

스트림 흐름의 개념

왜 스트림 흐름을 사용해야 할까요?

Stream의 아이디어는 생산 작업장의 조립 라인과 유사합니다. 여러 요소(특히 다단계 작업)를 운영해야 하는 경우 성능과 편의성을 고려하여 먼저 "모델" 단계 중심 계획을 수립한 다음 계획에 따라 실행해야 합니다.

Stream은 데이터 소스의 요소 대기열입니다.

요소는 대기열을 형성하는 특정 유형의 개체입니다. Stream in lava는 요소를 저장하지 않지만 요청 시 요소를 계산합니다.

DataSource 스트림의 소스입니다. 컬렉션, 배열 등이 될 수 있습니다.

Stream의 두 가지 기본 기능:

·파이프라이닝: 중간 작업은 객체 자체를 리플로우합니다. 이러한 방식으로 Fluent 스타일과 마찬가지로 여러 작업을 파이프라인에 연결할 수 있습니다. 이렇게 하면 게으름 및 단락과 같은 작업을 최적화할 수 있습니다.

내부 반복: 과거에는 컬렉션 순회가 반복자 또는 향상된 for를 통해 컬렉션 외부에서 명시적으로 반복되었습니다. 스트림은 내부 반복 방법을 제공하며 스트림은 순회 방법을 직접 호출할 수 있습니다.

스트림을 사용할 때 일반적으로 세 가지 기본 단계가 포함됩니다. 데이터 소스(소스) 가져오기 → 데이터 변환: 원하는 결과를 얻기 위한 작업을 수행합니다. 원본 Stream 개체가 변환될 때마다 원본 Stream 개체는 변환되지 않습니다. 변경하면 새 객체가 반환됩니다. 이를 통해 해당 객체에 대한 작업을 체인처럼 배열하고 파이프라인이 될 수 있습니다.

스트림 스트림 획득

스트림을 획득하는 두 가지 일반적인 방법이 있습니다.

1. 컬렉션을 통해 획득

2 스트림 인터페이스의 정적 메서드는

컬렉션을 통해 획득

모든 컬렉션을 획득할 수 있습니다. 스트림 기본 메소드를 통해 스트림을 얻습니다

//把集合转换为stream流

//list集合

List<String>list=new ArrayList<>();

Stream<String>stream=list.stream();

//set集合

Set<String>set=new HashSet<>();

Stream<String>stream2=set.stream();

//map集合（map集合需要间接的转换）

Map<String, String>map=new HashMap<>();

//方法一：获取键，存储到一个set集合中

Set<String>keySet=map.keySet();

Stream<String>stream3=keySet.stream();

//方法二：获取值，存储到一个collection集合中

Collection<String>values=map.values();

Stream<String>stream4=values.stream();

//方法三：获取键值对，，键与值的映射关系，entrySet()

Set<Map.Entry<String, String>>entries=map.entrySet();

Stream<Map.Entry<String, String>>stream5=entries.stream();

2. Stream 인터페이스의 정적 메소드는 배열에 해당하는 스트림을 얻을 수 있습니다.

매개변수는 가변 매개변수이므로 배열을 전달할 수 있습니다.

//把数组转换成Stream流

Stream<Integer>stream6=Stream.of(1,2,3,4,5);

//可变参数可以传递数组

Integer[]arr={1,2,3,4,5};

Stream<Integer>stream7=Stream.of(arr);

String[]arr2={"a","bb","ccc"};

Stream<String>stream8=Stream.of(arr2);

스트림의 일반적인 방법

스트림의 일반적인 방법은 두 가지 범주로 나뉩니다.

지연된 방법:

반환 값 유형은 여전히 ​​Stream입니다. 인터페이스 자체 유형의 메서드이므로 연결 호출을 지원합니다. (최종 메소드를 제외하고 다른 모든 메소드는 지연 메소드입니다.)

Terminator 메소드:

반환값 유형은 더 이상 Stream 인터페이스 자체 유형의 메소드가 아니므로 StringBuilder와 같은 체인 호출은 더 이상 지원되지 않습니다.

위는 일반적인 스트리밍 방법 몇 가지를 차례로 살펴보겠습니다.

각 순회 방법에 대해

이 방법은 소비자 인터페이스 기능을 허용하고 처리를 위해 각 스트림 요소를 기능에 넘겨줍니다. 소비자 인터페이스는 람다 식을 전달하고 데이터를 사용할 수 있는 소비자 기능 인터페이스입니다.

foeeach 메서드는 스트림의 데이터를 순회하는 데 사용됩니다. 순회 후에는 스트림의 다른 메서드를 사용할 수 없습니다.

기본적으로

public class Demo03Stream_forEach {

public static void main(String[] args) {

Stream<String>stream=Stream.of("张三","李四","王五","赵六","小明","小胖");

/*stream.forEach((String name)->{

System.out.println(name);

});*/

stream.forEach(name->System.out.println(name));

}

}

필터 필터 방법

을 사용하여 스트림의 숫자를 필터링합니다. 필터 메소드의 Predicate 매개변수는 기능적 인터페이스이므로 람다 표현식을 전달하여 데이터를 필터링할 수 있습니다. 아래와 같이 필터 메서드를 사용하여 변환을 다음 스트림으로 필터링할 수 있습니다.

위 그림은 필터 메서드를 사용하여 일부 다른 요소를 필터링한 다음 새 스트림이 됩니다.

기본적으로

public class Demo04Stream_filter {

public static void main(String[] args) {

//创建一个Stream流

Stream<String>stream=Stream .of("张三丰","赵敏","张无忌","周芷若","张三","狮王","张大牛");

//对Stream流中的元素进行过滤。只要张的人

Stream<String>stream2=stream.filter((String name)->{return name.startsWith("张");});

//遍历Stream流

stream2.forEach(name->System.out.println(name));

}

}

맵 매핑 방식(변환) 사용

스트림의 요소를 다른 스트림으로 변환해야 하는 경우 맵 방식을 사용할 수 있습니다. 이 인터페이스에는 아래와 같이 현재 스트림의 T 유형 데이터 유형을 다른 R 유형 데이터 스트림으로 변환할 수 있는 기능 기능적 인터페이스 매개변수가 필요합니다.

위 그림은 다양한 요소의 데이터를 A 유형의 데이터로 변환합니다. 요소.

기본적으로

public class Demo05Stream_map {

public static void main(String[] args) {

//获取一个String类型的Stream流

Stream<String>stream=Stream.of("1","2","3","4","5");

//使用map方法，把字符串类型的整数，转换（映射）为integer类型的整数

Stream<Integer>stream2=stream.map((String s)->{

return Integer.parseInt(s);

});

//遍历Stream流

stream2.forEach(i->System.out.println(i));

}

}

count counting element method

을 사용하여 Stream 스트림의 요소 개수를 계산합니다. count 메서드는 터미널 메서드이고 반환 값은 Long 유형의 정수입니다. 따라서 더 이상 스트림 스트림에서 다른 메서드를 호출할 수 없습니다

기본 사용

public class Demo06Stream_count {

public static void main(String[] args) {

//获取一个Stream流

ArrayList<Integer>list=new ArrayList<Integer>();

//添加元素

list.add(1);

list.add(2);

list.add(3);

list.add(4);

list.add(5);

list.add(6);

list.add(7);

Stream<Integer>stream=list.stream();

//统计stream流中的元素个数

long count=stream.count();

//打印输出

System.out.println(count);//7

}

}

limit截取流元素方法

Limit方法可以对流进行截取，只取用前n个。参数是一个long型，如果集合当前长度大于参数则进行截取，否则不进行操作。limit方法是一个延迟方法，只是对流中的元素进行截取，返回一个新的流，使用可以继续调用stream流中的其他方法。

基本使用

public class Demo07Stream_limit {

public static void main(String[] args) {

show02();

}

private static void show02() {

//创建一个String类型的数组

String[]arr={"喜羊羊","美羊羊","沸羊羊","懒羊羊","灰太狼","红太狼"};

//集合获取一个Stream流

Stream<String>stream=Stream.of(arr);

//用limit方法截取前6个元素

Stream<String>stream2=stream.limit(3);

//遍历Stream2流

stream2.forEach(i->System.out.println(i));

}

}

skip跳过元素方法

如果希望跳过前几个元素，可以使用skip方法获取一个截取之后的新流，如果流的当前长度大于n,则跳过前n个；否则将会得到一个长度为0的流。

基本使用

public class Demo08Stream_skip {

public static void main(String[] args) {

//创建一个String类型的数组

String[]arr={"喜羊羊","美羊羊","懒羊羊","慢羊羊","红太狼","灰太狼","小灰灰","沸羊羊","软绵绵","武大狼"};

//获取Stream流

Stream<String>stream=Stream.of(arr);

//使用skip方法截取后面的元素

Stream<String>stream2=stream.skip(5);

//遍历stream2流

stream2.forEach(i->System.out.println(i));

}

}

concat:合并方法

用于把流组合到一块。如果有两个流，希望合并成为一个流，就可以使用concat方法

基本使用

public class Demo09Stream_concat {

public static void main(String[] args) {

//创建一个Stream流

Stream<String>stream=Stream.of("张三丰","张翠山","赵敏","周芷若","张无忌");

//创建一个String类型的数组

String[]arr={"喜羊羊","美羊羊","懒羊羊","慢羊羊","红太狼","灰太狼","小灰灰","沸羊羊","软绵绵","武大狼"};

//获取Stream流

Stream<String>stream2=Stream.of(arr);

//使用常用方法concat方法合并流

Stream<String>stream3=Stream.concat(stream, stream2);

//遍历Stream3流

stream3.forEach(i->System.out.println(i));

}

}

Stream流的练习

最后，我们通过下面的练习来巩固一下上面所学的内容。

现在有两个ArrayList集合存储队伍当中的多个成员姓名，

要求使用传统的for循环(或增强for循环)依次进行以下若干操作步骤:

1.第一个队伍只要名字为3个字的成员姓名:存储到一个新集合中。

2.第一个队伍筛选之后只要前3个人;存储到一个新集合中。

3.第二个队伍只要姓张的成员姓名;存储到一个新集合中。

4.第二个队伍筛选之后不要前2个人;存储到一个新集合中。

5.将两个队伍合并为一个队伍;存储到一个新集台中。

6.根据姓名创建Person对象:存储到一个新集合中，

7.打印整个队伍的Person对象信息。

示例：

第一支队伍：迪丽热巴、宋远桥、苏星河、石破天、石中玉、老子、庄子、洪七公

第二支队伍：古娜力扎、张无忌、赵丽颖、张三丰、尼古拉斯赵四、张天爱、张二狗

首先创建Person对象类

public class Person {

private String name;

public Person() {

super();

}

public Person(String name) {

super();

this.name = name;

}

public String getName() {

return name;

}

public void setName(String name) {

this.name = name;

}

@Override

public String toString() {

return "Person [name=" + name + "]";

}

}

然后再根据习题要求用Stream流进行过滤

1.第一个队伍只要名字为3个字的成员姓名:存储到一个新集合中。

2.第一个队伍筛选之后只要前3个人;存储到一个新集合中。

// 第一支队伍

// 创建集合

ArrayList<String> one = new ArrayList<>();

// 添加元素

one.add("迪丽热巴");

one.add("宋远桥");

one.add("苏星河");

one.add("石破天");

one.add("石中玉");

one.add("老子");

one.add("庄子");

one.add("洪七公");

//1.第一个队伍只要名字为3个字的成员姓名:存储到一个新集合中。

//2.第一个队伍筛选之后只要前3个人;存储到一个新集合中。

Stream<String>oneStream=one.stream().filter(name->name.length()==3).limit(3);

3.第二个队伍只要姓张的成员姓名;存储到一个新集合中。

4.第二个队伍筛选之后不要前2个人;存储到一个新集合中。

// 第二支队伍

// 创建集合

ArrayList<String> tow = new ArrayList<>();

// 添加元素

tow.add("古娜力扎");

tow.add("张无忌");

tow.add("赵丽颖");

tow.add("张三丰");

tow.add("尼古拉斯赵四");

tow.add("张天爱");

tow.add("张二狗");

//3.第二个队伍只要姓张的成员姓名;存储到一个新集合中。

//4.第二个队伍筛选之后不要前2个人;存储到一个新集合中。

Stream<String>towStream=tow.stream().filter(name->name.startsWith("张")).skip(2);

5.将两个队伍合并为一个队伍;存储到一个新集台中。

6.根据姓名创建Person对象:存储到一个新集合中，

7.打印整个队伍的Person对象信息。

//5.将两个队伍合并为一个队伍;存储到一个新集台中。

//6.根据姓名创建Person对象:存储到一个新集合中，

//7.打印整个队伍的Person对象信息。

Stream.concat(oneStream,towStream).map(name->new Person(name)).forEach(p->System.out.println(p));

위 내용은 Java8의 새로운 기능 Stream을 사용하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!