如何落地一款重试组件（下）

<dependency>
    <groupId>com.github.rholder</groupId>
    <artifactId>guava-retrying</artifactId>
    <version>2.0.0</version>
</dependency>
复制代码

package org.idea.qiyu.framework.retry.guava;
import com.github.rholder.retry.*;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.TimeUnit;
/**
 * @Author linhao
 * @Date created in 9:18 上午 2021/10/4
 */
public class Application {
    static class ResponseInfo {
        int code;
        public int getCode() {
            return code;
        }
        public void setCode(int code) {
            this.code = code;
        }
        public ResponseInfo() {
        }
        public static ResponseInfo buildSuccess(){
            ResponseInfo responseInfo = new ResponseInfo();
            responseInfo.setCode(1);
            return responseInfo;
        }
    }
    public static void main(String[] args) throws ExecutionException, RetryException {
        Callable<ResponseInfo> callable = new Callable<ResponseInfo>() {
            @Override
            public ResponseInfo call() throws Exception {
                System.out.println("call ...");
                return ResponseInfo.buildSuccess();
            }
        };
        Retryer<ResponseInfo> retryer = RetryerBuilder.<ResponseInfo>newBuilder()
                .retryIfResult(expectResult-> expectResult.getCode()==1)
                .retryIfException()
                .withStopStrategy(StopStrategies.stopAfterAttempt(3))
                .withWaitStrategy(WaitStrategies.fixedWait(1, TimeUnit.SECONDS))
                .withRetryListener(new MyRetryListener())
                .build();
        retryer.call(callable);
    }
}
复制代码

package org.idea.qiyu.framework.retry.guava;
import com.github.rholder.retry.Attempt;
import com.github.rholder.retry.RetryListener;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
 * @Author linhao
 * @Date created in 9:35 上午 2021/10/4
 */
public class MyRetryListener implements RetryListener {
    private static final Logger LOGGER = LoggerFactory.getLogger(MyRetryListener.class);
    @Override
    public <V> void onRetry(Attempt<V> attempt) {
        // 第几次重试(注意:第一次重试其实是第一次调用)
        System.out.printf("retry time : %s \n", attempt.getAttemptNumber());
        // 距离第一次重试的延迟
        System.out.printf("retry delay : %s  \n", attempt.getDelaySinceFirstAttempt());
        // 是否因异常终止
        if (attempt.hasException()) {
            System.out.printf("causeBy: %s  \n", attempt.getExceptionCause());
        }
        // 正常返回时的结果
        if (attempt.hasResult()) {
            System.out.printf("result=%s  \n", attempt.getResult());
        }
    }
}
复制代码