一、前言：

1.        retrofit嵌套请求

在实际开发中，可能会存在：需要先请求A接口，在请求B接口的情况，比如进入“玩android”网页请求获取收藏文章列表，但是需要先登录拿到Cookie才能请求搜藏文章几口，此时请求就有了先后顺序，为了完成该功能，我们需要这样实现代码。

代码显得就很冗杂。

2.Retrofit适配器

Retrofit的接口返回的方法必须是Call，如果能够将Call改为RxJava的Observable。对于嵌套而言就得到了非常方便的解决，这就是适配器的功能。如果我们想要返回的不是Call适配器就能帮助我们转换为其他类型。

3.添加依赖：

    implementation 'com.squareup.retrofit2:adapter-rxjava3:2.9.0'

如果是Android开发还需要引入

    implementation 'io.reactivex.rxjava3:rxandroid:3.0.0'

二、代码实现

1.创建接口类对象

public interface WanAndroidService2 {/*** 学习Retrofit嵌套请求与适配器* 登录接口* @param username* @param pwd* @return*/@POST("user/login")@FormUrlEncodedFlowable<BaseResponse> login2(@Field("username") String username, @Field("password") String pwd);/*** 学习Retrofit嵌套请求与适配器* 获取收藏文章列表* @return*/@GET("lg/collect/list/{pageNum}/json")Flowable<ResponseBody> getArticle(@Path("pageNum") int pageNum);
}

2.代码实现

public class WanAndroidUnitTest {/*** 学习Retrofit嵌套请求与适配器*/Map<String,List<Cookie>> cookies = new HashMap<>();//全局变量接收cookieRetrofit retrofit3 = new Retrofit.Builder().baseUrl("https://www.wanandroid.com/").callFactory((okhttp3.Call.Factory) new OkHttpClient.Builder().cookieJar(new CookieJar() {@Overridepublic void saveFromResponse(@NonNull HttpUrl httpUrl, @NonNull List<Cookie> list) {cookies.put(httpUrl.host(),list);}@NonNull@Overridepublic List<Cookie> loadForRequest(@NonNull HttpUrl httpUrl) {List<Cookie> cookies = WanAndroidUnitTest.this.cookies.get(httpUrl.host());return cookies == null ? new ArrayList<>() :cookies;}}).build()).addConverterFactory(GsonConverterFactory.create())//添加转换器.addCallAdapterFactory(RxJava3CallAdapterFactory.create())//添加适配器.build();//创建retrofit对象WanAndroidService2 wanAndroidService3 = retrofit3.create(WanAndroidService2.class);//创建接口类对象，并且设置为全局变量。@Testpublic void rxjavaText(){//切换线程，如果是android请求的话必须把网络请求切换到一个子线程//把观察的回调切换到android的主线程，现在在java环境中。如果是在android环境中就需要把subscribeOn(Schedulers.newThread())换成.subscribeOn(AndroidSchedulers.mainThread())  。使得我们接口的回调是在主线程              .subscribeOn(AndroidSchedulers.mainThread())wanAndroidService3.login2("Anglin","rssqzqyp").flatMap(new Function<BaseResponse, Publisher<ResponseBody>>() {@Overridepublic Publisher<ResponseBody> apply(BaseResponse baseResponse) throws Throwable {return wanAndroidService3.getArticle(0);}}).observeOn(Schedulers.io()).subscribeOn(AndroidSchedulers.mainThread()).subscribe(new Consumer<ResponseBody>() {@Overridepublic void accept(ResponseBody responseBody) throws Throwable {System.out.println(responseBody.string());}});while (true){}}
}