专栏名称: RAE
Android
目录
相关文章推荐
51好读  ›  专栏  ›  RAE

优雅的解决Retrofit RxAndroid关联生命周期问题

RAE  · 掘金  ·  · 2019-05-14 06:02

正文

请到「今天看啥」查看全文


阅读 76

优雅的解决Retrofit RxAndroid关联生命周期问题

Retrofit 结合 RxAndroid 应该是史上最好用的网络请求框架了,在项目中只需要一段代码就可以完成网络请求以及回调处理,来看看 google官方示例

public class UserActivity extends AppCompatActivity {
    // 数据提供
    private UserViewModel mViewModel;
    // 管理subscriptions订阅的释放
    private final CompositeDisposable mDisposable = new CompositeDisposable();

    @Override
    protected void onStart() {
        super.onStart();
        // 发起网络请求
        mDisposable.add(mViewModel.getUserName()
                .subscribeOn(Schedulers.io()) // 请求在IO线程运行
                .observeOn(AndroidSchedulers.mainThread()) // 回调到Android主线程
                .subscribe(userName -> mUserName.setText(userName), // 回调监听
                        throwable -> Log.e(TAG, "Unable to update username", throwable)));
    }

    @Override
    protected void onStop() {
        super.onStop();
        // 释放请求
        mDisposable.clear();
    }
}
复制代码

在上面的例子中,所有的请求都必须要 add CompositeDisposable 中,在 Activity 停止的时候进行释放操作。如果不释放的话会怎么样?答案是程序会崩溃。因为你的网络请求是运行在异步线程IO中去的,当线程完成后回调到主线程来,发现 Activity 跑路(被释放)了,回调的 subscribe(...) 找不到对象了,那肯定不干啊,线程也是有点小脾气的嘛。

痛点

程序员都是 "很懒的" ,一来写代码不好看,每个请求要嵌套在 add() 括号中;二来要在 Activity 销毁的时候进行释放。

Retrofit Rxandroid Adapter

为解决 Retrofit 关联的 Activity Fragment 生命周期而设计。

一、用法

通过 with(this) 来关联生命周期,简化 Activity.onStop() 的释放操作。

public class UserActivity extends AppCompatActivity {
	@Override
	protected void onCreate(@Nullable Bundle savedInstanceState) {
		MyService service = retrofit.create(MyService.class); // 你的接口
		service.getUser()
		       .with(this) // 关联生命周期
		       .subscribe(new YourObserver());
	}
}
复制代码

二、配置

1、在 Retrofit 初始化的实例的时候,添加 RxAndroidCallAdapterFactory 作为回调适配器。

Retrofit retrofit = new Retrofit.Builder()
    .baseUrl("https://example.com/")
    // 添加适配器
    .addCallAdapterFactory(RxAndroidCallAdapterFactory.create())
    .build();
复制代码

2、改写你的接口返回值,由之前的 Observable<> 改为 AndroidObservable<>

interface MyService {
  @GET("/user")
  AndroidObservable<User> getUser();
}
复制代码

三、下载

allprojects {
	repositories {
		// ... 省略其他
		maven { url 'https://jitpack.io' }
	}
}
复制代码
dependencies {
	implementation 'com.github.raedev:retrofit-rxandroid-adapter:latest.version'
}
复制代码

AndroidObservable

源码请查看 开源地址:https://github.com/raedev/retrofit-rxandroid-adapter







请到「今天看啥」查看全文