美文网首页MVPretrofit2
RxJava+Retrofit+MVP封装(一)

RxJava+Retrofit+MVP封装(一)

作者: kgxl | 来源:发表于2017-10-20 15:45 被阅读0次

    前言

    在去年最火的无疑是RxJava+Retrofit这对组合了,出去说自己不会都不好意思,在去年的时候就看过RxJava和Retrofit,但是那时候看着这两个玩意一脸懵比,特别是初次看到RxJava的时候觉得这个学着好困难,看了些文章跟着写了写(然并卵),随便写个啥请求都要撸一大串代码,感觉没有传说的那么神奇,但是结合上Retrofit后简直不要太叼(鸟枪换炮),如果对于这对组合没什么了解的话没关系,这里推荐两篇非常不错的文章:

    扔物线大神写的:《给 Android 开发者的 RxJava 详解》

    个人比较喜欢的:www.jianshu.com/u/c50b715ccaeb

    看完这两个基本上就对RxJava和Retrofit算是有个基本的了解,下面简单使用下RxJava和Retrofit

    RxJava+Retrofit进行网络请求

    1.添加依赖。
    注意:converter-gson,adapter-rxjava2需要与retrofit版本一样

        compile'io.reactivex.rxjava2:rxjava:2.1.0' 
        compile'io.reactivex.rxjava2:rxandroid:2.0.1'
        compile'com.squareup.retrofit2:retrofit:2.2.0'  //retrofit依赖
        compile'com.squareup.retrofit2:converter-gson:2.2.0'  //gson
        compile'com.squareup.retrofit2:adapter-rxjava2:2.2.0'  //让retrofit能被rxjava使用      
    

    2.写一个API请求

        public interface Api {
          //查询书本
          @GET("v2/book/search")
          Observable<Book> searchBook(@Query("q") String bookName);
         }
    

    这里返回的是一个Observable类型,Book就是这个Observable的泛型也就是实体类,这样就能被RxJava使用,作为被观察者

    3.创建一个Retrofit进行请求

    //初始化Okhttp
    mOkHttpClient = new OkHttpClient.Builder()
                              .retryOnConnectionFailure(true)
                              .connectTimeout(30, TimeUnit.SECONDS)
                              .writeTimeout(20, TimeUnit.SECONDS)
                              .readTimeout(20, TimeUnit.SECONDS)
                              .build();
    
    Retrofit retrofit = new Retrofit.Builder()
                  .baseUrl("https://api.douban.com/")
                  .client(mOkHttpClient)
                  .addCallAdapterFactory(RxJava2CallAdapterFactory.create()) //支持RxJava
                  .addConverterFactory(GsonConverterFactory.create()) //gson解析
                  .build();
    Api api=retrofit.create(Book.class);
    api.searchBook("西游记").subscribeOn(Schedulers.io()) //在io线程进行请求
                      .observeOn(AndroidSchedulers.mainThread())  //在主线程操作返回结果
                      .unsubscribeOn(Schedulers.io())
                      .subscribe(new Observer<Book>() {
                          @Override
                          public void onSubscribe(@NonNull Disposable d) {
    
                          }
    
                          @Override
                          public void onNext(@NonNull Book book) {
                             //请求成功
                          }
    
                          @Override
                          public void onError(@NonNull Throwable e) {
                             //请求失败
                          }
    
                          @Override
                          public void onComplete() {
    
                          }
                      });
    

    Book类是使用GsonFormat插件生成

    下面看下具体实现情况(:这里取书籍的副标题,可能为空):

    request.gif

      到这里也算是跑了一遍RxJava和Retrofit的流程,是不是觉得有点意思,结构清晰明了,but细心的朋友会发现很多能优化的地方,比如:

    • 每次请求都写一串代码创建Retrofit
    • 每次订阅Observable时都有一大串重写的方法,然而我们只关心请求成功与否和请求成功后返回的数据
    • 每次都需要设置ObserableObserver在哪个线程里工作
    • 如果请求未完成但是界面却退出了就会存在内存泄漏的风险
    • 每次请求添加公共参数(例如设备号,版本信息等等)

    MVP

    MVP

    这简单说说我对MVP的理解:

    • Model:对数据进行操作(网络请求,数据库存储,取本地数据等等)

    • View:对UI进行操作

    • Presenter:处理逻辑代码,并且负责View和Model交互

    简单来说就是M层得到数据后,交给P层去处理一些逻辑,然后由P层把处理过的数据给V层去显示,这样一来V层和M层就没有关联了,也算是很大程度上解耦,也推荐下相关的MVP资料:

    鸿洋大神的:http://blog.csdn.net/lmj623565791/article/details/46596109

    google的:https://github.com/googlesamples/android-architecture/tree/todo-mvp/

    这次就先简单使用下并且看清需要优化地方,明天周末,祝大家周末愉快,下次就是对RxJava+Retrofit+MVP封装。

    RxJava+Retrofit+MVP封装(一)

    RxJava+Retrofit+MVP封装(二)

    RxJava+Retrofit+MVP封装(三)

    相关文章

      网友评论

        本文标题:RxJava+Retrofit+MVP封装(一)

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