Spring Integration Retry Advice未触发重试，咨询先重试再返回自定义异常方案

问题根源 #

你的dPersist方法内部捕获了数据库异常并直接返回ResponseEntity，导致Spring Integration的重试通知（Retry Advice）无法感知到异常，因此不会触发重试逻辑——重试机制的触发前提是方法抛出可被识别的异常。

解决方案步骤 #

1. 修改业务方法，抛出异常而非内部处理 #

修改dAdapterController中的dPersist方法，移除对数据库异常的内部捕获，直接将异常抛出。若需要包装异常，可转换为自定义业务异常后抛出，确保重试通知能捕获到异常。

示例代码：

public YourReturnType dPersist(YourPayloadType payload) throws SQLException {
    // 移除原有try-catch，直接执行数据库操作
    yourDatabaseOperation.execute();
    return normalResult;
}

// 或包装异常后抛出
public YourReturnType dPersist(YourPayloadType payload) {
    try {
        yourDatabaseOperation.execute();
        return normalResult;
    } catch (SQLException e) {
        throw new RuntimeException("数据库操作失败", e);
    }
}

2. 调整重试配置与失败处理流程 #

保留现有重试配置，在dRetryChannel的后续流程中添加处理逻辑，将失败消息转换为你需要的自定义ResponseEntity，再发送到目标通道（如原流程的dIntermediateChannel或专门的异常输出通道）。

修改后的配置示例：

<int:chain id="a1-chain" input-channel="dRequestInputChannel" output-channel="dIntermediateChannel">
    <int:service-activator ref="dAdapterController" method="dPersist">
        <int:request-handler-advice-chain>
            <int:retry-advice max-attempts="4" recovery-channel="dRetryChannel">
                <int:exponential-back-off initial="1000" multiplier="5.0" maximum="60000" />
                <!-- 可选：指定只重试数据库相关异常，避免其他异常误触发 -->
                <int:retry-exception-classes>
                    <int:include class="java.sql.SQLException" />
                    <int:include class="java.lang.RuntimeException" />
                </int:retry-exception-classes>
            </int:retry-advice>
        </int:request-handler-advice-chain>
    </int:service-activator>
</int:chain>

<int:transformer input-channel="dRetryChannel" expression="payload.getFailedMessage()" />
<!-- 添加自定义异常响应转换逻辑 -->
<int:service-activator input-channel="dRetryChannel" ref="exceptionHandler" method="buildErrorResponse" output-channel="dIntermediateChannel" />

对应的异常处理类示例：

@Component("exceptionHandler")
public class ExceptionHandler {
    public ResponseEntity<String> buildErrorResponse(Message<?> failedMessage) {
        Throwable rootException = ((MessagingException) failedMessage.getPayload()).getCause();
        // 构建自定义异常响应
        return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR)
                .body("数据库操作重试4次失败：" + rootException.getMessage());
    }
}

流程说明 #

1. 当dPersist抛出数据库异常时，重试通知会按配置执行4次指数退避重试；
2. 若4次重试全部失败，失败消息会被发送到dRetryChannel；
3. 经过transformer提取原失败消息后，由异常处理类转换为自定义ResponseEntity，最终发送到dIntermediateChannel进入后续流程。

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