跳到主要内容

RetryUtil 重试工具

📦 包路径：top.csaf.thread.RetryUtil

🔗 所属模块：zutil-all

RetryUtil是基于 Resilience4j Retry 的轻量封装，提供了统一的重试配置与执行入口，重点处理了以下问题：

  • 固定间隔或自定义策略重试
  • 异常重试与结果重试
  • 线程中断语义保护（InterruptedException默认不重试）
  • 受检异常包装与 API 简化

✨ 核心特性​

  • 默认配置安全：默认忽略InterruptedException，避免中断被重复重试吞掉。
  • 统一执行入口：支持Callable、Supplier、Runnable。
  • 名称规范化：空白名称自动回退到默认名RetryUtil。
  • 条件化重试：支持按异常类型、结果值、间隔函数组合策略。
  • 类型化结果谓词：提供Class<T> + Predicate<? super T>重载，避免结果类型不匹配时抛出转换异常。

🚀 常用方法概览​

1. 配置方法​

方法说明
config(int maxAttempts, long waitMillis)固定间隔配置。要求maxAttempts > 0、waitMillis >= 0。
config(int, IntervalFunction, Predicate<Throwable>, Predicate<?>)自定义间隔、异常谓词、结果谓词。
config(int, IntervalFunction, Predicate<Throwable>, Class<T>, Predicate<? super T>)类型化结果谓词配置。null结果固定不重试。

2. 执行方法​

方法说明
retry(String name, RetryConfig config)创建Retry实例；config == null时使用内置默认配置。
execute(String name, RetryConfig config, Callable<T> callable)直接按名称+配置执行。
execute(Retry retry, Callable<T> callable)按Retry实例执行。
executeSupplier(Retry retry, Supplier<T> supplier)执行无受检异常任务。
run(Retry retry, Runnable runnable)执行无返回值任务。

🧪 使用示例​

1. 固定间隔 + 异常重试​

RetryConfig config = RetryUtil.config(3, 200L);
Retry retry = RetryUtil.retry("http-call", config);

String result = RetryUtil.execute(retry, () -> {
  // 前两次抛异常，第三次成功
  return remoteCall();
});

2. 结果重试（返回值不满足时重试）​

IntervalFunction interval = attempt -> 100L;
RetryConfig config = RetryUtil.config(
  3,
  interval,
  null,
  result -> result == null
);

String value = RetryUtil.execute(RetryUtil.retry("result-retry", config), () -> fetchMaybeNull());

3. 类型化结果谓词​

IntervalFunction interval = attempt -> 0L;
RetryConfig config = RetryUtil.config(
  3,
  interval,
  null,
  String.class,
  String::isEmpty
);

String value = RetryUtil.execute(RetryUtil.retry("typed", config), () -> "");

行为说明：

  • 返回值是String且满足String::isEmpty时会重试
  • 返回值类型不匹配时不会重试（不会抛ClassCastException）
  • 返回值为null时不会重试

⚠️ 异常与中断语义​

1. 中断异常处理​

  • 默认配置已忽略InterruptedException重试
  • 执行层捕获InterruptedException后会调用Thread.currentThread().interrupt()恢复中断标记，再抛出RuntimeException

2. 异常透传与包装​

  • 运行时异常：保持原异常类型向外抛出
  • 受检异常：包装为RuntimeException（cause保留原始异常）

📏 参数约束​

-maxAttempts必须大于0 -waitMillis必须大于等于0

  • 自定义配置时intervalFunction不能为空
  • 类型化重载中：当retryOnResult != null时，resultType不能为空