스트림이란?

• 자료의 대상과 관계없이 동일한 연산을 수행

• 배열, 컬렉션을 대상으로 연산을 수행 함

• 일관성 있는 연산으로 자료의 처리를 쉽고 간단하게 함

• 자료 처리에 대한 추상화가 구현되었다고 함

• 한번 생성하고 사용한 스트림은 재사용 할 수 없음

• 자료에 대한 스트림을 생성하여 연산을 수행하면 스트림은 소모됨

• 다른 연산을 수행하기 위해서는 스트림을 다시 생성해야 함

• 스트림 연산은 기존 자료를 변경하지 않음-> 자료에 대한 스트림을 생성하면 스트림이 사용하는 메모리 공간은 별도로 생성되므로 연산이 수행되도 기존 자료에 대한 변경은 발생하지 않음

스트림 연산은 중간 연산과 최종 연산으로 구분 됨

스트림에 대해 중간 연산은 여러 개의 연산이 적용될 수 있지만 최종 연산은 마지막에 한 번만 적용

최종연산이 호출되어야 중간 연산에 대한 수행이 이루어 지고 그 결과가 만들어짐
따라서 중간 연산에 대한 결과를 연산 중에 알수 없음 - > 이를 '지연 연산'이라 함

스트림 생성

public class IntArrayTest {

	public static void main(String[] args) {

		int[] arr = {1,2,3,4,5};
        
		//Arrays.stream은 IntStream 반환
		int sumVal = Arrays.stream(arr).sum();
		long count = Arrays.stream(arr).count();
		
		System.out.println(sumVal);
		System.out.println(count);
	}

}

Arrays.stream(arr).forEach(n->System.out.println(n));
// 내부 요소 하나씩 출력

중간 연산과 최종 연산

중간 연산 : 조건에 맞는 요소를 추출(filter)하거나 요소를 변환 함(map)

문자열 리스트에서 문자열의 길이가 5 이상인 요소만 출력하기

  sList.stream().filter(s->s.length() >= 5).forEach(s->System.out.println(s));

고객 클래스 배열에서 고객 이름만 가져오기

customerList.stream().map(c->c.getName()).forEach(s->System.out.println(s));

public class ArrayListStreamTest {

	public static void main(String[] args) {
		List<String> sList = new ArrayList<String>();
		sList.add("Tomas");
		sList.add("Edward");
		sList.add("Jack");
		
		Stream<String> stream = sList.stream();
		stream.forEach(s->System.out.print(s + " "));
		System.out.println();
		
		sList.stream().sorted().forEach(s->System.out.print(s+ " "));
		sList.stream().map(s->s.length()).forEach(n->System.out.println(n));
		sList.stream().filter(s->s.length() >= 5).forEach(s->System.out.println(s));
		
	}

}

reduce 연산

정의된 연산이 아닌 프로그래머가 직접 구현한 연산을 적용

최종연산이며 스트림을 소모하면서 연산 수행(두번째 요소에 람다식을 넣음으로써 다양한 기능 수행 가능)

람다식을 직접 구현하거나 람다식이 긴 경우 BinaryOperator를 구현한 클래스를 사용 함

// BinaryOperator는 인터페이스이고 apply를 구현해야 함
T reduce(T identify, BinarayOperator<T> accumulator)

Arrays.stream(arr).reduce(0, (a,b)->a+b));

문자열 배열에서 길이가 가장 긴 문자열 찾기 예시

import java.util.Arrays;
import java.util.function.BinaryOperator;

class CompareString implements BinaryOperator<String>{

	@Override
	public String apply(String s1, String s2) {
		if(s1.getBytes().length >= s2.getBytes().length) return s1;
		else return s2;
	}
	
}




public class ReduceTest {

	public static void main(String[] args) {
		String[] greeting = {"안녕하세요~~~", "hello", "Good morning", "반갑습니다^^"};
		
		System.out.println(Arrays.stream(greeting).reduce("", (s1,s2) ->
		{if (s1.getBytes().length >= s2.getBytes().length)
			return s1;
		else return s2;}));
		
		String str = Arrays.stream(greeting).reduce(new CompareString()).get();
		System.out.println(str);

	}

}

패키지 여행 비용 계산하기

여행사에 패키지 여행 상품이 있습니다. 여행 비용은 15세 이상은 100만원, 그 미만은 50만원 입니다. 
고객 세 명이 패키지 여행을 떠난다고 했을 때 비용 계산과 고객 명단 검색등에 대한 연산을 스트림을 활용하여 구현해 봅니다.
고객에 대한 클래스를 만들고 ArrayList로 고객을 관리 합니다. 

고객 정보는 다음과 같습니다.

CustomerLee 
이름 : 이순신
나이 : 40
비용 : 100

CustomerKim
이름 : 김유신
나이 : 20 
비용 : 100

CustomerHong
이름 : 홍길동
나이 :13
비용 : 50

public class TravelCustomer{

	private String name;
    private int age;
    private int price;
    
    public TravelCustomer(String name, int age, int price){
    	this.name = name;
        this.age = age;
        this.price = price;
    }
    
    public String getName(){
    	return name;
   }
   
   public int getAge(){
  		return age;
   }
   
   public int getPrice(){
   		return price;
   }
   
   public void setName(String name){
   		this.name = name;
   }
   
   public void setAge(int age){
   		this.age = age;
   }
   
   public void setPrice(int price){
   		this.price = price;
   }
   
   public String toString(){
   		return "name:" + name + "age:" + age + "price: " + price;
   }
   
}

public class TravelTest {

	public static void main(String[] args) {
		TravelCustomer customerLee = new TravelCustomer("이순신",40,100);
        TravelCustomer customerKim = new TravelCustomer("김유신",20,100);
        TravelCustomer customerHong = new TravelCustomer("홍길동",13,50);
        
        List<TravelCustomer> customerList = new List<TravelCustomer>();
        customerList.add(customerLee);
        customerList.add(customerKim);
        customerList.add(customerHong);
        
        System.out.println("== 고객 명단 추가된 순서대로 출력 ==");
        customerList.stream().map(c->c.getName).forEach(s->System.out.println(s));
        
        int total = customerList.stream().mapToInt(c->c.getPrice()).sum();
        System.out.println("총 여행 비용은 :" + total + "입니다");
        
        System.out.println("== 20세 이상 고객 명단 정렬하여 출력 ==");
        customerList.stream().filter(s->s.getAge() >= 20).map(s -> s.getName()).sorted.
        forEach(s->System.out.println(s));