Блог

В настоящее время я изучаю spring integration framework. Поэтому, пожалуйста, простите и поправьте меня, если мой вопрос абсурден. как или есть ли способ имитировать исходящий http-шлюз для запуска моего unit tastcase?

 public IntegrationFlow sendSms() {
        final ObjectMapper objectMapper = new ObjectMapper();
        objectMapper.configure(MapperFeature.ACCEPT_CASE_INSENSITIVE_PROPERTIES, true);
        final JsonObjectMapper<?, ?> mapper = new Jackson2JsonObjectMapper(objectMapper);
        return IntegrationFlows.from("sendSmsGatewayRequestChannel")
                .handle(Http
                        .outboundGateway(environment.getProperty("integration.sms.endpoint")
                                  "?ProductType={ProductType}amp;MobleNo={MobleNo}amp;smsType={smsType}amp;Message={Message}")
                        .expectedResponseType(String.class).httpMethod(HttpMethod.GET)
                        .uriVariableExpressions(createExpressionMap()))
                .transform(Transformers.fromJson(SmsResponseDto.class, mapper)).get();
    }
 

это мой поток интеграции.

Кроме того, можем ли мы использовать mockmvc для тестирования входящего шлюза?

добавьте идентификатор компонента в обработчик как,

 @Bean
    public IntegrationFlow sendSms() {
        final ObjectMapper objectMapper = new ObjectMapper();
        objectMapper.configure(MapperFeature.ACCEPT_CASE_INSENSITIVE_PROPERTIES, true);
        final JsonObjectMapper<?, ?> mapper = new Jackson2JsonObjectMapper(objectMapper);
        return IntegrationFlows.from("sendSmsGatewayRequestChannel")
                .handle(Http.outboundGateway(smsEndpoint).expectedResponseType(String.class).httpMethod(HttpMethod.GET)
                        .uriVariableExpressions(createExpressionMap()), **e -> e.id("smsOutboundGateway")**)
                .transform(Transformers.fromJson(SmsResponseDto.class, mapper)).get();
    }
 

затем вы можете имитировать ответ с помощью,

 final ArgumentCaptor<Message<?>> messageArgumentCaptor = ArgumentCaptor.forClass(Message.class);
        final MessageHandler mockMessageHandler = MockIntegration.mockMessageHandler(messageArgumentCaptor)
                .handleNextAndReply(m -> MessageBuilder.withPayload(
                        "response")
                        .build());
        mockIntegrationContext.substituteMessageHandlerFor("smsOutboundGateway", mockMessageHandler);
 

Примечание: я новичок в Spring integration. так что я не знаю, правильный ли это способ сделать это. в любом случае, это работает: D. исправьте, если я ошибаюсь. 🙂

Спасибо Артему Билану за помощь.

Да, любой handle() (или лучше сказать MessageHandler ) в приложении можно издеваться. Для этой цели нам нужен @SpringIntegrationTest MockIntegration API and .

Смотрите больше информации в документах: https://docs.spring.io/spring-integration/docs/current/reference/html/testing.html#testing

И да, с HTTP мы действительно можем использовать макет MVC-фреймворка и MockMvcClientHttpRequestFactory вводить его в HttpRequestExecutingMessageHandler представленный им Http.outboundGateway() .

Подробнее в документах: https://docs.spring.io/spring-framework/docs/current/reference/html/testing.html#spring-mvc-test-client