如何解决使用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
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。