浅谈 RxAndroid + Retrofit + Databinding
最近 RxAndroid 、MVP、MVVM 一直是 Android 程序猿茶余饭后的谈资，于是我也抱着凑热闹的态度试试了试水。这里就谈谈试水后的感受
什么是 RxAndroid ?
要说什么是 RxAndroid ，得从 RxJava 说起。RxJava 在 GitHub 主页上的自我介绍是 "a library for composing asynchronous and event-based programs using observable sequences for the Java VM"（一个在 Java VM 上使用可观测的序列来组成异步的、基于事件的程序的库）。这就是 RxJava ，概括得非常精准。
RxJava 的本质可以压缩为异步这一个词。说到根上，它就是一个实现异步操作的库，而别的定语都是基于这之上的。
而RxAndroid是RxJava的一个针对Android平台的扩展，主要用于 Android 开发。
什么是 Retrofit ?
Retrofit 是一套 RESTful 架构的 Android（Java） 客户端实现，基于注解，提供 JSON to POJO（Plain Ordinary Java Object ，简单 Java 对象），POJO to JSON，网络请求（POST，GET， PUT，DELETE 等）封装。
既然只是一个网络请求封装库，现在已经有了那么多的大家已经耳熟能详的网络请求封装库了，为什么还要介绍它呢，原因在于 Retrofit 是一套注解形的网络请求封装库，让我们的代码结构更给为清晰。它可以直接解析JSON数据变成JAVA对象，甚至支持回调操作，处理不同的结果。主要是 Retrofit 能很好的与 RxAndroid 配合使用。
想更详细的了解 Retrofit，可以查看官方文档
什么是 MVVP ?
MVC（Model-View-Controller）和 MVP（Model-View-Presenter）是最常见的软件架构之一，业界有着广泛应用，大家一定不陌生。但知道什么事 MVVP 的就不多了，它本身很容易理解，但是要讲清楚，这几个架构的区别就不容易了。
MVVM（Model-View-ViewModel），它采用双向绑定（data-binding）：View的变动，自动反映在 ViewModel，反之亦然。Angular 和 Ember 都采用这种模式。
而 Google 新推出的 Databinding 正是采用了这种模式。
RxAndroid + Retrofit + Databinding
上面已经分别介绍了 RxAndroid、Retrofit、Databinding ，想必大家也有了个初步的认识，那我们就看看 RxAndroid + Retrofit + Databinding 产生的“化学反应”。
private void initActionBar() {
setSupportActionBar(getBinding().toolbar);
DrawerLayout drawer = getBinding().drawLayout;
ActionBarDrawerToggle toggle = new ActionBarDrawerToggle(this, drawer, getBinding().toolbar, R.string.navigation_drawer_open, R.string.navigation_drawer_close);
drawer.setDrawerListener(toggle);
toggle.syncState();
getBinding().navigationView.setNavigationItemSelectedListener(this);
}
代码中不再充斥着 findViewById 这样的代码了，将 etContentView() 换成下面的方法。
this.mBinding = DataBindingUtil.setContentView(context, layout_id);
系统会将我们的 layout 和 data 进行绑定并返回 bind 对象，bind.*** 或者 bind.set 方法来取得控件或修改值。当然还有其它的方法，但是你此时再使用 findViewById() 方法不再有效了。
public interface NewsApi {
/**
* 根据 ID 请求新闻列表
* @param id
* @return
*/
@Headers("apikey: 2c61a1cd1f64216e92f7da1603697bf7")
@GET(ApiConst.NEWS)
Observable<News.NewsData> queryNewsByID(@Query("channelId") String id, @Query("page") int page);
/**
* 根据 ChannelName (标题)请求新闻列表
* @param title
* @return
*/
@Headers("apikey: 2c61a1cd1f64216e92f7da1603697bf7")
@GET(ApiConst.NEWS)
Observable<News.NewsData> queryNewsByCName(@Query("channelName") String title, @Query("page") int page);
/**
* 根据 title (标题)请求新闻列表
* @param title
* @return
*/
@Headers("apikey: 2c61a1cd1f64216e92f7da1603697bf7")
@GET(ApiConst.NEWS)
Observable<News.NewsData> queryNewsByTitle(@Query("title") String title, @Query("page") int page);
}
private void initObservables() {
Observable.Transformer<List<News>, List<News>> networkingIndicator = RxNetworking.bindRefreshing(getBinding().refresher);
observableRefresherNewsData = Observable.defer(() -> mNewApi.queryNewsByCName(getArguments().getString(BUNDLE_NAME), 1))
.doOnUnsubscribe(() -> this.unsubcribe("observableNewsData"))
.flatMap(data -> Observable.just(data.contentlist))
.flatMap(list -> getApp().getDB().putList(Const.DB_NEWS_NAME, list, News.class))
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.compose(networkingIndicator);
observableLoadMoreNewsData = Observable.defer(() -> mNewApi.queryNewsByCName(getArguments().getString(BUNDLE_NAME), mCurrPage + 1))
.doOnUnsubscribe(() -> this.unsubcribe("observableNewsData"))
.map(data -> {
mCurrPage = data.currentPage;
return data.contentlist;
})
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.compose(networkingIndicator);
// 刷新/加载更多
RxSwipeRefreshLayout.refreshes(getBinding().refresher)
.doOnUnsubscribe(() -> this.unsubcribe("SwipeRefreshLayout"))
.flatMap(avoid -> observableRefresherNewsData)
.compose(bindToLifecycle())
.subscribe(RxList.prependTo(mNews, getBinding().content), this::showError);
RxEndlessRecyclerView.reachesEnd(getBinding().content)
.doOnUnsubscribe(() -> this.unsubcribe("Recycler"))
.flatMap(avoid -> observableLoadMoreNewsData)
.compose(bindToLifecycle())
.subscribe(RxList.appendTo(mNews), this::showError);
// 首次进入手动加载
observableRefresherNewsData
.map(list -> {
mNews.clear();
return list;
})
.compose(bindToLifecycle())
.subscribe(RxList.prependTo(mNews, getBinding().content), this::showError);
}
上面代码是使用 Retrofit 以 Get 形式从服务器中获取对应的新闻数据，大家可以看到代码的逻辑非常清晰，代码也很简洁（这里使用了 lambda 表达式，不使用的话，代码会长些，但是逻辑依然清晰），如果是按以前的写法的话，我们的代码会比这复杂的多，还涉及到复杂的线程之间的通信。而通过 RxJava ，我们只需要简单的使用 subscribeOn(Schedulers.io()) 和 observeOn(AndroidSchedulers.mainThread()) 就可以完成 IO 线程和 UI 线程的切换。
帅的简直不敢相信，原来还可以这样玩。
总结
优点：
- 代码逻辑更多加清晰。
- 线程之间的切换更加方便、自如。
- 代码可扩展性高，便于维护。
- 不再为 findViewById() 方法而烦，为 Activity 减负，整体结构更加清晰。
缺点：
- 代码出错时，由于 RxJava 的原因，将不太容易找到具体出错位置。
- 由于 RxJava 结构问题，部分需要捕捉的错误可能被 RxJava 消化掉。
- Databinding 在部分情况使用不太如意，如 include 进来的 layout 里对应的 id 不会被关联起来。
- 需要一定的学习成本（当然这不是问题）。
广告
这里打个小广告，介绍下我最近开发的几个小应用
大家多支持下，如果下载达到 1000 的话，我会将其中一两个项目开源出来的哦。
扩展阅读
- RxJava / RxAndroid
- Retrofit:
- Retrofit 官方文档：http://square.github.io/retrofit/
- Retrofit 使用介绍：http://www.cnblogs.com/angeldevil/p/3757335.html
- Retrofit 离线缓存策略：http://www.jcodecraeer.com/a/anzhuokaifa/androidkaifa/2016/0115/3873.html
- Databinding
- MVC，MVP 和 MVVM 的图示：http://www.ruanyifeng.com/blog/2015/02/mvcmvp_mvvm.html
- DataBinding 用户指南：http://segmentfault.com/a/1190000002876984
- Github 上比较全面的：https://github.com/LyndonChin/MasteringAndroidDataBinding
其它
- Blog：http://imli.me
- Github：https://github.com/iQuick
