美文网首页kotlin
Retrofit搭配协程,真香耶!

Retrofit搭配协程,真香耶!

作者: Natchi | 来源:发表于2019-09-29 09:45 被阅读0次

    为什么你需要用协程?

    1. Kotlin推出了协程,但Java没有(只有某些框架有这个概念)
    2. 告别回调地狱(提高代码的可读性)
    3. 面试需要(别逼无奈) :)
    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,还需对协程更深入的了解。小弟表示,我只会简单的用用。等了解透了,再分享给大家,谢谢大家,么么哒

    相关文章

      网友评论

        本文标题:Retrofit搭配协程,真香耶!

        本文链接:https://www.haomeiwen.com/subject/uxeoectx.html