西部数码主机 | 阿里云主机| 虚拟主机 | 服务器 | 返回乐道官网

使用RxJava优雅的处理服务器返回异常

时间:2016-01-19 13:49来源:未知 作者:好模板 点击:
实际开发经常有这种情况,比如登录请求,返回来的并不会仅仅是User对象,而是被包装的RESTResultUser对象,RESTResult对象里,包括请求返回的状态:失败还是成功,错误码,User对象等等

实际开发经常有这种情况,比如登录请求,返回来的并不会仅仅是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种处理方案,“优雅度”逐个提高:)
方案1:

    _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里处理,这样并不合适。
判断RESTResult的部分更应该放在链式操作里,我们需要炫酷的Rx操作符!

方案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操作符可以使你提供一个指定的测试数据项,只有通过测试的数据才会被“发射”;
map操作符可以返回一个新的数据类型的observable对象,在该例中,把Observable<RESTResult>转换为Observable<User>。

这个方案表实现了链式操作,但仍然有2个问题:
1、对于服务器返回status=FAILURE的异常的情况下,观察者并“不知情”,因为filter过滤掉该数据源,观察者并不能接受到任何数据源;
2、对于服务器返回status=FAILURE的异常的情况下,提示用户异常信息、隐藏提示框等操作需要在filter里自行处理。

这个方案也不是很完美,接下来看下方案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):

Returns an Observable that invokes an Observer's onError method when the Observer subscribes to it.

该方法是返回一个Observable,当观察者订阅时,执行观察者的onError方法。

这个方案完美的解决了方案1、2的问题:
1、观察者拿到“加工”完成的数据源;
2、异常方面,不管是服务器异常还是其他异常情况,最终观察者都可以接收到异常数据源,并最终统一在onError里处理。
3、使用flatMap处理RESTResult部分的代码,可以放在IO线程处理

最后:
通过RxJava的链式操作,结合恰当的操作符,不仅可以把正常的数据源发射给观察者,同时也可以将错误异常数据源发射给观察者,RxJava远比想象中的强大!

第3个方案是目前我能想到的最合适的方案,也是在我实际项目中使用的方案,如果还有更好的解决方案,欢迎告诉我哈

(责任编辑:好模板)
顶一下
(4)
100%
踩一下
(0)
0%
------分隔线----------------------------
栏目列表
热点内容