如何在Spring集成网关中获取自定义标头值？

Question

这是我的第一个问题。

我的Web应用程序正在使用Spring集成来获取第三方API响应。

响应具有以“X-”开头的自定义标头值。X值是两个。（X-AccessToken-Quota-Allotted，X-AccessToken-Quota-Flow）

因此，我在config xml的header-mapper中添加了inboundHeaderNames，如下所示。

    <int-http:outbound-gateway id="dms.put.outbound.gateway.cert"
        header-mapper="dmsHeaderMapper"
       ...
</int-http:outbound-gateway>

<bean id="dmsHeaderMapper" class="org.springframework.integration.http.support.DefaultHttpHeaderMapper" factory-method="outboundMapper" >
    <property name="outboundHeaderNames" value="X-Request-Id...blabla"/>
    <property name="inboundHeaderNames" value="X-AccessToken-Quota-Allotted, X-AccessToken-Quota-Current"/>
    <property name="userDefinedHeaderPrefix" value=""/>
</bean>

以下是回应。我可以看到X-AccessToken-Quota-alloted

[integration]generic message[payload = { " Type ":" common response "，" serverName ":" usl xacd 20022 use1c . intranet . local "，" errorMessage":null}，headers = { error channel = org . spring framework . messaging . core . genericmessaging template $ temporaryreply channel @ 41208186，X-Request-Id = 0 ce 88 CD 6-d04 b-47dc-b3db-2224656 Fe 9090，uri = https://API-APIcharset=UTF-8，timestamp=1592791409206}]

几乎每个字段值都映射到了responseDto的字段，但我不知道如何将X自定义标题值映射到ResponseTo字段。

以下是当前设置。

<int:gateway id="dmsHttpPUTGateway" service-interface="blabla.gateway.DmsHttpPUTGateway" 
        default-request-channel="dms.put.ch.request.header.router"><int:method name="call" /></int:gateway>

<int:header-value-router input-channel="dms.put.ch.reply.header.router" header-name="jsonObjectName">
    <int:mapping value="DmsCommonResponseDto" channel="dms.put.ch.reply.transformer.DmsCommonResponseDto"/>
</int:header-value-router>

<int:channel id="dms.put.ch.reply.transformer.DmsCommonResponseDto"></int:channel>

<int:json-to-object-transformer input-channel="dms.put.ch.reply.transformer.DmsCommonResponseDto" output-channel="dms.put.ch.reply" type="blabla.DmsCommonResponseDto"></int:json-to-object-transformer>

    DmsCommonResponseDto.java 
private static final long serialVersionUID = 1L;

private String serverName;
private DmsErrorMessageDto errorMessage;
private Date responseDate;

...setter, getter method.

任何哪怕是一点点的线索也会有帮助。提前谢谢你。

Answer 1

听起来您需要一个 json 转换器下游的自定义转换器。

class MyTransformer extends AbstractTransformer {

    protected abstract Object doTransform(Message<?> message) {
        DmsCommonResponseDto dto = (DmsCommonResponseDto) message.getPayload();
        dto.setRequestId(message.getHeaders.get("X-request-id"));
        ...
        return dto.
    }    

}