Spring 出站 Http 端点的集成测试

Question

我是 Spring 集成项目的新手，现在我需要使用 Java DSL 创建一个流程并对其进行测试。我想出了这些流程。第一个应该运行通过 cron 并调用第二个，它调用 HTTP 端点并将 XML 响应转换为 POJO：

  @Bean
  IntegrationFlow pollerFlow() {
    return IntegrationFlows
        .from(() -> new GenericMessage<>(""),
            e -> e.poller(p -> p.cron(this.cron)))
        .channel("pollingChannel")
        .get();
  }

  @Bean
  IntegrationFlow flow(HttpMessageHandlerSpec bulkEndpoint) {
    return IntegrationFlows
        .from("pollingChannel")
        .enrichHeaders(authorizationHeaderEnricher(user, password))
        .handle(bulkEndpoint)
        .transform(xmlTransformer())
        .channel("httpResponseChannel")
        .get();
  }

  @Bean
  HttpMessageHandlerSpec bulkEndpoint() {
    return Http
        .outboundGateway(uri)
        .httpMethod(HttpMethod.POST)
        .expectedResponseType(String.class)
        .errorHandler(new DefaultResponseErrorHandler());
  }

现在我想测试流程和模拟 HTTP 调用，但很难模拟 HTTP 处理程序，我尝试这样做：

@ExtendWith(SpringExtension.class)
@SpringIntegrationTest(noAutoStartup = {"pollerFlow"})
@ContextConfiguration(classes = FlowConfiguration.class)
public class FlowTests {

  @Autowired
  private MockIntegrationContext mockIntegrationContext;
  @Autowired
  public DirectChannel httpResponseChannel;
  @Autowired
  public DirectChannel pollingChannel;

  @Test
  void test() {
    final MockMessageHandler mockHandler = MockIntegration.mockMessageHandler()
        .handleNextAndReply(message -> new GenericMessage<>(xml, message.getHeaders()));
    mockIntegrationContext.substituteMessageHandlerFor("bulkEndpoint", mockHandler);
    httpResponseChannel.subscribe(message -> {
      assertThat(message.getPayload(), is(notNullValue()));
      assertThat(message.getPayload(), instanceOf(PartsSalesOpenRootElement.class));
    });

    pollingChannel.send(new GenericMessage<>(""));
  }
}

但我总是得到一个错误，在线：

mockIntegrationContext.substituteMessageHandlerFor("bulkEndpoint", mockHandler);

org.springframework.beans.factory.BeanNotOfRequiredTypeException: Bean named 'bulkEndpoint' is expected to be of type 'org.springframework.integration.endpoint.IntegrationConsumer' but was actually of type 'org.springframework.integration.http.outbound.HttpRequestExecutingMessageHandler'

我是不是做错了什么？我假设我的 IntegrationFlow 本身有问题，或者我的测试方法有问题。

Answer 1

错误正确。 bulkEndpoint 本身不是端点。真是一个MessageHandler。端点是从 .handle(bulkEndpoint) 创建的。请参阅文档：https://docs.spring.io/spring-integration/docs/current/reference/html/overview.html#finding-class-names-for-java-and-dsl-configuration and https://docs.spring.io/spring-integration/docs/current/reference/html/testing.html#testing-mocks.

因此，要使其正常工作，您需要执行以下操作：

.handle(bulkEndpoint, e -> e.id("actualEndpoint"))

然后在测试中：

mockIntegrationContext.substituteMessageHandlerFor("actualEndpoint", mockHandler);

您可能还需要考虑在测试时不要启动 pollerFlow，因为您手动将消息发送到 pollingChannel。因此，与您要测试的内容没有冲突。出于这个原因，您还将 id() 添加到 e.poller(p -> p.cron(this.cron)) 并使用 @SpringIntegrationTest(noAutoStartup) 使其在测试前停止。我看到你尝试 noAutoStartup = {"pollerFlow"}，但这对静态流没有帮助。在这种情况下，您确实需要停止实际端点。

Spring 出站 Http 端点的集成测试

Spring Integration Testing of Outbound Http Enpoint

java

spring

spring-integration

spring-integration-dsl

spring-integration-http