Spring集成4.2.1.RELEASE未映射到内容类型标头

Question

我使用的是最新的Spring集成4.2.1.RELEASE，使用DSL配置。我的请求没有从入站请求映射其 HTTP 标头内容类型。

有一个旧的JIRA INT-3508已解决。在4.0到4.1迁移指南中，似乎说这已修复。

然而，我的代码没有请求标题。

    @Bean
public IntegrationFlow httpProxyFlow()  {
    return IntegrationFlows
        .from((MessagingGateways g) ->
                g.httpGateway("/csa-service/**")
                    .messageConverters(getMessageConverter())
                    .payloadFunction(httpEntity ->
                            ((ServletRequestAttributes) RequestContextHolder.currentRequestAttributes())
                                    .getRequest()
                                    .getQueryString())
                    .requestPayloadType(String.class))
                    .handleWithAdapter(a ->
                            a.httpGateway(this::setupUrl)
                                    .messageConverters(getMessageConverter())
                                    .httpMethodFunction(this::getMethodFunction)
                                    .errorHandler(new PassThroughErrorHandler())
                                    .encodeUri(false)
                                    .expectedResponseType(String.class)
                    ).get();
}

private HttpMessageConverter getMessageConverter() {
    StringHttpMessageConverter stringConverter = new StringHttpMessageConverter();
    stringConverter.setWriteAcceptCharset(false);
    stringConverter.setSupportedMediaTypes(Arrays.asList( //
            MediaType.TEXT_PLAIN,
            MediaType.APPLICATION_JSON_UTF8,
            new MediaType("application", "*+json"),
            MediaType.TEXT_HTML,
            MediaType.APPLICATION_JSON));
    return stringConverter;
}

当我调试DefaultHttpHeaderMapper时，问题正是上面JIRA提到的，第730行:

        else if (MessageHeaders.CONTENT_TYPE.equalsIgnoreCase(name)) {

并且该静态变量映射回

    public static final String CONTENT_TYPE = "contentType";

从3.0到4.0的迁移指南展示了object-to-json-transformer和header-enricher的配置。而4.0版指南显示

<int:chain>
 <int:object-to-json-transformer/>
 <int-http:outbound-gateway url="http://service"/></int:chain>

看起来DSL中的等价物是

        .transform(new ObjectToJsonTransformer())

然而，添加这一功能将引入Jackson数据绑定转换器，它将恢复我在Gary Russell的帮助下刚刚修复的古怪JSON。

Answer 1

想出了一个解决方法。

                .expectedResponseType(String.class)
                )
                .transform(new ObjectToJsonTransformer())
               .get();

奏效了，但是97号线的电话

    Object payload = ResultType.STRING.equals(this.resultType)
            ? this.jsonObjectMapper.toJson(message.getPayload())
            : this.jsonObjectMapper.toJsonNode(message.getPayload());

导致我的有效载荷中的JSON被重新编码。所以我创建了一个自定义版本的类，并删除了这一行，现在我测试的一切都正常了。

doTransform()方法有我需要的内容类型修复，但是在我们的例子中，这个对象似乎并不需要。任何关于我如何能更好地实现这一点的建议将不胜感激。