Spring集成@网关回复超时

Question

我有一个如下的集成，我从rest控制器调用这个方法，但回复超时并没有像我预期的那样工作。

我期望的是：如果在我给出的回复超时时间内没有响应，则返回timeout作为对客户端的响应。

对于通道配置中的超时持续时间，是否需要执行一些操作？

谢谢。

@Gateway(requestChannel = REQUEST_CHANNEL, replyChannel = RESPONSE_CHANNEL, requestTimeout = 5000, replyTimeout = 5000)
Mono<ResponseObject> sendRequestObject(RequestObject request);

@Bean    
public IntegrationFlow myRequestFlow() {     
     return IntegrationFlows.from(REQUEST_CHANNEL)
           .enrichHeaders(HeaderEnricherSpec::headerChannelsToString)
           .handle(message -> {
               // I didn't send anything on the response channel.
               System.out.println(message);    
            })
           .get(); 
       }  

@Bean
public IntegrationFlow myResponseFlow(MessageChannel myResponseChannel) { 
     return IntegrationFlows.from(myResponseChannel)
               .channel(RESPONSE_CHANNEL)
               .get(); 
       }

Answer 1

GatewayProxyFactoryBean的当前默认行为是在回复超时时返回null。逻辑如下：

if (reply == null && this.errorOnTimeout) {
            throwMessageTimeoutException(object, "No reply received within timeout");
}

默认情况下，errorOnTimeout是false，我看不出我们有一个来自注释的钩子来配置它。请随时就此事提出GH问题。

无论如何，我没有看到MonoReplyChannel中涉及ReplyTimeout。因此，从网关的角度来看，这可能是另一个改进。

但我仍然认为，您的web客户端应该设置一些请求超时，以避免无限期等待。