Spring Integration REST API请求头校验异常处理超时问题求助

核心问题1：错误处理器Bean引用不匹配 #

你的配置中，<int:service-activator>指定的错误处理器ref="testErrorHandler"，但实际定义的Bean id是loadErrorHandler，两者不匹配导致Spring无法找到错误处理实例，错误通道的消息无人处理，最终触发网关的超时错误「No reply received from error channel within timeout」。

修复方式：
将service activator的ref改为与Bean id一致，或者修改Bean id匹配testErrorHandler：

<int:service-activator input-channel="apiErrorChannel" ref="loadErrorHandler" method="handleFailedRequest" output-channel="sampleResponseChannel"/>

核心问题2：错误通道消息未正确转换为HTTP响应 #

错误通道传递的消息payload是MessagingException，直接返回无法被HTTP网关正确解析为客户端响应。需要在错误处理器中提取异常信息，构造标准错误响应并设置HTTP状态码头。

修改错误处理器实现：

public class TestErrorHandler {
    public Message<?> handleFailedRequest(MessagingException ex) {
        // 获取原始业务异常
        Throwable rootCause = ex.getCause();
        String errorMsg = rootCause != null ? rootCause.getMessage() : "请求处理失败";
        
        // 构造错误响应体
        ErrorResponse errorResponse = new ErrorResponse(HttpStatus.BAD_REQUEST.value(), errorMsg);
        
        // 设置HTTP状态码，确保网关返回正确的响应状态
        return MessageBuilder.withPayload(errorResponse)
                .setHeader(HttpHeaders.STATUS_CODE, HttpStatus.BAD_REQUEST)
                .build();
    }

    // 定义错误响应DTO
    public static class ErrorResponse {
        private int status;
        private String message;

        public ErrorResponse(int status, String message) {
            this.status = status;
            this.message = message;
        }

        // 省略getter/setter
        public int getStatus() { return status; }
        public void setStatus(int status) { this.status = status; }
        public String getMessage() { return message; }
        public void setMessage(String message) { this.message = message; }
    }
}

优化建议：提前校验请求头 #

无需在业务代码中抛异常，可直接在HTTP网关层面添加请求头校验，更早拦截非法请求：

<int-http:inbound-gateway 
     request-channel="sampleRequestChannel"
     reply-channel="sampleResponseChannel"
     error-channel="apiErrorChannel"
     reply-timeout="15000"
     supported-methods="GET"
     path="/test/{testId}"
     mapped-request-headers="*"
     payload-expression="#pathVariables.testId">
    <int:header name="source" expression="#requestParams[source]"/>
    <!-- 添加请求头校验 -->
    <int-http:header-validator>
        <int-http:header name="需要校验的头名称" expected-value="指定值"/>
    </int-http:header-validator>
</int-http:inbound-gateway>

校验不通过时会直接抛出异常，进入错误通道处理，避免请求流入业务逻辑。

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