Java 고급 함수형

Java Reactive Programming

Java Reactive Programming — 고급

Reactive Programming

1. 도입 (왜 배워야 하는가)

Reactive Programming(리액티브 프로그래밍)은 비동기 처리와 이벤트 기반 프로그래밍을 효율적으로 다루기 위한 프로그래밍 패러다임입니다. 현대 소프트웨어 개발에서는 사용자 인터페이스(UI) 반응성과 데이터 스트림 처리의 중요성이 커지고 있습니다. 특히, 대규모 애플리케이션에서는 사용자 입력이나 데이터 변경에 즉각적으로 반응할 수 있는 능력이 필수적입니다.

만약 리액티브 프로그래밍을 모른다면, 다음과 같은 문제가 발생할 수 있습니다:

복잡한 비동기 처리: 일반적인 방법으로 비동기 처리를 구현하면, 코드가 복잡해지고 관리하기 어려워질 수 있습니다.
성능 저하: 이벤트 기반 처리의 장점을 활용하지 못해 애플리케이션의 성능이 저하될 수 있습니다.
유지보수의 어려움: 리액티브 프로그래밍의 장점인 코드의 간결성과 가독성을 놓치게 되어, 결과적으로 유지보수가 힘들어질 수 있습니다.

2. 핵심 개념 설명

리액티브 프로그래밍의 핵심 개념을 몇 가지 설명하겠습니다.

2.1 Observable

정의: Observable은 데이터의 흐름을 나타내는 객체로, 데이터가 변경될 때마다 이를 구독하는 Observer에게 알리는 역할을 합니다.
비유: 일기 예보와 같습니다. 일기 예보를 구독하면, 날씨가 바뀔 때마다 알림을 받는 것과 유사합니다.

2.2 Observer

정의: Observable에서 발생하는 이벤트를 받아 처리하는 객체입니다.
비유: 일기 예보의 수신자입니다. 예보를 받고 날씨에 맞게 옷을 준비하는 역할을 합니다.

2.3 Subscription

정의: Observer가 Observable에 연결되어 데이터를 수신하는 상태입니다.
비유: 일기 예보를 구독하기 위해 신청서를 제출한 상태입니다.

용어	정의
Observable	데이터의 흐름을 나타내는 객체
Observer	Observable의 이벤트를 처리하는 객체
Subscription	Observer가 Observable에 연결된 상태

3. 기본 코드 예제

리액티브 프로그래밍을 활용한 기본적인 코드 예제를 살펴보겠습니다.

import io.reactivex.rxjava3.core.Observable;

public class ReactiveExample {
    public static void main(String[] args) {
        // Observable 생성
        Observable<String> observable = Observable.just("Hello", "Reactive", "World");

        // Observer 구독
        observable.subscribe(data -> System.out.println("Received: " + data));
    }
}

실행 결과:

Received: Hello
Received: Reactive
Received: World

코드 설명:

Observable<String> observable = Observable.just("Hello", "Reactive", "World");

- 문자열 데이터를 포함하는 Observable을 생성합니다.

observable.subscribe(data -> System.out.println("Received: " + data));

- Observable에 Observer를 구독시켜, 데이터가 발행될 때마다 콘솔에 출력합니다.

4. 실전 활용 예제

4.1 쇼핑몰에서 장바구니 구현

장바구니에 아이템이 추가될 때마다 가격을 자동으로 갱신하는 경우:

import io.reactivex.rxjava3.core.Observable;

public class ShoppingCart {
    public static void main(String[] args) {
        Observable<Double> cartTotal = Observable.just(10.0, 20.0, 30.0);

        cartTotal.subscribe(total -> System.out.println("Cart total is: " + total));
    }
}

4.2 실시간 데이터 스트리밍

주식 가격 변동을 실시간으로 감시하는 경우:

import io.reactivex.rxjava3.core.Observable;

public class StockPrice {
    public static void main(String[] args) {
        Observable<Double> stockPrices = Observable.just(100.0, 101.5, 99.0);

        stockPrices.subscribe(price -> System.out.println("Current stock price: " + price));
    }
}

5. 흔한 실수와 주의사항

실수 1: Observable을 잘못 생성함

// 잘못된 코드
Observable<String> observable = Observable.create(emitter -> {
    emitter.onNext("Hello");
    emitter.onComplete();
});

문제: emitter가 null인 경우 예외 발생 가능.

실수 2: Observer가 데이터 수신을 취소하지 않음

// 잘못된 코드
Disposable disposable = observable.subscribe(data -> System.out.println(data));
// 데이터 수신 후 disposable.dispose()를 호출하지 않으면 리소스 누수 발생

6. 정리

리액티브 프로그래밍은 비동기 처리와 이벤트 기반 프로그래밍을 효율적으로 다루기 위한 패러다임입니다.
Observable, Observer, Subscription 등의 개념을 이해하는 것이 중요합니다.
실무에서 리액티브 프로그래밍의 패턴을 활용하면 코드의 간결성과 가독성을 높일 수 있습니다.

학습