Retrotif2 + RxJava发送POST请求失败
Retrotif2 + RxJava发送POST请求失败
提问于 2018-08-24 18:37:56
我想用Retrofit + RxJava发送POST请求，但它失败了，我不知道原因。在一个活动中，它在工作，在另一个活动中--不想工作：
private void sendMerchantInfo() {
try {
String advertiserOriginalDeepLink = "https://mywebsite.com/main-1?param1=value1¶m2=value2";
String urlGetParams = LinkParser.getUrlGETParams(advertiserOriginalDeepLink);
Map<Object, Object> merchantInfo = LinkParser.parseUrlGetParams(urlGetParams);
String merchantInfoJson = new Gson().toJson(merchantInfo); //{"param1":"value1","param2":"value2"}
String url = "https://api.endpoint.com/v1/system/merchant/process";
userService = this.serviceGenerator.createService(UserService.class, true);
final Observable observable = userService.sendUserInfo(
url, new RetrofitMapBody(merchantInfo))
.doOnNext(new Consumer<ResponseBody>() {
@Override
public void accept(ResponseBody responseBody) throws Exception {
//handle 200 OK.
}
})
.onErrorResumeNext((ObservableSource<? extends ResponseBody>) v ->
Crashlytics.log("Send user info attempt failed."))
.subscribeOn(Schedulers.from(threadExecutor))
.observeOn(postExecutionThread.getScheduler());
addDisposable(observable.subscribe());
}
} catch (Exception exception) {
Crashlytics.log("Send user info attempt failed. " + exception.getMessage());
}
}我怀疑这部分的问题，我尝试在OnCreate()方法中发送请求：
.subscribeOn(Schedulers.from(threadExecutor))
.observeOn(postExecutionThread.getScheduler());尝试使用此命令，但没有效果：
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread());我做错了什么？它总是调用onErrorResumeNext()，这可能与线程有关，因为有一次我得到了异常：networkonmainthreadexception。请帮帮忙。
回答 1
Stack Overflow用户
回答已采纳
发布于 2018-08-26 03:09:37
试着用RxJava2 Adapter，它会帮你省很多钱！
第1步：改装客户端设置
private Retrofit getRetrofitClient() {
return new Retrofit.Builder()
.baseUrl(BASE_URL)
.addConverterFactory(GsonConverterFactory.create())
.addCallAdapterFactory(RxJava2CallAdapterFactory.create()) //option 1
.addCallAdapterFactory(RxJava2CallAdapterFactory.createWithScheduler(Schedulers.newThread())) //option 2
.build();
}第2步： APIService接口(示例)
@GET("endpoint")
Single<ResponseModel> fetch();第3步：使用
Single<ResponseModel> fetch() {
return getRetrofitClient()
.create(APIService.class)
.fetch();
}- 任何非2xx HTTP响应都将被包装在
HttpException中，您可以从中提取状态代码，状态消息和完整的HTTP HTTP连接错误将被包装在IOException
中
这就是将网络调用包装在任何RxJava流中所需做的全部工作。
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/52002672
复制相关文章
相似问题