개발놀이터

자바 스트림API 본문

Java

자바 스트림API

마늘냄새폴폴 2021. 8. 16. 01:36

*스트림 API
Java SE 8 부터 추가된 스트림 API는 파일입출력에서의  스트림과는 전혀 다른 개념이다.
자바에서는 많은 양의 데이터를 저장하기 위해서 배열이나 컬렉션을 사용한다.
이렇게 저장된 데이터에 접근하기 위해서는 반복문이나 반복자를 사용하여 매번 새로운 코드를 작성해야한다.

하지만 이렇게 작성된 코드는 길이가 너무 길고 가독성도 떨어지며, 코드의 재사용이 거의 불가능하다.
즉, 데이터베이스의 쿼리와 같이 정형화된 처리 패턴을 가지지 못했기에 데이터마다 다른 방법으로 접근해야만 했다.

이러한 문제점을 극복하기 위해서 Java SE 8 부터 스트림 API를 도입했다.
스트림 API는 데이터를 추상화하여 다루므로, 다양한 방식으로 저장된 데이터를 읽고 쓰기 위한 공통된 방법을 제공한다. 따라서 스트림 API를 이용하면 배여리나 컬렉션뿐만 아니라 파일에 저장된 데이터도 모두 같은 방법으로 다룰 수 있게 된다.


*스트림 API의 특징
스트림 API는 다음과 같은 특징을 가진다

1. 스트림은 외부 반복을 통해 적업하는 컬렉션과는 달리 내부 반복을 통해 작업을 수행한다.
2. 스트림은 재사용이 가능한 컬렉션과 달리 단 한번만 사용할 수 있다.
3. 스트림은 원본 데이터를 변경하지 않는다.
4. 스트림의 연산은 필터-맵 기반의 API를 사용하여 자연연산을 통해 성능을 최적화한다.
5. 스트림은 parallelStream() 메소드를 통한 손쉬운 병렬처리를 지원한다.


*스트림의 생성
스트림 API는 다음과 같은 다양한 데이터소스에서 생성할 수 있다.

1. 컬렉션
2. 배열
3. 가변 매개변수
4. 지정된 범위의 연속된 정수
5. 특정 타입의 난수들
6. 람다 표현식
7. 파일
8. 빈 스트림


1. 컬렉션 
자바에서 제공하는 모든 컬렉션의 최고 상위 조상인 Collection 인터페이스에는 stream()메소드가 정의되어 있다.
따라서 Collection 인터페이스를 구현한 모든 List와  Set 컬렉션 클래스에서도 stream() 메소드로 스트림을 생성할 수 있다. 또한, parallelStream() 메소드를 사용하면 병렬 처리가 가능할 스트림을 생성할 수 있다.

Stream 클래스의 forEach() 메소드는 해당 스트림의 요소를 하나씩 소모해가며 순차적으로 요소에 접근하는 메소드이다.
따라서 같은 스트림으로는 forEach() 메소드를 한 번 밖에 호출할 수 없다.
단, 원본 데이터의 요소를 소모하는 것은 아니므로, 같은 데이터에서 또 다른 스트림을 생성하여 forEach() 메소드를 호출하는 것은 가능하다.


2. 배열
배열에 관한 스트림을 생성하기 위해 Arrays 클래스에는 다양한 형태의 stream() 메소드가 클래스 메소드로 정의되어 있다.
또한, 기본 타입인 int, long, double 형을 저장할 수 있는 배열에 관한 스트림이 별도로 정의되어 있다.
이러한 스트림은 java.util.stream 패키지의 IntStream, LongStream, DoubleStream 인터페이스로 각각 제공된다.


3. 가변 매개변수
Stream 클래스의 of() 메소드를 사용하면 가변 매개변수를 전달받아 스트림을 생성할 수 있다.


4. 지정된 번위의 연속된 정수
지정된 범위의 연속된 정수를 스트림으로 생성하기 위해 IntStream이나 LongStream 인터페이스에는 range() 와 rangeClosed() 메소드가 정의되어 있다.

range() 메소드는 명시된 시작 정수를 포함하지만, 명시된 마지막 정수는 포함하지 않는 스트림을 생성한다.
rangeClosed() 메소드는 명시된 시작 정수뿐만 아니라 명시된 마지막 정수까지도 포함하는 스트림을 생성한다.


5. 특정 타입의 난수들
특정 타입의 난수로 이루어진 스트림을 생성하기 위해 Random클래스에는 ints(), longs(), doubles() 와 같은 메소드가 정의되어 있다.

이 메소드들은 매개변수로 스트림의 크기를 long타입으로 전달받을 수 있다.
이 메소드들은 만약 매개변수를 전달받지 않으면 크기가 정해지지 않은 무한 스트림을 반환한다.
이때에는 limit() 메소드를 사용하여 따로 스트림의 크기를 제한해야 한다.


6. 람다 표현식
람다 표현식을 매개변수로 전달받아 해당 람다 표현식에 의해 반환되는 값을 요소로 하는 무한 스트림을 생성하기 위해 Stream 클래스에는 iterate() 와 generate() 메소드가 정의 되어 있다.

iterate() 메소드는 시드로 명시된 값을 람다 표현식에 사용하여 반환된 값을 다시 시드로 사용하는 방식으로 무한 스트림을 생성한다.
반면에 generate() 메소드는 매개변수가 없는 람다 표현식을 사용하여 반환된 값으로 무한 스트림을 생성한다.


7. 파일
파일의 한 행을 요소로 하는 스트림을 생성하기 위해 java.nio.file.Files 클래스에는 lines() 메소드가 정의되어 있다.
또한, java.io.BufferedReader 클래스의 lines() 메소드를 사용하면 파일 뿐만 아니라 다른 입력으로부터도 데이터를 행 단위로 읽어올 수 있다.


8. 빈 스트림
아무 요소도 가지지 않는 빈 스트림은 Stream클래스의 empty() 메소드를 사용하여 생성할 수 있다.


*스트림의 중개 연산
스트림 API에 의해 생성된 초기 스트림은 중개 연산을 통해 또 다른 스트림으로 변환된다.
이러한 중개 연산은 스트림을 전달받아 스트림을 반환하므로, 중개 연산은 연속으로  연결해서 사용할 수 있다.
또한, 스트림의 중개 연산은 필터-맵 기반의 API를 사용함으로 지연연산을 통해 성능을 최적화할 수 있다.

스트림 API에서 사용할 수 있는 대표적인 중개 연산과 그에 따른 메소드는 다음과 같다.

1. 스트림 필터링 : filter(), distinct()
2. 스트림 변환 : map(), flatMap()
3. 스트림 제한 : limit(), skip()
4. 스트림 정렬 : sorted()
5. 스트림 연산 결과 확인 : peek()


1. 스트림 필터링
filter() 메소드는 해당 스트림에서 주어진 조건에 맞는 요소만으로 구성된 새로운 스트림을 반환합니다.
또한, distinct() 메소드는 해당 스트림에서 중복된 요소가 제거된 새로운 스트림을 반환한다.
distinct() 메소드는 내부적으로 Object 클래스의 equals() 메소드를 사용하여 요소의 중복을 비교한다.


2. 스트림 변환
map() 메소드는 해당 스트림의 요소들을 주어진 함수에 인수로 전달하여, 그 반환값들로 이루어진 새로운 스트림을 반환한다.
만약 해당 스트림의 요소가 배열이라면, flapMap() 메소드를 사용하여 각 배열의 각 요소의 반환값을 하나로 합친 새로운 스트림을 얻을 수 있다.


3. 스트림 제한
limit() 메소드는 해당 스트림의 첫 번째 요소부터 전달된 개수만큼의 요소만으로 이루어진 새로운 스트림을 반환한다.
skip() 메소드는 해당 스트림의 첫 번째 요소부터 전달된 개수만큼의 요소를 제외한 나머지 요소만으로 이루어진 새로운 스트림을 반환한다.


4. 스트림 정렬
sorted() 메소드는 해당 스트림을 주어진 비교자를 이용하여 정렬한다.
이때 비교자를 전달하지 않으면 기본적으로 사전 편찬 순으로 정렬하게 된다.


5. 스트림 연산 결과 확인
peek() 메소드는 결과 스트림으로부터 요소를 소모하여 추가로 명시된 동작을 수행한다.
이 메소드는 원본 스트림에서 요소를 소모하지 않으므로, 주로 연산관 연산 사이에 결과를 확인하고 싶을 때 사용한다.
따라서 개발자가 디버깅 용도로 많이 사용한다.


*스트림 최종 연산
스트림 API에서 중개 연산을 통해 변환된 스트림은 마지막으로 최종 연산을 통해 각 요소를 소모하여 결과를 표시한다.
즉 지연되었던 모든 중개 연산들이 최종 연산시에 모두 수행되는 것이다.
이렇게 최종 연산 시에 모든 요소를 소모한 해당 스트림은 더는 사용할 수 없게 된다.

스트림 API에서 사용할 수 있는 대표적인 최종 연산과 그에 따른 메소드는 다음과 같다.

1. 요소의 출력 : forEach()
2. 요소의 소모 : reduce()
3. 요소의 검색 : findFirst(), findAny()
4. 요소의 검사 : anyMatch(), allMatch(), noneMatch()
5. 요소의 통계 : count(), min(), max()
6. 요소의 연산 : sum(), average()
7. 요소의 수집 : collect()


1. 요소의 출력
forEach() 메소드는 스트림의 각 요소를 소모하여 명시된 동작을 수행한다.
반환 타입이 void이므로 보통 스트림의 모든 요소를 출력하는 용도로 많이 사용한다.


2. 요소의 소모
스트림의 최종 연산은 모두 스트림의 각 요소를 소모하여 연산을 수행하게 된다.
하지만 reduce() 메소드는 첫 번째와 두 번째 요소를 가지고 연산을 수행한 뒤, 그 결과와 세 번째 요소를 가지고 또 다시 연산을 수행한다.
이런식으로 해당 스트림의 모든 요소를 소모하여 연산을 수행하고, 그 결과를 반환하게 된다.
또한, 인수로 초깃값을 전달하면 초깃값과 해당  스트림의 첫 번째 요소와 연산을 시작하며, 그 결과와 두 번째 요소를 가지고 계속해서 연산을 수행하게 된다.


3. 요소의 검색
findFirst() 와 findAny() 메소드는 해당 스트림에서 첫 번재 요소를 참조하는 Optional 객체를 반환한다.
두 메소드 모두 비어있는 스트림에서는 비어있는 Optional 객체를 반환한다.


4. 요소의 검사
해당 스트림의 요소 중에서 특정 조건을 만족하는 요소가 있는지, 아니면 모두 만족하거나 모두 만족하지 않는지를 다음 메소드를 사요하여 확인할 수 있다.

1. anyMatch() : 해당 스트림의 일부 요소가 특정 조건을 만족할 경우에 true를 반환함
2. allMatch() : 해당 스트림의 모든 요소가 특정 조건을 만족할 경우에 true를 반환함
3. noneMatch() : 해당 스트림의 모든 요소가 특정 조건을 만족하지 않을 경우에 true를 반환함

세 메소드 모두 인수로 Predicate 객체를 전달받으며 요소의 검사 결과는 boolean 값으로 반환한다.


5. 요소의 통계
count() 메소드는 해당 스트림의 요소의 총 개수를 long 타입의 값으로 반환한다.
또한, max() 와 min() 메소드를 사용하면 해당 스트림의 요소 중에서 가장 큰 값과 가장 작은 값을 가지는 요소를 참조하는 Optional객체를 얻을 수 있다.


6. 요소의 연산
IntStream이나 DoubleStream과 같은 기본 타입 스트림에는 해당 스트림의 모든 요소에 대해 합과 평균을 구할 수 있는 sum() 과 average() 메소드가 각각 정의되어 있다.
이때 average() 메소드는 각 기본 타인ㅂ으로 래핑된 Optional 객체를 반환한다.


7. 요소의 수집
collect() 메소드는 인수로 전달되는 Collectors 객체에 구현된 방법대로 스트림의 요소를 수집한다.
또한, Collectors 클래스에는 미리 정의된 다양한 방법이 클래스 메소드로 정의되어 있다.
이 외에도 사용자가 직접 Collector 인터페이스를 구현하여 자신만의 수집 방법을 정의할 수도 있다.

'Java' 카테고리의 다른 글

자바 Optional  (0) 2021.09.23
Timer / TimerTask  (0) 2021.09.06
자바 람다식표현  (0) 2021.08.16
자바 Map컬렉션 클래스  (0) 2021.08.10
자바 Stack 과 Queue  (0) 2021.08.09