在微信登录时会遇到着这样的问题，获取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，直接用的话，请求不成功，这个需要注意。
网友评论