Spring Integration HttpOutbound收到ETag:1响应触发ErrorChannel问题求助

问题根因 #

远程服务器返回的ETag: 1不符合HTTP协议规范：根据RFC 7232要求，ETag值必须用双引号包裹，弱ETag需要以W/前缀开头再加双引号包裹的内容。Spring框架的HttpHeaders类对ETag格式做了严格校验，遇到不符合规范的ETag会直接抛出IllegalArgumentException异常。

解决方案 #

以下三种方案可根据业务场景选择：

方案1：过滤远程响应的ETag头（最简实现）

如果业务不需要将远程服务的ETag返回给上游调用方，直接在出站网关配置中排除ETag响应头即可，修改代码如下：

@Bean
public IntegrationFlow request() {
    return flow -> flow.enrichHeaders((headerEnricherSpec -> {
        headerEnricherSpec.header(authKey,authToken,true);
    })).handle(Http.outboundGateway(url)
            .mappedRequestHeaders(authKey)
            // 配置排除ETag响应头，*表示默认映射所有响应头，!ETag表示排除ETag
            .mappedResponseHeaders("*", "!ETag")
            .httpMethod(HttpMethod.POST)
            .expectedResponseType(ResponseDTO.class)
    ).transform(responseTransformer);
}

方案2：兼容处理不规范ETag

如果业务需要保留ETag返回给上游，可以自定义HeaderMapper重写ETag处理逻辑，自动补全不符合规范的ETag格式：
首先定义自定义HeaderMapper：

@Bean
public DefaultHttpHeaderMapper compatibleETagHeaderMapper() {
    DefaultHttpHeaderMapper mapper = new DefaultHttpHeaderMapper() {
        @Override
        protected void setETag(HttpHeaders headers, Object value) {
            if (value == null) {
                return;
            }
            String etag = value.toString().trim();
            // 对不符合格式的ETag自动补全双引号
            if (!etag.startsWith("\"") && !etag.startsWith("W/")) {
                etag = "\"" + etag + "\"";
            }
            super.setETag(headers, etag);
        }
    };
    mapper.setInboundHeaderNames(new String[]{"*"});
    mapper.setOutboundHeaderNames(new String[]{"*"});
    return mapper;
}

将自定义HeaderMapper配置到出站网关中：

@Bean
public IntegrationFlow request() {
    return flow -> flow.enrichHeaders((headerEnricherSpec -> {
        headerEnricherSpec.header(authKey,authToken,true);
    })).handle(Http.outboundGateway(url)
            .mappedRequestHeaders(authKey)
            .headerMapper(compatibleETagHeaderMapper())
            .httpMethod(HttpMethod.POST)
            .expectedResponseType(ResponseDTO.class)
    ).transform(responseTransformer);
}

方案3：手动移除ETag响应头

在出站网关处理完成后新增一步头处理逻辑，直接移除ETag头：

@Bean
public IntegrationFlow request() {
    return flow -> flow.enrichHeaders((headerEnricherSpec -> {
        headerEnricherSpec.header(authKey,authToken,true);
    })).handle(Http.outboundGateway(url)
            .mappedRequestHeaders(authKey)
            .httpMethod(HttpMethod.POST)
            .expectedResponseType(ResponseDTO.class)
    )
    // 移除ETag响应头
    .enrichHeaders(headerSpec -> headerSpec.remove("ETag"))
    .transform(responseTransformer);
}

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