[STUDY] RxAndroid Part 3 (메모리 누수 - RxLifecycle, compose / CompositeSubscription)

[목차]==================================================

1. Rxandroid 메모리누수

2. RxLifecycle 사용법(compose)

3. RxJava의 Lifecycle 사용방법 - CompositeSubscription

4. MVP 패턴에서의 CompositeSubscription

======================================================

1. Rxandroid 메모리누수

• Rxandroid 는 메모리누수에 대한 문제점이 있는데,
  Observable이 Context를 복사해서 유지하고 있기 때문에 엑티비티가 종료 될때 unsubscribe하지 않으면 안된다. 기본 예제에서는 명시적으로 onPause 나 onDestory에 명시적으로 unsubscribe()를 호출하도록 되어 있다.(참고로 정상적으로 onComplete()나 onError()콜백으로 진입 하게 되면 알아서 unsubscribe()된다)
•  => 이러한 부분을 쉽게 사용하기 위해서 RxLifecycle 라이브러리를 사용하면 쉽게 사용 할 수 있다.

2. RxLifecycle 사용법(compose)

• Activity의 상속을 RxAppCompatActivity으로 변경하고 compose를 사용하여 Rxlifecycle을 적용해 줍니다.
• onCreate 에서 subscribe을 하면 onDestory 에서 자동으로 unsubscribe 되고 onResume 에서 subscribe을 하면 onPause 에서 자동으로 unsubscribe 됩니다.
• 만약에 종료되는 시점은 바꾸고 싶다면 직접 bindUntilEvent 선언하여 조정할 수 있습니다.
• 프로젝트에 의존성 추가

package tiii.com.rxandroid; import android.os.Bundle; import android.util.Log; import android.widget.TextView; import com.trello.rxlifecycle.ActivityEvent; import com.trello.rxlifecycle.components.support.RxAppCompatActivity; import rx.Observable; import rx.Subscriber; public class MainActivity extends RxAppCompatActivity {     public static final String TAG = MainActivity.class.getSimpleName();     @Override     protected void onCreate(Bundle savedInstanceState) {         super.onCreate(savedInstanceState);         setContentView(R.layout.activity_main);         Observable<String> simpleObservable =                 Observable.create(new Observable.OnSubscribe<String>() {                     @Override                     public void call(Subscriber<? super String> subscriber) {                         subscriber.onNext("Hello RxAndroid !!");                         subscriber.onCompleted();                     }                 })                 // `this.<String>` is necessary if you're compiling on JDK7 or below.                 //                 // If you're using JDK8+, then you can safely remove                 .compose(this.<String>bindToLifecycle());                 //.compose(this.<String>bindUntilEvent(ActivityEvent.DESTROY));         simpleObservable.subscribe(new Subscriber<String>() {             @Override             public void onCompleted() {                 Log.d(TAG, "complete!");             }             @Override             public void onError(Throwable e) {                 Log.e(TAG, "error: " + e.getMessage());             }             @Override             public void onNext(String text) {                 ((TextView) findViewById(R.id.textview)).setText(text);             }         });     } }

3. RxJava의 Lifecycle 사용방법 - CompositeSubscription

• RxJava에는 CompositeSubscription이라는 클래스를 제공 한다. 이 클래스는 생성된 Subscription인스턴스를 하나로 관리 해주는 클래스 이다.
• CompositeSubscription클래스의 remove()메소드를 보면, Removes a Subscription from this CompositeSubscription, and unsubscribes the Subscription.이라고 되어 있다. 이 CompositeSubscription에 add()된 Subscription에 remove()메소드를 콜하면 CompositeSubscripnt에서 제거 되면 동시에 unsubscribe된다고 명시 되어 있다
  Activity나 Fragment등의 onCreate()메소드 에서는 멤버변수로 존재 하는 CompositeSubscription인스턴스를 생성 하는 기능이 들어 간다.
• 어떠한 작업을 위해서 subscribe()를 하게 되면 Subscription인스턴스를 변수로 정의 한 다음 CompositeSubscription에 add()해 준다. Activity나 Fragment등의 onDestroy()메소등에서는 생성된 인스턴스로 존재 하는 CompositeSubscription인스턴스를 unsubscribe()한다. Activity나 Fragment에서 생성되어지고 add()된 모든 Rx의 subscribe들은 이제 unubcribe()될 것 이다.

public class MainActivity     extends Activity {   private CompositeSubscription compositeSubscription;   @Override   protected void onCreate(Bundle savedInstanceState) {     super.onCreate(savedInstanceState);     compositeSubscription = new CompositeSubscription();     Observable<String> observable = Observable.create(         (Observable.OnSubscribe<String>) subscriber -> {           ...         }     );     Subscription subscription = observable         .observeOn(Schedulers.computation())         .subscribeOn(AndroidSchedulers.mainThread())         .subscribe(             s -> {               ...             }         );     compositeSubscription.add(subscription);  }   @Override   protected void onDestroy() {     if (compositeSubscription != null) {       compositeSubscription.unsubscribe();     }     super.onDestroy();   } }

4. MVP 패턴에서의 CompositeSubscription

• 위의 3번 방법에서는 Activity나 Fragment에 바로 Subscription을 생성하고 멤버변수로 CompositeSubscription을 생성하여 add(), unsubscribe()하는 것을 알 수 있다.
• 하지만, MVP패턴에서는 Subscription을 실제로 생성하고 비동기 작업을 요청 하는곳이 Activity나 Fragment가 아닌 Presenter에서 하게 된다. Presenter에 CompositeSubscription을 멤버로 두고 관리하게 하는건 무리가 없을것이다. 하지만 Activity나 Fragment의 Lifecycle에 맞추어 Subscription을 관리 하려 하는 목적에 어긋난다.
• 아래 소스는 Presenter의 부모 클래스로서 CompositeSubscription에 Subscriber를 등록 하고 destroy()메소드를 액티비티나 프래그먼트의 라이프 사이클에 맞추어 콜 하는 그 예 이다.

public class BasePresenter {   private CompositeSubscription compositeSubscriptionl;   public BasePresenter() {     this.compositeSubscriptionl = new CompositeSubscription();   }   public <T> void addSubscriber(@NonNull Subscriber<T> subscriber) {     if (compositeSubscriptionl != null) {       compositeSubscriptionl.add(subscriber);     }   }   public void destroy() {     if (compositeSubscriptionl != null) {       compositeSubscriptionl.unsubscribe();     }   } }

1) Presenter의 부모 클래스를 만들고 CompositeSubscription의 멤버변수를 추가 한다.
2) 부모 클래스의 생성자에서는 CompositeSubscription의 인스턴스를 생성 한다.
3) 부모 클래스에는 만들게 될 Subscriber의 인스턴스를 add()하는 메소드와 lifecycle의 onDestroy()에 맞춰 unsubscribe()하는 메소드인destroy()`메소드를 추가 한다.
4) 앞으로 만들게 되는 모든 Presenter들은 부모 Presenter를 상속해서 만든다.
5) 그리고 Activity나 Fragment를 상속한 부모 클래스들을 또 만들고, onCreate()메소드 군 에서는 presenter의 인스턴스를 생성 한다.
6) 또한 onDestroy()에서는 presenter의 destroy()메소드를 꼭 호출 하여 생성된 모든 Subscription을 unsubscribe()하게 해 준다.

이러한 부분이 번거롭다면, 그냥 Trello에서 개발 한 RxLifecycle을 사용 하자!

출처 : 인터넷에서 RxAndroid 검색하여 필요한 정보를 다양한 사이트에서 종합하여 작성된 것입니다. 많은 사이트 내용을 종합하여 공부하여 작성하다보니 일일이 나열하지 못하였습니다. ㅈㅅ(_ _) 이글은 자유롭게 퍼 가셔서 도움이 되었으면 좋겠습니다. 감사합니다.