前言

在去年最火的无疑是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插件生成

下面看下具体实现情况（注：这里取书籍的副标题，可能为空）：