Rxjava Retrofit okhttp 依次执行多个请求

在微信登录时会遇到着这样的问题，获取access_token，获取用户信息userinfo，然后拿着获取到的用户信息去执行自己的的登录。三个请求都是拿着上一个请求的结果去执行请求，如果分开写，过于麻烦。Rxjava Retrofit 可以很好的解决这个问题。

废话不多说，直接上代码：

三个api

WxApi.class的内容

@GET("https://api.weixin.qq.com/sns/oauth2/access_token")

public  Observable getToken(@Query("appid") String appid,

                                                @Query("secret") String secret,

                                                @Query("code") String code,

                                                @Query("grant_type") String grant_type);

@GET("https://api.weixin.qq.com/sns/userinfo")

public Observable getUseInfo(@Query("access_token") String access_token,

                                                @Query("openid") String openid);

                                                @FormUrlEncoded

@POST("http://api.dev.myapi.cn/login/wx/")

Observable MyLogin(@Field(encoded =true,value ="userinfo") String userinfo);

下面是请求逻辑代码：

 Retrofit.Builder retrofit =newRetrofit.Builder()

.addCallAdapterFactory(RxJavaCallAdapterFactory.create())

.addConverterFactory(StringConverterFactory.create())    //添加了一个String转换器，因为这个过程string用着比较方便

.baseUrl("https://api.weixin.qq.com/sns/");    //添加baseUrl，api中又写全了为什么呢，后面会讲

OkHttpClient.Builder mBuilder =newOkHttpClient.Builder();//用okhttp去请求

HttpLoggingInterceptor loggingInterceptor =newHttpLoggingInterceptor();    //请求日志

loggingInterceptor.setLevel(HttpLoggingInterceptor.Level.BODY);

mBuilder.addInterceptor(loggingInterceptor);

finalWxApi api = retrofit.client(mBuilder.build()).build().create(WxApi.class);

Observable observable = api.getToken(AppConstant.WX_APP_ID, AppConstant.WX_APP_SECRET, code,"authorization_code");

observable

                   .subscribeOn(Schedulers.io())

                    .observeOn(Schedulers.io())//设定第一次请求结果放在io线程并同时执行第二次                       请求

                    .flatMap(newFunc1<String,Observable<String>>() {

                    @Override

                    publicObservable call(String s) {

                            //拿到第一次请求结果，从string中取到access_token和 openid

                            //执行第二次请求

                            return api.getUseInfo(access_token, openid);

                    }

                    })

                    .observeOn(Schedulers.io())//设定第三次请求结果放在io线程并同时执行次                              自己的登录请求

                    .flatMap(newFunc1<String,Observable<String>>() {

                            @Override

                            publicObservable call(String s) {

                                    //拿到微信返回的用户信息去执行自己服务端的登录请求

                                     return api.MyLogin(s);

                            }

                    })

                    .observeOn(AndroidSchedulers.mainThread())

                    .subscribe(newBaseObserver() {

                     @Override

                    public void onNext(String s) {

                             super.onNext(s);

                            //自己的登录请求结果

                    }

                    @Override

                    public void onCompleted() {

                                super.onCompleted();

                    }

                    });

以上就是三次请求依次执行的逻辑代码，犹豫微信登录与自己api登录的baseUrl不一样，所以在设定baseUrl的同时，api用的是全部的url地址，当在WxApi设定全部的url地址时可以覆盖baseUrl，但如果不设定baseUrl，直接用的话，请求不成功，这个需要注意。