Spring集成5.1-集成流测试-dsl

Question

我已经建立了一个简单的Spring集成流程，该流程由以下步骤组成：

1. 然后定期轮询一个rest api
2. 对有效载荷做一些处理
3. 并将其置于Kafka主题上。

请遵守以下代码：

@Component
public class MyIntegrationFlow extends IntegrationFlowAdapter {
    @Override
    protected IntegrationFlowDefinition<?> buildFlow() {
        return from(() -> List.of("pathVariable1", "pathVariable2"), c -> c.poller(Pollers.fixedDelay(5, TimeUnit.SECONDS)))
                .split()
                .handle(httpRequest(), c -> c.advice(new RequestHandlerRetryAdvice()))
                .transform(Tranformers.fromJson(Foo.class))
                .filter(payload -> payload.isValid())
                .log()
                .transform(Tranformers.toJson())
                .channel(Source.OUTPUT); // output channel for kafka topic
    }

    private HttpMessageHandlerSpec httpRequest() {
        return Http.outboundGateway("http://somehost:8080/{pathVariable}")
                .httpMethod(GET)
                .uriVariable("pathVariable", Message::getPayload)
                .expectedResponseType(String.class);
    }
}

这非常有效，然而，我正在努力想出一些好的测试。

• 我应该如何模拟外部RESTAPI

Answer 1

问题太多，其中一些需要太广泛的解释。无论如何，我认为您可以从Spring集成测试框架及其文档开始。

>

我认为您可以考虑使用Spring Framework中的模拟MVC及其MockMvcClientHttpRequestFactory，基于HttpMessageHandlerSpec注入HttpRequestExecutingMessageHandler。

重试策略不起作用

好吧，我想同一个模拟MVCendpoint可以验证它被调用了多少次，并且在最初几次启动重试时失败。

如何更改消息源

这正是Spring集成测试框架的一部分，它的MockIntegration.mockMessageSource（）和MockIntegrationContext：https://docs.spring.io/spring-integration/docs/5.1.6.RELEASE/reference/html/#mockintegration

进入Kafka主题？

或者你提到的模拟集成。mockMessageHandler（）验证是否调用了Kafka的endpoint。或者使用Spring Kafka项目中的嵌入式Kafka：https://docs.spring.io/spring-kafka/docs/2.2.7.RELEASE/reference/html/#embedded-Kafka注释