Android Retrofit + Rxjava

🔥 Rxjava와 함께 Retrofit 구현하기

Retrofit 은 자체적으로 백그라운드에서 Thread  를 실행하고 Callback 을 통해 메인 Thread 에서 UI 업데이트가 가능하다.
이 때 주로 Call interface 의 enqueue 메소드를 통하여 비동기적으로 API 통신을 진행하고, onResponse 와 onFailue 로 통신 결과를 받는다.

Rxjava 와 Retrofit 을 같이 사용할 경우에는 비동기 Thread 를 Rxjava 에서 사용하기 때문에 구독을 통해 진행한다.
Rxjava 와 Retrofit 을 같이 사용하면 일관된 비동기 작업 관리를 할 수 있고, 복잡한 비동기 작업을 보다 쉽게 구현할 수 있다는 장점이 있다. 하지만, 간단한 어플리케이션인 경우에는 Rxjava 를 같이 사용할 필요는 없으므로 개발 상황과 프로젝트에 맞게 사용하면 된다.

아래 예제를 통해 Rxjava 와 Retrofit 을 사용하는 방법을 알아보자.

✓ build.gradle

dependencies {
	...
	implementation 'io.reactivex.rxjava3:rxandroid:3.0.2'
    implementation 'io.reactivex.rxjava3:rxjava:3.1.5'

    implementation 'com.squareup.retrofit2:retrofit:2.9.0'
    implementation 'com.squareup.retrofit2:converter-gson:2.9.0' // JSON 데이터 처리를 위한 Gson 컨버터
    implementation 'com.squareup.retrofit2:adapter-rxjava3:2.9.0'  // RxJava 3 어댑터 추가
}

✓ TestRequest.java

public class TestRequest {
	private String name;
    private String time;
    
    public TestRequest (String name, String time) {
		this.name = name;
        this.time = time;
	}
}

• API 요청 시 전달받을 data class

✓ TestApi.java

public interface TestApi {
    @POST("/test")
    Observable<ResponseBody> getTest(@Body NotificationRequest request);

    @POST("/testSingle")
    Single<String> getTestSingle();
}

• 서버 요청 주소와 파라미터를 포함하여 클라이언트에서 사용할 함수 선언

✓ 사용

// Retrofit
Retrofit retrofit = new Retrofit.Builder()
		.baseUrl("서버 URL")
        .addConverterFactory(GsonConverterFactory.create())
        .addCallAdapterFactory(RxJava3CallAdapterFactory.create())
        .build();

TestApi testApi = retrofit.create(TestApi.class);

// RxJava - Observable
testApi.getTest(request)
		.subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(new Observer<ResponseBody>() {
    	    	@Override
	    	    public void onSubscribe(@io.reactivex.rxjava3.annotations.NonNull Disposable d) {
                        // 구독 시 처리할 내용
                }

				@Override
                public void onNext(@io.reactivex.rxjava3.annotations.NonNull ResponseBody responseBody) {
                        // 결과 데이터 처리
                }

				@Override
                public void onError(@io.reactivex.rxjava3.annotations.NonNull Throwable e) {
                		// 에러 처리
                }

				@Override
                public void onComplete() {
                        // 작업 완료 처리
                    }
                });
                
// Rxjava - Single
testApi.getTestSingle()
		.subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(new SingleObserver<>() {
        		@Override
                public void onSubscribe(@NonNull Disposable d) {
                	// 구독 시 처리할 내용
                }

				@Override
                public void onSuccess(@NonNull String s) {
					// 성공
                }

				@Override
                public void onError(@NonNull Throwable e) {
                	// 오류
                }
        });
 

• 이벤트를 발생시키는 주체인 Observable 과 하나의 데이터만을 발생시키는 Single 의 예시 코드이다.
• 이외에도 Flowable 등의 타입이 있는데, 상황에 맞는 타입을 적용시키면 된다.