IntegrationFlow HttpRequestHandlingMessagingGateway直接回复

Question

我是Spring Integration的新手，我正在尝试使用HttpRequestExecutingMessageHandler和HttpRequestHandlingMessagingGateway。处理程序正在发送POST请求并期待答复。网关正在使用该请求。它工作正常，但处理程序没有得到回复。我不知道如何设置我的流程，我可以直接发送回信并继续我的流程。

@Bean
public HttpRequestExecutingMessageHandler httpOutbound() {
  HttpRequestExecutingMessageHandler handler = Http.outboundGateway(restUrl)
        .httpMethod(HttpMethod.POST)
        .messageConverters(new MappingJackson2HttpMessageConverter())
        .mappedRequestHeaders("Content-Type")
        .get();
  handler.setExpectReply(true);
  handler.setOutputChannel(httpResponseChannel());
  return handler;
}

@Bean
public HttpRequestHandlingMessagingGateway httpRequestGateway() {
  HttpRequestHandlingMessagingGateway gateway = new HttpRequestHandlingMessagingGateway(true);
  RequestMapping mapping = new RequestMapping();
  mapping.setMethods(HttpMethod.POST);
  mapping.setPathPatterns(httpRequestHandlingPathPattern);
  gateway.setRequestMapping(mapping);
  gateway.setErrorChannel(errorChannel());
  gateway.setReplyChannel(replyChannel());
  gateway.setRequestChannel(requestChannel());
  gateway.setRequestPayloadTypeClass(DocumentConverterInput.class);
  return gateway;
 }

@Bean
public IntegrationFlow documentConverterFlow() {
  return IntegrationFlows
        .from(requestChannel())
        .publishSubscribeChannel(publishSubscribeSpec ->
              publishSubscribeSpec.subscribe(flow -> flow
                          .enrichHeaders(headerEnricherSpec -> headerEnricherSpec.header("http_statusCode", HttpStatus.OK))
                          .channel(replyChannel())))
        .enrichHeaders(headerEnricherSpec ->
             headerEnricherSpec.headerExpression(Constants.DOCUMENT_CONVERTER_INPUT, "payload"))
        .handle(Jms.outboundAdapter(jmsTemplate(connectionFactory)))
        .get();
 }

我的HttpRequestExecutingMessageHandler已成功发布请求。 HttpRequestHandlingMessagingGateway已成功使用它。起初，我有一个错误“超时内未收到回复”，因此我添加了一个publishSubscriberChannel。我不知道这是不是正确的方法，但是我找不到能说明如何正确回答的有效示例。

我上面的代码正在工作，但没有将回复发送回HttpRequestExecutingMessageHandler！

我的目标是接收请求消息并直接发回200 OK。之后，我想继续进行集成流程，做一些事情并将结果发送到队列。

有什么建议吗？

Answer 1

仅对于200 OK响应，您需要考虑使用HttpRequestHandlingMessagingGateway配置expectReply = false。这样，它将作为入站通道适配器工作，但是由于HTTP始终是请求响应的事实，因此它只会执行setStatusCodeIfNeeded(response, httpEntity);，而客户端的HttpRequestExecutingMessageHandler将为空，但是[C0 ] Resposnse。

[不确定为什么OK不能按预期工作。您可能是这样的事实，您将请求channel(replyChannel())返回到最终成为HTTP响应的回复消息中，但是以某种方式失败了，可能是在转换期间...