Блог

Я пытаюсь написать интеграционный тест, и часть этого теста требует имитировать вызов REST, а также вызов SOAP. Остальная часть работает нормально, я могу издеваться над этим. Вызов SOAP оказывается трудным для моделирования. Я получаю исключение WebServiceIOException.

 Caused by: org.springframework.ws.client.WebServiceIOException: I/O error: Connection refused: connect; nested exception is java.net.ConnectException: Connection refused: connect
    at org.springframework.ws.client.core.WebServiceTemplate.sendAndReceive(WebServiceTemplate.java:561)
    at org.springframework.ws.client.core.WebServiceTemplate.marshalSendAndReceive(WebServiceTemplate.java:390)
    at org.springframework.ws.client.core.WebServiceTemplate.marshalSendAndReceive(WebServiceTemplate.java:378)
    at ca.nbc.payment.pmt_commons_mcp_connector.service.OdsPreferencesConnector.getPreferences(OdsPreferencesConnector.java:18)
    at ca.nbc.payment.pmt_commons_mcp_connector.service.McpConnectorMessageService.processGetCustomerMessage(McpConnectorMessageService.java:46)
    at ca.nbc.payment.pmt_commons_mcp_connector.stream.McpConnectorStreamListener.handleCustomerManagementMessageRetrieve(McpConnectorStreamListener.java:29)
    at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
    at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.base/java.lang.reflect.Method.invoke(Method.java:566)
    at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:171)
    at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:120)
    at org.springframework.cloud.stream.binding.StreamListenerMessageHandler.handleRequestMessage(StreamListenerMessageHandler.java:55)
  

Вот мой класс client, класс, который расширяет WebServiceGatewaySupport

 public class OdsPreferencesConnector extends WebServiceGatewaySupport {

  @Value("${ods.url}")
  private String odsUrl;

  public String getPreferences(String memberIdNo) {
    GetPreferencesResponse getPreferencesResponse = (GetPreferencesResponse) getTemplate().marshalSendAndReceive(odsUrl, getGetPreferencesRequest(memberIdNo));

    if (!getPreferencesResponse.getServiceResponse().getPreferenceList().getPreference().isEmpty()) {
      return getPreferencesResponse.getServiceResponse().getPreferenceList().getPreference().get(0).getPrefValue();
    }

    return null;
  }

  private WebServiceTemplate getTemplate() {
    WebServiceTemplate webServiceTemplate = new WebServiceTemplate();

    Jaxb2Marshaller jaxb2Marshaller = new Jaxb2Marshaller();
    jaxb2Marshaller.setClassesToBeBound(GetPreferencesRequest.class, GetPreferencesResponse.class);
    webServiceTemplate.setMarshaller(jaxb2Marshaller);
    webServiceTemplate.setUnmarshaller(jaxb2Marshaller);

    return webServiceTemplate;
  }

  private GetPreferencesRequest getGetPreferencesRequest(String memberIdNo) {
    GetPreferencesRequest getPreferencesRequest = new GetPreferencesRequest();

    getPreferencesRequest.setServiceRequest(new GetPreferencesRequestType());
    getPreferencesRequest.getServiceRequest().setPartyNumber(new PartyNumberType());
    getPreferencesRequest.getServiceRequest().getPartyNumber().setMemberIdNo(memberIdNo);

    return getPreferencesRequest;
  }

}
  

Вот мой тестовый класс

 @SpringBootTest
@ActiveProfiles("integration-tests")
class IntegrationTest {

  @Autowired
  private ObjectMapper objectMapper;

  @Autowired
  private MessageCollector messageCollector;

  @Autowired
  private McpConnectorStream mcpConnectorStream;

  @Autowired
  private static OdsPreferencesConnector odsPreferencesConnector;

  private static MockWebServiceServer mockServer;

  private static WireMockServer wireMockServer;

  @BeforeAll
  public static void setup() {
    wireMockServer = new WireMockServer(options().bindAddress("127.0.0.1").port(14000));
    wireMockServer.start();

    odsPreferencesConnector = new OdsPreferencesConnector();

    ReflectionTestUtils.setField(odsPreferencesConnector, "odsUrl", "http://localhost:12000/ws");

    mockServer = MockWebServiceServer.createServer(odsPreferencesConnector);
  }

  @AfterAll
  public static void afterAll() {
    wireMockServer.stop();
  }

  @Test
  void handleCustomerManagementMessageGet() throws Exception {
    PaymentCommonsCustomer receivedMessage = TestObjectBuilder.createPaymentCommonsCustomerMessage();
    GetIndividualBaseResponse getIndividualBaseResponse = TestObjectBuilder.createIndividualBaseResponse();

    // Mock MCP REST call
    wireMockServer.stubFor(WireMock.get("/individuals/"   receivedMessage.getBncId()   "/base")
        .willReturn(aResponse()
            .withHeader("Content-Type", "application/json")
            .withBody(objectMapper.writeValueAsString(getIndividualBaseResponse))));

    // Mock ODS SOAP call
    Source requestPayload = new StringSource(TestObjectBuilder.createGetPreferencesRequestXML());
    Source responsePayload = new StringSource(TestObjectBuilder.createGetPreferencesResponseXML());
    mockServer.expect(payload(requestPayload)).andRespond(withPayload(responsePayload));

    sendMessage(receivedMessage, StreamAction.ACTION_GET);

    Message<String> sentMessageJson = (Message<String>) messageCollector.forChannel(mcpConnectorStream.outboundCustomerApi()).poll();
    assertNotNull(sentMessageJson);

    PaymentCommonsCustomer sentMessage = objectMapper.readValue(sentMessageJson.getPayload(), PaymentCommonsCustomer.class);

    assertEquals(receivedMessage.getMessageId(), sentMessage.getMessageId());
    assertEquals(receivedMessage.getTransactionDate(), sentMessage.getTransactionDate());
    assertEquals(receivedMessage.getLastPublishedDate(), sentMessage.getLastPublishedDate());
  }

  private void sendMessage(PaymentCommonsCustomer message, String action) throws Exception {
    mcpConnectorStream.inboundMcpConnector().send(MessageBuilder.withPayload(objectMapper.writeValueAsString(message)).setHeader("action", action).build());
  }

}
  

Если веб-служба SOAP запущена, то мой модульный тест работает нормально. Я что-то упускаю или делаю неправильно? Я использую Java 11 и JUnit 5.

Недавно у меня была аналогичная проблема. Проблема в вас WebServiceTemplate , вы создаете новый экземпляр каждый раз, когда вызываете свою службу.

Вместо этого попробуйте либо ввести WebServiceTemplate , либо использовать тот, который WebServiceGatewaySupport.getWebServiceTemplate() предоставляется по умолчанию, и не манипулируйте ничем из шаблона службы при вызове вашей службы.

Одна вещь, которая MockWebServiceServer.createServer(client) делает, это взять ваш шаблон сервиса и установить MockWebServiceMessageSender в качестве отправителя сообщения, который вам нужен, чтобы избежать фактического http-вызова, в вашем коде макет никогда не вызывался, потому что каждый раз создается новый экземпляр шаблона сервиса. Наконец, вам не понадобится WireMockServer