实际开发经常有这种情况,比如登录请求,返回来的并不会仅仅是User对象,而是被包装的RESTResult<User>对象,RESTResult对象里,包括请求返回的状态:失败还是成功,错误码,User对象等等。 public class RESTResult<T> { public static final int FAILURE = 0; // 失败 public static final int SUCCESS = 1; // 成功 private int status; // 返回状态:0 失败 1 成功 private HttpResponseCode code; // 错误码 private String message; // 返回信息 private T data; // 包装的对象 // 其他省略 .... 在使用Retrofit+RxJava的情况下,以登录为例,ApiService如下: public interface ApiService { @FormUrlEncoded @POST(API + "account/login") Observable<RESTResult<User>> login(@Field("mobile") String mobile, @Field("code") String code); } 我们对于登录返回的结果会这样处理:如果status为SUCCESS,则获取到User对象并进行后续操作;如果status为FAILURE,则需要根据code或者message提示用户相应的错误提示,并隐藏进度条对话框等操作。
我这里给出3种处理方案,“优雅度”逐个提高:) _apiService.login(mobile, verifyCode) .subscribeOn(Schedulers.io()) .doOnSubscribe(() -> showLodingDialog("登录中...")) .subscribeOn(AndroidSchedulers.mainThread()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(new Observer<RESTResult<User>>() { @Override public void onCompleted() { hideLoadingDialog(); } @Override public void onError(Throwable e) { e.printStackTrace(); hideLoadingDialog(); Toast.makeText(_context, "请求失败,请稍后重试", Toast.LENGTH_SHORT).show(); } @Override public void onNext(RESTResult<User> result) { if (result.getStatus() == RESTResult.FAILURE) { HttpResponseCode code = result.getCode(); // 根据不同code进行不同处理 ... Toast.makeText(_context, result.getMessage(), Toast.LENGTH_SHORT).show(); } else { User user = result.getData(); ... } } });
显然这个方案有太多缺点,RxJava建议在subscribe的时候,观察者应该拿到的是加工完成的数据源,而不是未加工的数据源;而且在服务器返回status=FAILURE的情况下,异常是在onNext里处理,这样并不合适。 方案2 - 使用filter+map操作符: _apiService.login(mobile, verifyCode) .// 略 显示提示框、切换线程 .filter(result -> { if (result.getStatus() == RESTResult.FAILURE) { HttpResponseCode code = result.getCode(); // 根据不同code进行不同处理 ... Toast.makeText(_context, result.getMessage(), Toast.LENGTH_SHORT).show(); hideLoadingDialog(); return false; } return true; }) .map(result -> result.getData()) .subscribe(new Observer<User>() { @Override public void onCompleted() { hideLoadingDialog(); } @Override public void onError(Throwable e) { e.printStackTrace(); hideLoadingDialog(); Toast.makeText(_context, "请求失败,请稍后重试", Toast.LENGTH_SHORT).show(); } @Override public void onNext(User user) { // 直接是User对象 } });
在这个方案里,我们用了filter操作符+map操作符,filter操作符可以使你提供一个指定的测试数据项,只有通过测试的数据才会被“发射”;
这个方案表实现了链式操作,但仍然有2个问题: 这个方案也不是很完美,接下来看下方案3。 方案3 - 使用Observable.error(e): _apiService.login(mobile, verifyCode) .// 略 显示提示框、切换线程 .flatMap(result -> { // 可以运行在IO线程 if (result.getStatus() == RESTResult.FAILURE) { HttpResponseCode code = result.getCode(); // 根据不同code进行不同处理 ... return Observable.error(new ServerException(result.getMessage())); } return Observable.just(result.getData()); }) .subscribe(new Observer<User>() { @Override public void onCompleted() { hideLoadingDialog(); } @Override public void onError(Throwable e) { e.printStackTrace(); hideLoadingDialog(); if(e instanceof ServerException){ Toast.makeText(_context, e.getMessage(), Toast.LENGTH_SHORT).show(); }else{ Toast.makeText(_context, "请求失败,请稍后重试", Toast.LENGTH_SHORT).show(); } } @Override public void onNext(User user) { // 直接是User对象 } }); flaMap操作符可以接收一个Observable的输出作为输入,同时输出另外一个Observable。在服务器返回status=FAILURE的情况下,返回Observable.error(Throwable exception),SUCCESS的话,just源数据为一个新的Observable返回。 Observable.error(Throwable exception):
该方法是返回一个Observable,当观察者订阅时,执行观察者的onError方法。
这个方案完美的解决了方案1、2的问题:
最后: 第3个方案是目前我能想到的最合适的方案,也是在我实际项目中使用的方案,如果还有更好的解决方案,欢迎告诉我哈 (责任编辑:好模板) |