如何在Spring集成中从网关发送响应

Question

我遵循下面的示例来实现spring集成网关。

问题：无法从服务激活器发送的网关上获得响应。

1. 网关应答通道是"最佳应答通道"。
2. 服务激活器写入同一个通道。

所有的自定义方法都被执行，响应被组成，但是从来没有被发送出去。知道这里缺少什么吗？我的配置在流程中也有一个分散收集。

<!--Gateway:-->
<channel id="bestQuoteResponseChannel"/>
<gateway id="loanBrokerGateway"
        default-request-channel="loanRequestsChannel"
        service-interface="org.springframework.integration.samples.loanbroker.LoanBrokerGateway">
    <method name="getBestLoanQuote" reply-channel="bestQuoteResponseChannel">
        <header name="RESPONSE_TYPE" value="BEST"/>
    </method>
</gateway>

<chain input-channel="loanRequestsChannel">
    <header-enricher>
        <header name="creditScore" expression="@creditBureau.getCreditReport(payload).score"/>
    </header-enricher>
    <recipient-list-router apply-sequence="true">
        <recipient selector-expression="headers.creditScore > 800" channel="exclusiveBankChannel"/>
        <recipient selector-expression="headers.creditScore > 750" channel="premiereBankChannel"/>
        <recipient selector-expression="headers.creditScore > 700" channel="qualityBankChannel"/>
        <recipient selector-expression="headers.creditScore > 650" channel="friendlyBankChannel"/>
        <recipient channel="easyBankChannel"/>
    </recipient-list-router>
</chain>

<!-- Messages are sent to the banks via bank channels and will be received and processed by an aggregator -->

<aggregator input-channel="loanQuotesChannel" output-channel="input" method="aggregateQuotes">
    <beans:bean class="org.springframework.integration.samples.loanbroker.LoanQuoteAggregator"/>
</aggregator>

<service-activator ref="findBestQuoteService" method="findBestQuote" input-channel="input" output-channel="bestQuoteResponseChannel"/>

Answer 1

在spring集成流将应答发送到网关之前，我已经在spring集成流中进行了分散收集。这在某种程度上阻止了它向网关发送响应。

所做的更改：我用发布-订阅通道和聚合器组合替换了散点-收集组件。

https://docs.spring.io/spring-integration/docs/5.3.0.M1/reference/html/scatter-gather.html#scatter-聚集命名空间

Answer 2

首先，在这种情况下，网关上不需要回复通道，因此服务激活器上也不需要输出通道。所有的应答逻辑都应该落在replyChannel头上，当网关方法被调用时，它总是由框架填充。

很高兴看到你的找到了什么样的TestQuoteService。findBestQuote已经为我们做了一切，因为LoanQuoteAggregator已经为我们做了一切：

/**
 * Aggregates LoanQuote Messages to return a single reply Message.
 *
 * @param quotes list of loan quotes received from upstream lenders
 * @param responseType header that indicates the response type
 * @return the best {@link LoanQuote} if the 'RESPONSE_TYPE' header value is 'BEST' else all quotes
 */
public Object aggregateQuotes(List<LoanQuote> quotes,
        @Header(value="RESPONSE_TYPE", required=false) String responseType) {
    Collections.sort(quotes);
    return ("BEST".equals(responseType)) ? quotes.get(0) : quotes;
}

那么，你以后的定制服务有什么意义呢？

还可以考虑打开org.springframework.integration类别的DEBUG级别，以查看您的消息是如何传输的。可能我们也会在日志中看到一些问题。

我不知道你的逻辑怎么会丢失replyChannel头，但我们需要更多信息来调查。