Spring集成Java DSL入站和出站错误处理

Question

我正在尝试构建一个集成解决方案，其中

IntegrationFlows
  .from(inBoundGateway)
  .enrichHeaders(enrichHeaders())
  .transform(dto to externaldto)
  .handle(outBoundGateway, advice -> advice.advice(retryAdvice()))
  .transform(exetrnaldto to dto)
  .get()

  @Bean
  RequestHandlerRetryAdvice rhra
  rhra.setRecoveryCalBack(errorMessgaeRecoverer());

  @Bean
  ErrorMessageSendingRecoverer errorMessgaeRecoverer

我的outboundgateway定义为

Http.outboundGateway(uri, resttemplate)
 ...
 .get()


new RestTemplate(requestFactory)

请求工厂在哪里

TrustStratgey ts = new TrustStratgey(){
 public boolean isTrusted(...){
   return true;
 }
}
SSLContext context = SSLContexts,custom().loaddTrustMaterials(null, ts);
SSLContextFactory cf = new SSLContextFactory(context, new NoopHostnameVerifier());
HttpClientBuilder clientBuilder ..
clientBuilder.setSSLSocketFactory()

快乐之路运行良好，我面临的问题是不太快乐的道路。

• 当Api调用返回错误响应时。转换（exetrnaldto到dto）失败，客户端获得500
• 我想把error resposne json也翻译成我的json
• 我如何处理错误情况

我的问题是：

1. 如何处理错误。
2. 在错误条件下如何停止流不转换
3. 如何将状态代码从出站发送到客户端（这很重要）
4. 如何处理像典型的@Controller建议@ErrorHandler机制或类似的错误。

希望Garry看到这篇帖子，找不到任何答案，我看了很多书和论坛，感觉Java DSL还没有被广泛使用或评论。

Answer 1

您的问题中没有任何Spring集成JavaDSL特定的内容。它实际上更多的是关于如何在服务器端（MVC-HttpIn边界网关）和客户端-RestTemboard和HttpOut边界网关上处理HTTP错误。JavaDSL只是现有技术和解决方案的语法糖。

因此，@Controller Advie@ErrorHandler是一个MVC，服务器端。您肯定可以让它与HttpInbnGateway一起工作，但对于客户端REST调用来说，这确实是错误的方向。

看起来您希望捕捉到该代码的REST错误调用。句柄（outBoundGateway）。考虑使用表达式Evaluating RequestHandlerAdvice和retryAdvice。因此，您将能够使用其故障通道处理异常，并将其分别转换为所需的JSON。

在文档中查看更多信息：https://docs.spring.io/spring-integration/docs/current/reference/html/messaging-endpoints.html#expression-建议