使用MockWebServiceServer测试Web服务客户端时出现WebServiceIOException

问题描述

我正在尝试编写集成测试，该测试的一部分需要模拟REST调用以及SOAP调用。 REST部分工作正常，我能够对此进行模拟。事实证明，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)

这是我的客户端类，该类扩展了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 Web服务已启动，则我的单元测试可以正常工作。有什么我想念的或做错的吗？我正在使用Java 11和JUnit 5。

解决方法

我最近遇到了类似的问题。问题在于您的 WebServiceTemplate，您每次调用服务时都会创建一个新实例。

相反，尝试注入 WebServiceTemplate 或使用 WebServiceGatewaySupport.getWebServiceTemplate() 默认提供的一个，并且在调用服务时不要操作服务模板中的任何内容。

MockWebServiceServer.createServer(client) 所做的一件事是获取您的服务模板并将 MockWebServiceMessageSender 设置为消息发送者，这是您需要避免实际 http 调用的消息发送者，在您的代码中模拟是从未被调用，因为每次都创建一个新的服务模板实例。最后，您不需要 WireMockServer