利用Rxjava简单处理复杂请求

这是Android Weekly第270期推荐的一篇文章:How to make complex requests simple with RxJava in Kotlin,Kotlin写的,MVP+Dagger2+RxJava2+Retrofit2,现在的标配?黑人问号??下载下来发现作者是用Android Studio 3.0写的,改build.gradle中的gradle版本也跑不起来,也不想下载beta版的AS,就想着自己试着写一个,顺便练习下。MVP和Dagger2其实挺烦人的,所以我就怎么简单怎么写,达到目的就行了,还是用的Kotlin写的(如果你说你不会kotlin,那么建议赶紧学学,说不定以后大牛的Demo都看不懂,多难过啊),下面分析。最后上代码,有兴趣的可以看看。

先看效果图

screen

这个Demo主要用的StackOverflow的开放API,就2个页面,第一个界面是请求了reputation最高的用户并展示,第二个页面是选择了该用户,展示其提的问题,给别人回答的答案,最喜欢的问题这三个部分,每个部分只显示3条。

烦人的就是第二个页面了,该页面是由4个接口返回的值组成的,其中getQuestions和getFavorites可以直接获取到,但是getAnswers返回的是答案,我们还要通过答案中的question_id再去请求对应的问题来展示。

一般的做法就是一个一个请求,再写个方法组成没问题,但是用RxJava中的flatmap和zip操作符能够更加轻松的完成。

首先考虑用Single,对于Single,官网是这样解释的:

A Single is something like an Observable, but instead of emitting a series of values — anywhere from none at all to an infinite number — it always either emits one value or an error notification.

区别于Observable不同的是,Observable发出0~n个事件,而single只发出一个(事件)值:成功的值或者失败的提示,我们就关心这2样,相比较Observable的onNext,onComplete,onError稍微简单些。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
Single.zip(
ApiHelper.getService().getQuestionsByUser(mUserId),
getAnswers(),
ApiHelper.getService().getFavoritesByUser(mUserId),
Function3<CommonResult<Question>, List<Question>, CommonResult<Question>, DetailModel>
{ questionResult, answers, favoritesResult ->
val questions = questionResult.items.take(3)
val favorites = favoritesResult.items.take(3)
DetailModel(questions, answers, favorites)
}
).subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe({
adapter.setData(it)
}, {
it.printStackTrace()
toast("请求错误:${it.message}")
})

zip的作用是将前三个Single发射的东西整合成一个再发射出去,看Function3,比如上面是将Single,Single,Single合成Single返回,便于后续处理。

getAnswers返回Single>,说到flatmap就想到和map的区别,map是将一个值转化为另一个值,但是flatmap是将一个值转化为一个新的Observable或者Single,再发出去,相当于解决嵌套的问题。下面有个注意点,用questionId去请求问题接口的话,如果把多个questionId放一起,用;隔开去请求就会得到一个多个问题的数组返回

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
private fun getAnswers(): Single<List<Question>> {
return ApiHelper.getService()
.getAnswersByUser(mUserId)
.flatMap {
val processedAnswers = it.items
.filter { it.accept }
.take(3)

val ids = processedAnswers
.map { it.questionId.toString() }
.joinToString(separator = ";")

ApiHelper.getService()
.getQuestionById(ids)
.map { it.items }
}
}

最后上自己写的代码地址:GitHub Repository,主要核心还是上面的zip和flatmap的使用。代码写的还有很多不足的地方,欢迎提出。