Java Akka Classic API中Duration.Inf()不存在 最大Duration取值是多少

问题背景 #

使用Akka Java Classic版本实现容错SupervisorStrategy时，官方给出的基础代码示例如下：

private static SupervisorStrategy strategy =
    new OneForOneStrategy(
        10,
        Duration.ofMinutes(1),        // 重启计数窗口时长
        DeciderBuilder.match(...)
                      .build();

按照官方文档说明，该配置支持特殊取值实现子Actor永久无限制重启：

• 给maxNrOfRetries参数传入-1
• 给withinTimeRange参数传入Duration.Inf()
  实际在OpenJDK 11环境下开发时，Duration.Inf()方法不存在，Stack Overflow上提到的JDK原生Duration最大值取值也无法被Akka正确识别，目前能勉强运行的最接近写法为传入Duration.ofNanos(Long.MAX_VALUE)，无法确认是用法遗漏、存在正确取值还是官方文档描述错误。

核心原因 #

这是Akka文档的导包歧义问题：文档中提到的Duration.Inf()并非JDK自带java.time.Duration类的方法，而是Scala标准库中scala.concurrent.duration.Duration类的静态方法。Java开发时默认导入java.time包下的Duration类，自然找不到该方法。

正确实现方案 #

根据你使用的Akka版本，选以下任意一种写法即可，都符合官方规范：

方案1：直接使用Scala Duration（兼容所有Akka Classic版本） #

手动导入Scala包下的Duration类，根据版本要求做类型转换即可：

• Akka 2.5及更早版本：OneForOneStrategy构造器本身接收Scala Duration类型参数，直接传值即可

import scala.concurrent.duration.Duration;

private static SupervisorStrategy strategy =
    new OneForOneStrategy(
        -1,
        Duration.Inf(),
        DeciderBuilder.match(Exception.class, e -> SupervisorStrategy.restart())
                      .build()
    );

• Akka 2.6及更新版本：构造器重载支持java.time.Duration类型，调用转换方法转成Java原生Duration即可

import scala.concurrent.duration.Duration;

private static SupervisorStrategy strategy =
    new OneForOneStrategy(
        -1,
        Duration.Inf().toJava(),
        DeciderBuilder.match(Exception.class, e -> SupervisorStrategy.restart())
                      .build()
    );

方案2：使用Akka提供的Java专用Duration常量（推荐2.6+版本使用） #

Akka专门为Java用户封装了不需要依赖Scala类的无限时长常量，直接导入即可使用，不需要额外做类型转换：

import akka.util.JavaDuration;

private static SupervisorStrategy strategy =
    new OneForOneStrategy(
        -1,
        JavaDuration.Inf(),
        DeciderBuilder.match(Exception.class, e -> SupervisorStrategy.restart())
                      .build()
    );

注意事项 #

• 不建议使用Duration.ofNanos(Long.MAX_VALUE)这类硬编码极大值的写法：Akka内部判断无限重启逻辑是识别专门的无限时长标记位，而非判断时长数值大小，该写法虽然实际运行时几乎不会触发窗口重置，但不符合官方实现规范，在部分定制修改版本中可能出现逻辑异常。
• 导包时注意区分三类Duration的差异，避免导错包：
  • java.time.Duration：JDK原生时间类，无Inf()相关方法
  • scala.concurrent.duration.Duration：Scala标准库时间类，自带无限时长定义
  • akka.util.JavaDuration：Akka为Java用户封装的适配类，直接提供Java原生类型的无限时长常量

内容的提问来源于stack exchange，提问作者Alessandro Bertulli