Retrofit搭配协程,真香耶!

1,658 阅读4分钟

为什么你需要用协程?

  1. Kotlin推出了协程,但Java没有(只有某些框架有这个概念)
  2. 告别回调地狱(提高代码的可读性)
  3. 面试需要(被逼无奈) :)

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

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

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

import kotlinx.coroutines.*

fun main() {
    GlobalScope.launch { 
            
    }
}

这就是传说中的协程,skr

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

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

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

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

单纯一个函数一个函数的讲,那我也讲不完,我也讲不清啊,那下面,我简单的讲下,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,还需对协程更深入的了解。小弟表示,我只会简单的用用。等了解透了,再分享给大家,谢谢大家,么么哒