如何捕获Reactor中包私有RetryExhaustedException异常？

因为reactor.core.Exceptions$RetryExhaustedException是包私有静态内部类，无法直接在catch语句中声明，你可以通过以下两种方式精准识别并处理这个异常：

方法一：使用Reactor官方工具类判断（推荐） #

Reactor的Exceptions类提供了isRetryExhausted(Throwable)这个公开静态方法，专门用来判断异常是否是重试耗尽导致的。结合Exceptions.unwrap()解包真实异常，就能精准处理：

try {
    // 执行你的Reactor异步逻辑
} catch (IllegalStateException e) {
    Throwable realEx = Exceptions.unwrap(e);
    if (Exceptions.isRetryExhausted(realEx)) {
        // 这里写重试耗尽后的专属处理逻辑
        // 比如记录特定日志、触发告警等
    } else {
        // 其他类型的IllegalStateException，直接重新抛出或做通用处理
        throw e;
    }
}

方法二：通过全限定类名判断（兼容旧版本） #

如果你的Reactor版本没有isRetryExhausted方法，可以直接对比异常的全限定类名来识别：

try {
    // 执行你的Reactor异步逻辑
} catch (IllegalStateException e) {
    Throwable realEx = Exceptions.unwrap(e);
    if ("reactor.core.Exceptions$RetryExhaustedException".equals(realEx.getClass().getName())) {
        // 处理重试耗尽的逻辑
    } else {
        throw e;
    }
}

关键注意点 #

• 必须先用Exceptions.unwrap()解包：Reactor经常会将原始异常包装在一层通用异常里，直接拿e判断可能得不到真实的内部类实例。
• 不要直接捕获Throwable：保持只捕获IllegalStateException，再做精准过滤，避免扩大异常处理范围。

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