[📕 Reactive] 1. Reactive 시스템과 Reactive 프로그래밍

Reactor, Spring WebFlux의 기초 개념을 꼼꼼하게 다지고자 "스프링으로 시작하는 리액티브 프로그래밍" 책을 정독하고 정리하려고 한다. 

 

 

1. 리액티브 시스템이란?

리액티브 시스템 = 반응을 잘하는 시스템 

 

👉 비동기 메시지 기반의 통신을 기반으로 클라이언트의 요청에 즉각적으로 응답함으로써 지연 시간을 최소화하는 것을 의미

---

✳️ 특징

• 선언형 프로그래밍
  • 실행할 동작을 구체적으로 명시하지 않고, 목표만 선언
  • 여러 가지 동작을 각각 별도의 코드로 분리하지 않고, 각 동작에 대해서 메서드 체인을 형성해 한 문장으로 된 코드로 구성
• Data streams와 propagation of change
  • 데이터가 발생할 때마다 이것을 변화하는 이벤트로 봄
  • 이벤트를 발생키면서 데이터를 계속적으로 전달 

 

🔷 명령형 프로그래밍 

public class Example1_1 {
	public static void main(String[] args){
 		List<Integer> numbers = Arrays.asList(1, 3, 21, 10, 8, 11);
        int sum = 0;
        for(int number : numbers){
        	if(number > 6 && (number % 2 != 0 )) {
            	sum += number;
            }
        }
        
        System.out.println("합계 : " + sum);
    }
}

 

 

🔷 선언형 프로그래밍

public class Example1_2 {
	public static void main(String[] args){
 		List<Integer> numbers = Arrays.asList(1, 3, 21, 10, 8, 11);
        int sum = numbers.stream()
        	.filter(number -> number > 6 && (number % 2 != 0))
            .mapToInt(number -> number)
            .sum();
           
        System.out.println("합계 : " + sum);
    }
}

 

 

 

 

2. 리액티브 프로그래밍 코드 구성

✳️ publisher

• 입력으로 들어오는 데이터를 제공하는 역할

 

✳️ subscriber

• publisher가 제공하는 데이터를 전달받아서 사용하는 주체 

 

✳️ data source (data stream)

• publisher의 입력으로 들어오는 데이터 
• ex) IoT 디바이스 센서로부터 측정된 데이터 (연속적으로 끊임없이 발생)

 

✳️ operator

• publisher와 subscriber 중간에서 데이터 가공 처리