Rxjava和Retrofit返回数据解析问题 Android

一、前言：在我们数据请求过程中，采用的接口请求，Observable返回数据。我们定义的返回数据都是Json数据。
通过Dagger2配置：

@Module public class RetrofitModule { private int CONNECT_TIMEOUT = 3; private int READ_TIMEOUT = 3; private int WRITE_TIMEOUT = 3; /** * 添加应用拦截器interceptor * @param interceptor * @return */ @Singleton @Provides public OkHttpClient provideOkHttpClient(HttpInterceptor interceptor){ HttpLoggingInterceptor httpLoggingInterceptor = new HttpLoggingInterceptor(); httpLoggingInterceptor.setLevel(HttpLoggingInterceptor.Level.BODY); return new OkHttpClient.Builder(). connectTimeout(CONNECT_TIMEOUT, TimeUnit.SECONDS). readTimeout(READ_TIMEOUT, TimeUnit.SECONDS). writeTimeout(WRITE_TIMEOUT, TimeUnit.SECONDS). //添加拦截器 addInterceptor(interceptor). retryOnConnectionFailure(true). build(); } @Singleton @Provides public Retrofit provideRetrofit(OkHttpClient okHttpClient){ return new Retrofit.Builder() .baseUrl(BuildConfig.BASE_URL) .client(okHttpClient) //添加数据解析 .addConverterFactory(GsonConverterFactory.create()) //支持RXJava返回 .addCallAdapterFactory(RxJava2CallAdapterFactory.create()) .build(); } }

下面看问题啊。

文章图片

/** * 发送短信 */ public Observable sendMsg(String mobile) { return apiService.sendMsg(mobile); }

【Rxjava和Retrofit返回数据解析问题】看问题：接受数据定义为ResponseBody，可以看到返回的数据不是Json样式，也无法进行解析。
二、解决问题解决思路：若是不想定义接受对象Bean，就可以定义为JSONObject数据，一定不要定义为ResponseBody。强烈建议定义为Bean，就算定义为JSONObject，你还是要转化为Bean对象的。
1. 网络发起请求

@Override public void sendMsg(String phone) { //View是否绑定如果没有绑定，就不执行网络请求 if (!isViewAttached()) { return; } suManHttpService.sendMsg(phone).compose(RxSchedulers.compose()).subscribe(new HttpResponseObserver() { @Override public void success(Object object) { JSONObject jsonObject = (JSONObject) object; String msg = (String) jsonObject.getString("msg"); String code = (String) jsonObject.getString("code"); Log.d("LUO", code+"================" + msg); } @Override public void error(int code, String message) { Log.d("LUO","code==================="+code+"============="+message); } }); }