将开源的重试工具进行简单封装为小工具，方便使用。
引入jar包
在pom中引入如下的包
<dependency>
<groupId>com.github.rholder</groupId>
<artifactId>guava-retrying</artifactId>
<version>2.0.0</version>
</dependency>
编码
package com.gongsi.aos.tmp.utils;
import com.github.rholder.retry.*;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.TimeUnit;
import java.util.function.Predicate;
/**
* @author jingzhongzhi
* @since 2020/7/29
*/
public class RetryUtils<V> {
private static final Logger log = LoggerFactory.getLogger(RetryUtils.class);
/**
* 重试等待时间
*/
public static final int RETRY_SLEEP_TIME = 100;
/**
* 重试次数
*/
public static final int RETRY_ATTEMPT_TIMES = 3;
/**
* 重试操作
*
* @param retryIfResult 如果该参数指定结果为 true，则会继续重试，否则结束重复返回值
* @param callable 执行重试的业务逻辑处理
* @return 重试后的结果
*/
public static <V> V retry(Predicate<V> retryIfResult, Callable<V> callable) {
return retry(retryIfResult, callable,TimeUnit.MILLISECONDS.toMillis(RETRY_SLEEP_TIME));
}
/**
* 重试操作
*
* @param retryIfResult 如果该参数指定结果为 true，则会继续重试，否则结束重复返回值
* @param callable 执行重试的业务逻辑处理
* @param maxWaitTimeInMill 重试最大等待时间
* @return 重试后的结果
*/
public static <V> V retry(Predicate<V> retryIfResult, Callable<V> callable, long maxWaitTimeInMill ) {
Retryer<V> retryer = RetryerBuilder.<V>newBuilder()
.retryIfResult(retryIfResult::test)
.retryIfException()
.withWaitStrategy(WaitStrategies.randomWait(maxWaitTimeInMill, TimeUnit.MILLISECONDS))
.withStopStrategy(StopStrategies.stopAfterAttempt(RETRY_ATTEMPT_TIMES))
.build();
try {
return retryer.call(callable);
} catch (ExecutionException | RetryException e) {
log.info("重试执行异常", e);
}
return null;
}
}
将常用的功能和重试策略等封装为工具，避免每次使用都重新new Retryer的builder代码，提高代码复用。
使用示例
Object retry = RetryUtils.retry(Objects::nonNull, (Callable<Object>) () -> "执行重试任务", MAX_WAIT_TIME_IN_MILL);
