[java] RxJava의 비동기 동시성 처리

28 Nov 2023

java

RxJava는 자바에서 비동기 동시성 처리를 위한 강력한 라이브러리입니다. 이 라이브러리는 함수형 프로그래밍 개념과 리액티브 프로그래밍의 원칙을 기반으로 설계되었습니다. RxJava를 사용하면 비동기 작업을 쉽게 처리하고 오류 처리, 쓰레드 관리, 제어 흐름 등에 대한 복잡한 부분을 간단하게 다룰 수 있습니다.

RxJava의 기본 개념

RxJava는 옵저버 패턴을 기반으로 동작합니다. 이 패턴은 옵저버(Observer)가 옵서버블(Observable)을 구독하고, 옵저버블이 값을 방출할 때마다 옵저버에게 이를 알리는 방식으로 동작합니다. RxJava에서는 데이터를 방출하는 방식을 스트림(Stream)이라고 부르며, 스트림을 사용하여 비동기 작업을 처리합니다.

스트림 생성하기

스트림을 생성하기 위해서는 먼저 RxJava의 Observable 클래스를 사용해야 합니다. Observable 클래스는 데이터를 방출하는 동안 옵저버에게 알리는 기능을 제공합니다. 다음은 RxJava에서 스트림을 생성하는 예제 코드입니다.

import io.reactivex.Observable;

public class Main {
    public static void main(String[] args) {
        Observable<String> stream = Observable.just("Hello", "World");

        stream.subscribe(item -> {
            System.out.println(item);
        });
    }
}

위의 예제에서는 Observable.just() 메서드를 사용하여 “Hello”와 “World”라는 문자열을 방출하는 스트림을 생성합니다. 그리고 subscribe() 메서드를 호출하여 옵저버를 등록하고, 방출된 값을 받아와 출력합니다.

비동기 작업 처리하기

RxJava를 사용하면 비동기 작업을 쉽게 처리할 수 있습니다. Observable 클래스의 subscribeOn() 메서드와 observeOn() 메서드를 이용하여 작업을 다른 스레드로 분리하고, 결과를 받아올 스레드를 지정할 수 있습니다. 다음은 RxJava에서 비동기 작업을 처리하는 예제 코드입니다.

import io.reactivex.Observable;
import io.reactivex.schedulers.Schedulers;

public class Main {
    public static void main(String[] args) {
        Observable<String> stream = Observable.just("Hello", "World")
                .subscribeOn(Schedulers.io()) // IO 스레드에서 작업 실행
                .observeOn(Schedulers.newThread()); // 새로운 스레드에서 결과 받아오기

        stream.subscribe(item -> {
            System.out.println(item);
        });

        // 다른 작업을 수행하더라도 메인 스레드는 종료되지 않음
        while (true) {
        }
    }
}

위의 예제에서는 subscribeOn() 메서드를 통해 IO 스레드에서 작업을 실행하도록 지정하고, observeOn() 메서드를 통해 새로운 스레드에서 결과를 받아오도록 지정합니다. 결과로는 “Hello”와 “World”가 출력됩니다.

결론

RxJava를 사용하면 자바에서 비동기 동시성 처리를 쉽고 간편하게 할 수 있습니다. 옵저버 패턴과 리액티브 프로그래밍 원칙에 기반한 RxJava는 비동기 작업 처리를 위한 강력한 기능을 제공합니다. 이를 통해 시스템의 응답성을 향상시키고 복잡한 동시성 문제를 해결할 수 있습니다.

RxJava의 기본 개념

스트림 생성하기

비동기 작업 처리하기

결론

참조