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

Question

我正在尝试编写一个集成测试，该测试的一部分需要模拟一个 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。

Answer 1

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

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

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