RxJava retryWhen操作符实现错误重试机制

发布时间：2020-12-13 21:08:53 所属栏目：PHP教程来源：网络整理

导读：业务需求当我们在app里发起网络要求时，可能会由于各种问题致使失败。如何利用RxJava来实现出现毛病后重试若干次，并且可以设定重试的时间间隔。具体实现网络要求使用Retrofit来做，还是使用上篇博客中的要求用户信息接口 @ GET("/userinfo?noToken=1")

业务需求

当我们在app里发起网络要求时，可能会由于各种问题致使失败。如何利用RxJava来实现出现毛病后重试若干次，并且可以设定重试的时间间隔。

具体实现

网络要求使用Retrofit来做，还是使用上篇博客中的要求用户信息接口

    @GET("/userinfo?noToken=1")
    Observable<Response> getUserInfoNoToken();

下面是要求用户信息接口的逻辑代码

userApi.getUserInfoNoToken()
                        //总共重试3次，重试间隔3000毫秒
                        .retryWhen(new RetryWithDelay(3,3000))
                        .observeOn(AndroidSchedulers.mainThread())
                        .subscribeOn(Schedulers.io())
                        .subscribe(new Action1<Response>() {
                            @Override
                            public void call(Response response) {
                                String content = new String(((TypedByteArray) response.getBody()).getBytes());
                                printLog(tvLogs,"",content);
                            }
                        },new Action1<Throwable>() {
                            @Override
                            public void call(Throwable throwable) {
                                throwable.printStackTrace();
                            }
                        });

RetryWithDelay

public class RetryWithDelay implements
            Func1<Observable<? extends Throwable>,Observable<?>> {

        private final int maxRetries;
        private final int retryDelayMillis;
        private int retryCount;

        public RetryWithDelay(int maxRetries,int retryDelayMillis) {
            this.maxRetries = maxRetries;
            this.retryDelayMillis = retryDelayMillis;
        }

        @Override
        public Observable<?> call(Observable<? extends Throwable> attempts) {
            return attempts
                    .flatMap(new Func1<Throwable,Observable<?>>() {
                        @Override
                        public Observable<?> call(Throwable throwable) {
                            if (++retryCount <= maxRetries) {
                                // When this Observable calls onNext,the original Observable will be retried (i.e. re-subscribed).
                                printLog(tvLogs,"get error,it will try after " + retryDelayMillis
                                        + " millisecond,retry count " + retryCount);
                                return Observable.timer(retryDelayMillis,TimeUnit.MILLISECONDS);
                            }
                            // Max retries hit. Just pass the error along.
                            return Observable.error(throwable);
                        }
                    });
        }
    }

如何摹拟重试呢？

方法1：把服务器关闭，关闭服务器后，客户端要求接口的必定会报错，看看是否是重试3次。

运行输出：

'get error,it will try after 3000 millisecond,retry count 1'
Main Thread:false,Thread Name:Retrofit-Idle

'get error,retry count 2'
Main Thread:false,retry count 3'
Main Thread:false,Thread Name:Retrofit-Idle

上面是重试3次了，但是我们怎样知道，如果在服务器启动后，在接下的重试中要求成功呢？接下来试试方法2。

方法2：先把服务器关闭，当点击按钮要求的同时，启动Tomcat服务器。

运行输出：

'get error,Thread Name:Retrofit-Idle

'username:chiclaim,age:007'
Main Thread:true,Thread Name:main

可以发现，在第3次重试的时候，服务器可用了。

github源码下载

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!