我正在尝试使用Spring 5路由的rest服务使用Spring云合约，但它不起作用。我在客户端，我正在尝试在junit测试中使用存根运行器。如果我使用我的经典@RestController并通量，它可以正常工作，但如果我尝试使用RouterFunction更改控制器，它不起作用，我获得404。这是我的示例代码。
pom. xml
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.0.5.RELEASE</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<dependencies>
...
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-contract-stub-runner</artifactId>
<scope>test</scope>
</dependency>
</dependencies>
Routing.java
@Configuration
@EnableWebFlux
public class Routing {
@Autowired
private TestLoginController loginController;
@Bean
public HttpHandler routerFunction() {
return WebHttpHandlerBuilder
.webHandler(RouterFunctions.toWebHandler(createRouterFunction()))
.build();
}
private RouterFunction<ServerResponse> createRouterFunction() {
return route(POST("/testlogin"), loginController::testLogin);
}
}
TestLoginController.java
@Component
public class TestLoginController {
@Autowired
private TestLoginService testLoginService;
public Mono<ServerResponse> testLogin(ServerRequest request) {
return Mono.just(request)
.flatMap(req -> ServerResponse.ok()
.body(testLoginService.testLogin(request.bodyToMono(LoginRequest.class)), LoginResponse.class)
);
}
}
DemoApplicationTest.java
@RunWith(SpringRunner.class)
@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
@AutoConfigureStubRunner(ids = {"groupId:artifactId:+:stubs:8090"},
stubsMode = StubRunnerProperties.StubsMode.LOCAL)
public class DemoApplicationTests {
@LocalServerPort
private int port;
@Test
public void contextLoads() throws Exception {
LoginRequest request = new LoginRequest();
WebTestClient
.bindToServer()
.baseUrl("http://localhost:" + port)
.build()
.post()
.uri("testlogin").accept(MediaType.APPLICATION_JSON)
.body(BodyInserters.fromObject(request))
.exchange()
.expectStatus().isOk()
.expectBody()
....
}
}
我有同样的问题，即使我删除@AutoConfigreStubRunner注释。如果我只添加存根运行器依赖项，我认为这种行为，我发现这个问题。我也尝试使用最新版本的Spring启动和Spring云合约，但我有同样的问题。有人能帮我吗？
Spring Cloud合约Stub Runner只是在给定（或随机端口）上启动WireMock服务器。Stub Runner不会发生与WebTestClient相关的任何事情。换句话说，您很可能错误地配置了WebTestClient。
让我们试着确保你没有滥用这个项目。如果你有服务A通过WebClient调用服务B，那么服务B应该定义合同，从中创建测试和跨度。然后在服务A端，你将使用Spring Cloud合同存根运行器来启动服务B的存根。无论你使用什么（RestTemplate、WebClient等），你仍然会向我们为你启动的WireMock服务器发送一个HTTP调用。
如何在WebTestClient中使用Spring Cloud合同存根运行器的示例（取自：https://github.com/spring-cloud-samples/spring-cloud-contract-samples/blob/master/consumer/src/test/java/com/example/BeerControllerWebClientTest.java）
package com.example;
import java.util.Objects;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.boot.test.autoconfigure.json.AutoConfigureJsonTesters;
import org.springframework.boot.test.autoconfigure.web.servlet.AutoConfigureMockMvc;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.boot.test.context.SpringBootTest.WebEnvironment;
import org.springframework.cloud.contract.stubrunner.spring.AutoConfigureStubRunner;
import org.springframework.cloud.contract.stubrunner.spring.StubRunnerPort;
import org.springframework.cloud.contract.stubrunner.spring.StubRunnerProperties;
import org.springframework.test.annotation.DirtiesContext;
import org.springframework.test.context.junit4.SpringRunner;
import org.springframework.test.web.reactive.server.WebTestClient;
/**
* @author Marcin Grzejszczak
*/
@RunWith(SpringRunner.class)
@SpringBootTest(webEnvironment = WebEnvironment.MOCK)
@AutoConfigureMockMvc
@AutoConfigureJsonTesters
//remove::start[]
@AutoConfigureStubRunner(stubsMode = StubRunnerProperties.StubsMode.LOCAL, ids = "com.example:beer-api-producer-webflux")
//remove::end[]
@DirtiesContext
//@org.junit.Ignore
public class BeerControllerWebClientTest extends AbstractTest {
//remove::start[]
@StubRunnerPort("beer-api-producer-webflux") int producerPort;
//remove::end[]
@Test public void should_give_me_a_beer_when_im_old_enough() throws Exception {
//remove::start[]
WebTestClient.bindToServer()
.build()
.post()
.uri("http://localhost:" + producerPort + "/check")
.syncBody(new WebClientPerson("marcin", 22))
.header("Content-Type", "application/json")
.exchange()
.expectStatus().is2xxSuccessful()
.expectBody(WebClientResponse.class)
.isEqualTo(new WebClientResponse(WebClientResponseStatus.OK));
//remove::end[]
}
@Test public void should_reject_a_beer_when_im_too_young() throws Exception {
//remove::start[]
WebTestClient.bindToServer()
.build()
.post()
.uri("http://localhost:" + producerPort + "/check")
.syncBody(new WebClientPerson("marcin", 17))
.header("Content-Type", "application/json")
.exchange()
.expectStatus().is2xxSuccessful()
.expectBody(WebClientResponse.class)
.isEqualTo(new WebClientResponse(WebClientResponseStatus.NOT_OK));
//remove::end[]
}
}
class WebClientPerson {
public String name;
public int age;
public WebClientPerson(String name, int age) {
this.name = name;
this.age = age;
}
public WebClientPerson() {
}
}
class WebClientResponse {
public WebClientResponseStatus status;
WebClientResponse(WebClientResponseStatus status) {
this.status = status;
}
WebClientResponse() {
}
@Override
public boolean equals(Object o) {
if (this == o) return true;
if (o == null || getClass() != o.getClass()) return false;
WebClientResponse that = (WebClientResponse) o;
return status == that.status;
}
@Override
public int hashCode() {
return Objects.hash(status);
}
}
enum WebClientResponseStatus {
OK, NOT_OK
}
