Retrofit搭配协程，真香耶！

2019-09-29 本文已影响0人 Natchi

为什么你需要用协程？

Kotlin推出了协程，但Java没有（只有某些框架有这个概念）
告别回调地狱（提高代码的可读性）
面试需要（别逼无奈）：）

image

我用Kotlin快一年了吧，Kotlin是真的香，但是Kotlin的协程，听过，看过，但我没用过，嘻嘻，可能是太懒了吧！！！

这个星期在官网摸了摸🐟，感觉还不错，但还是有很多地方不懂的，慢慢学吧，还请大家多多指教！！！

直接看看来官网的例子吧。(有一部分我去掉了，我想用我的理解说一下协程)

import kotlinx.coroutines.*

fun main() {
    GlobalScope.launch { 
            
    }
}

这就是传说中的协程，skr

你没看错，这就是开启协程的一种写法，是不是看起来很简单，~~嗯，我讲完了，协程就这么简单，再见晚安~~

当然，官网的每个例子哪有难的，难的话，我就不跟他玩了。

再来看一个关键词suspend，这个意思是挂起，我理解的是比如一条流水线上，我看一个东西坏了，我把他吊起来，但他不会影响流水线，我修好了，我又放到流水线上去，是可控的，我想咋样就咋样。

开启协程、吊起、放下一条龙服务

image

单纯一个函数一个函数的讲，那我也讲不完，我也讲不清啊，那下面，我简单的讲下，Retrofit搭配协程构建的简单的网络库

先分析下，先不说RxJava，单纯用Retrofit请求网络的话


    //demo例子，不需要管细节
    enqueue(object : Callback<T> {
            override fun onFailure(call: Call<T>, t: Throwable) {
            //错误回调，告诉返回结果
            mListener.onFail(t)
                }

            override fun onResponse(call: Call<T>, response: Response<T>?) {
            //成功回调，告诉返回结果
            mListener.onSuccess(t)
            }
        })

一般都是这样写吧，观察者模式，然后回调地狱模式开启。

那么加入协程会变成怎么样了，当然协程的作用肯定不止这一点，但我觉得从这里能更容易看出协程的好处。

第一步，开启协程


    fun requestDataToUI(){ GlobalScope.launch(Dispatchers.Main) {
                            try{
                                
                                //从这里开始请求网络
                                getXXData() //成功回调
                                }catch(t : Throwable){
                                //失败回调
                                //to do something
                                }
                             }
                         }

这里需要大概了解的是：

GlobalScope.launch()：是个顶层的开启协程的方法，可以看官网都有
Dispatchers.Main：是个调度器，是个枚举，里面有几个调度器类型，Main这个就认为把网络请求到的数据切换到主线程就可以啦
这里的try{ }catch()：暂时先不看，在后面会讲到

在IO线程请求网络

    suspend fun getXXData() =withContext(Dispatchers.IO) {
                                    requestData()
             }

这里需要了解的是：

suspend：吊起了，才能有更多的主动性的操作。
withcontext()：协程内，切换到指定的上下文
Dispatchers.IO：跟上面那个Main调度器一个妈生的

将回调转换成协程的挂起函数

    suspend fun requestData() : String =suspendCancellableCoroutine { continuation ->
        //获取当前协程实例
        ServiceBuilder.weatherService.getWeathers().enqueue(object : Callback<String> {
            override fun onFailure(call: Call<String>, t: Throwable) {
                continuation.resumeWithException(t)
            }

            override fun onResponse(call: Call<String>, response: Response<String>?) {
                 val body =response.body()

                if (body != null){
                    continuation.resume(body)//这看看源码也能大概知道什么意思，还有个resumeWith也可以了解一下
                }else{
                    continuation.resumeWithException(NullPointerException("Response Body is Null : $response"))
                }


            }
        })
}

这里估计理解的比较累点：

enqueue()：这个可以不用看了，你肯定懂的
suspendCancellableCoroutine{ continuation ->}：获取当前协程的实例，关键就在这，我们获取到了当前的实例，那么能做什么呢？
resumeWithException：放下协程了，不吊他了，但会抛出异常（这相当于观察者模式的错误回调）
resume：恢复协程，放下协程了，告诉协程，我是成功的（这相当于观察者模式的成功回调）

成功或者错误的回调都在第一步的try{ } catch( )注释中，通过协程的主动挂起和恢复协程，把回调地狱给解决了，🐂🍺

当然这只是个简单的讲协程的例子，例子中很多代码都还可以处理，比如：

loadingView的统一处理
请求网络方法的封装（写出扩展函数，网上一大堆）
取消网络请求等等

想要具体用好协程API，还需对协程更深入的了解。小弟表示，我只会简单的用用。等了解透了，再分享给大家，谢谢大家，么么哒