[java] RxJava를 이용한 비동기 UI 업데이트

28 Nov 2023

java

앱에서 사용자와 상호작용할 때 비동기 작업을 처리해야 하는 경우가 많습니다. 예를 들면 네트워크 요청, 데이터베이스 쿼리, 파일 다운로드 등이 있을 수 있습니다. 이러한 작업은 메인 스레드에서 실행하면 앱의 응답성이 떨어질 수 있으므로 별도의 스레드에서 실행하는 것이 좋습니다.

RxJava는 비동기 작업을 쉽게 처리하기 위한 라이브러리입니다. 이를 이용하면 간단하게 비동기 작업을 스레드에서 실행하고 결과를 메인 스레드에서 UI에 업데이트할 수 있습니다.

RxJava의 기본 개념

RxJava는 관찰자 패턴을 기반으로 동작합니다. 다음은 RxJava에서 사용되는 주요 개념입니다.

Observable: 값 또는 이벤트를 발행하는 객체입니다. 예를 들면 네트워크 요청의 결과를 발행하는 Observable이 있을 수 있습니다.
Observer: Observable로부터 값을 받아 처리하는 객체입니다. 이벤트를 구독하고 결과를 받아 처리합니다.
Subscription: Observer와 Observable 사이의 연결입니다. Subscription을 해제하면 Observable과 관련된 작업을 중단할 수 있습니다.

RxJava를 사용하여 UI 업데이트하기

비동기 작업을 통해 값을 받아와 UI를 업데이트하는 예제를 살펴보겠습니다.

Observable<String> fetchData() {
    return Observable.create(emitter -> {
        // 비동기 작업 수행
        // 결과 값을 emitter를 통해 발행
    });
}

void updateUI(String data) {
    // UI 업데이트 작업 수행
}

void loadData() {
    fetchData()
        .subscribeOn(Schedulers.io()) // IO 스케줄러에서 작업 실행
        .observeOn(AndroidSchedulers.mainThread()) // 메인 스레드에서 UI 업데이트
        .subscribe(data -> updateUI(data)); // Observable 구독하고 결과를 받아 UI 업데이트
}

위의 예제는 fetchData() 메서드를 통해 비동기 작업을 수행하고, loadData() 메서드를 호출하여 Observable을 구독합니다. subscribeOn() 메서드를 통해 IO 스케줄러에서 작업을 실행하고, observeOn() 메서드를 통해 메인 스레드에서 UI 업데이트 작업을 처리합니다. 마지막으로 subscribe() 메서드를 통해 Observable을 구독하고, 결과를 받아 updateUI() 메서드를 호출하여 UI를 업데이트합니다.

이러한 방식으로 RxJava를 사용하면 비동기 작업과 UI 업데이트를 효과적으로 처리할 수 있습니다.

RxJava의 기본 개념

RxJava를 사용하여 UI 업데이트하기

참고 자료