使用wiremock测试webflux代码时出现500个错误

Question

我有一个spring webflux应用程序，它的用户控制器类带有端点"/user和用户服务类。调用外部api的用户服务类。我正在尝试使用wiremock和junit 5来模拟外部api来测试服务类。然而，我得到以下错误->

021-07-30 18:22:52.511 ERROR 16974 --- [o-auto-1-exec-2] o.a.c.c.C.[.[.[/].[dispatcherServlet]    : Servlet.service() for servlet [dispatcherServlet] threw exception java.net.ConnectException: Connection refused

代码上传路径:https://github.com/neeleshsethi/wiremockdemp/tree/master

似乎它找不到控制器，因为在控制器中添加print语句不打印任何东西。下面是代码->

@Service
public class UserService {
@Autowired
WebClient webClient;
public Mono<User> createuser(User user) {
return  webClient.post()
.uri("/usercreate")
.contentType(MediaType.APPLICATION_JSON)
.accept(MediaType.APPLICATION_JSON)
.body(BodyInserters.fromValue(user))
.retrieve()
.bodyToMono(User.class);
}
}

WireMock配置类:

package com.example.wiremockdemo;

import com.github.tomakehurst.wiremock.WireMockServer;
import com.github.tomakehurst.wiremock.core.WireMockConfiguration;
import org.springframework.boot.test.util.TestPropertyValues;
import org.springframework.context.ApplicationContextInitializer;
import org.springframework.context.ConfigurableApplicationContext;
import org.springframework.context.event.ContextClosedEvent;
import java.util.Map;
public class WireMockInit implements ApplicationContextInitializer<ConfigurableApplicationContext> {

@Override
public void initialize(ConfigurableApplicationContext applicationContext) {
WireMockServer wireMockServer = new WireMockServer(new WireMockConfiguration().dynamicPort());
wireMockServer.start();
applicationContext.addApplicationListener( applicationEvent ->
{
if(applicationEvent instanceof ContextClosedEvent)
{
wireMockServer.stop();
}
}
);
applicationContext.getBeanFactory().registerSingleton("wireMockServer", wireMockServer);
TestPropertyValues.of("externalBaseUrl",wireMockServer.baseUrl()).applyTo(applicationContext);
}
}

测试类:

package com.example.wiremockdemo;
import com.example.wiremockdemo.model.User;
import com.github.tomakehurst.wiremock.WireMockServer;
import com.github.tomakehurst.wiremock.client.WireMock;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.boot.web.server.LocalServerPort;
import org.springframework.http.MediaType;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.web.reactive.server.WebTestClient;
import org.springframework.web.reactive.function.BodyInserters;
import reactor.core.publisher.Mono;
import java.awt.*;
import static com.github.tomakehurst.wiremock.client.WireMock.aResponse;
@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
@ContextConfiguration(initializers = {WireMockInit.class})
class WiremockdemoApplicationTests {
@Autowired
WebTestClient webTestClient;
@Autowired
private WireMockServer wireMockServer;
@LocalServerPort
private Integer port;

@Test
void createUsertest() {
System.out.println("Creating stub");
wireMockServer.stubFor(

WireMock.post("/usercreate")
.willReturn(
aResponse()
.withHeader("Content-Type", MediaType.APPLICATION_JSON_VALUE)
.withBodyFile("response.json"))

);

byte[] temp =   webTestClient.post()
.uri("http://localhost:" + port + "/user")
//    .uri("/user")
.contentType(MediaType.APPLICATION_JSON)
//.accept(MediaType.APPLICATION_JSON)
.body(BodyInserters.fromValue(createUser()))
.exchange()
.expectBody()
.returnResult()
.getResponseBody();
String s = new String(temp);
System.out.println("Response :" +s);    
}
public User createUser()
{
return  User.builder()
.firstName("neel")
.age(32)
.id(1234)
.build();
}
}

Answer 1

将这一行改为:

TestPropertyValues.of(Map.of("externalBaseUrl", wireMockServer.baseUrl()));

这是设置测试属性的正确方法。