自定义模式

testMode = 'CUSTOM'

import com.example.BeerRestBase;
import javax.inject.Inject;
import org.springframework.cloud.contract.verifier.http.HttpVerifier;
import org.springframework.cloud.contract.verifier.http.Request;
import org.springframework.cloud.contract.verifier.http.Response;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;

import static org.springframework.cloud.contract.verifier.assertion.SpringCloudContractAssertions.assertThat;
import static org.springframework.cloud.contract.verifier.util.ContractVerifierUtil.*;
import static org.springframework.cloud.contract.verifier.http.Request.given;

public class RestTest extends BeerRestBase {
	@Inject HttpVerifier httpVerifier;

	@Test
	public void validate_shouldGrantABeerIfOldEnough() throws Exception {
		// given:
			Request request = given()
					.post("/beer.BeerService/check")
					.scheme("HTTP")
					.protocol("h2_prior_knowledge")
					.header("Content-Type", "application/grpc")
					.header("te", "trailers")
					.body(fileToBytes(this, "shouldGrantABeerIfOldEnough_request_PersonToCheck_old_enough.bin"))
					.build();


		// when:
			Response response = httpVerifier.exchange(request);


		// then:
			assertThat(response.statusCode()).isEqualTo(200);
			assertThat(response.header("Content-Type")).matches("application/grpc.*");
			assertThat(response.header("grpc-encoding")).isEqualTo("identity");
			assertThat(response.header("grpc-accept-encoding")).isEqualTo("gzip");

		// and:
			assertThat(response.getBody().asByteArray()).isEqualTo(fileToBytes(this, "shouldGrantABeerIfOldEnough_response_Response_old_enough.bin"));
	}

}

@SpringBootTest(classes = BeerRestBase.Config.class,
		webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
public abstract class BeerRestBase {

	@Configuration
	@EnableAutoConfiguration
	static class Config {

		@Bean
		ProducerController producerController(PersonCheckingService personCheckingService) {
			return new ProducerController(personCheckingService);
		}

		@Bean
		PersonCheckingService testPersonCheckingService() {
			return argument -> argument.getAge() >= 20;
		}

		@Bean
		HttpVerifier httpOkVerifier(@LocalServerPort int port) {
			return new OkHttpHttpVerifier("localhost:" + port);
		}

	}
}