合并两个http请求的结果（spring集成）

Question

我正在努力做到以下几点：

创建两个 http 请求（getData 和 getMetadata），然后将结果合并到这样的负载中：{res1: getDataResult, res2: getMetadataResult} 然后将其传递到“resultChannel”。

<int:header-enricher input-channel="request" output-channel="getData">
    <int:header name="prop" value="1"/>
</int:header-enricher>

<int-http:outbound-gateway
        request-channel="getData"
        url-expression="'https://x.y.z/{param1}'"
        http-method="GET"
        reply-channel="aggregate"
        expected-response-type="java.util.HashMap"
        request-factory="restFactory">
    <int-http:uri-variable name="param1" expression="payload.param1"/>
</int-http:outbound-gateway>

<int-http:outbound-gateway
        request-channel="getData"
        url-expression="'https://x.y.z/{param2}'"
        http-method="GET"
        reply-channel="aggregate"
        expected-response-type="java.util.HashMap"
        request-factory="restFactory">
    <int-http:uri-variable name="param2" expression="payload.param2"/>
</int-http:outbound-gateway>

<int:aggregator
        release-strategy-expression="size() == 2"
        input-channel="aggregate"
        output-channel="resultChannel"
        correlation-strategy-expression="headers['prop']"
        expire-groups-upon-completion="true">
</int:aggregator>
<!---->

<int:channel id="resultChannel" />

作为输入，我有一个有效负载，其中包含必须用于请求的 param1 和 param2。

Answer 1

使用aggregator。

您将需要一个关联策略（将两个回复分组）；发布策略可能就像release-strategy-expression="size() == 2"一样简单。

如果您在两个请求中都设置了标头，例如将foo 设置为某个值，请使用correlation-strategy-expression="headers['foo']"。

聚合器会将两个回复配对并作为一个集合发布；然后，您可以使用<transformer/> 生成最终结果。

您可以重复使用相同的相关值，只要您设置expire-groups-upon-completion="true"。否则，相关性已释放的消息将被丢弃。