import org.springframework.test.web.client.ResponseCreator; //导入依赖的package包/类
private ResponseCreator withHalJsonResponse(String fileName) {
    Resource jsonResponse = new ClassPathResource(fileName);
    return withSuccess(jsonResponse, APPLICATION_HAL_JSON);
}
 

import org.springframework.test.web.client.ResponseCreator; //导入依赖的package包/类
@Test
public void testInject() {
    String url = "http://localhost:4000/foo";
    mockServer.expect(MockRestRequestMatchers.requestTo(url))
            .andExpect(MockRestRequestMatchers.method(HttpMethod.GET))
            .andRespond(new ResponseCreator() {
                @Override
                public ClientHttpResponse createResponse(ClientHttpRequest request) throws IOException {
                    MockClientHttpResponse response =
                            new MockClientHttpResponse(new byte[1], HttpStatus.OK);

                    response.getHeaders().add("traceId", request.getHeaders()
                            .getFirst("traceId"));
                    response.getHeaders().add("spanId", request.getHeaders()
                            .getFirst("spanId"));
                    return response;
                }
            });

    ResponseEntity<String> responseEntity = client.getForEntity(url, String.class);

    List<MockSpan> mockSpans = mockTracer.finishedSpans();
    Assert.assertEquals(1, mockSpans.size());
    Assert.assertEquals(mockSpans.get(0).context().traceId(),
            Long.parseLong(responseEntity.getHeaders().getFirst("traceId")));
    Assert.assertEquals(mockSpans.get(0).context().spanId(),
            Long.parseLong(responseEntity.getHeaders().getFirst("spanId")));
}
 

import org.springframework.test.web.client.ResponseCreator; //导入依赖的package包/类
@Test
public void postBadRequestTest_400() throws Exception {
  ResponseCreator response = withBadRequest();
  this.mockServer.expect(requestTo("http://localhost:8080/kaaTest/post")).andExpect(method(HttpMethod.POST)).andRespond(response);
  String result = testMessage.getMessage(kaaRestTemplate, TestHttpMethods.POST);
  this.mockServer.verify();
  assertThat(result, allOf(containsString("FAILED")));
}
 

import org.springframework.test.web.client.ResponseCreator; //导入依赖的package包/类
@Test
public void putBadRequestTest_400() throws Exception {
  ResponseCreator response = withBadRequest();
  this.mockServer.expect(requestTo("http://localhost:8080/kaaTest/put")).andExpect(method(HttpMethod.PUT)).andRespond(response);
  String result = testMessage.getMessage(kaaRestTemplate, TestHttpMethods.PUT);
  this.mockServer.verify();
  assertThat(result, allOf(containsString("FAILED")));
}
 

import org.springframework.test.web.client.ResponseCreator; //导入依赖的package包/类
@Test
public void putSuccessRequestTest() throws Exception {
  ResponseCreator response = withSuccess();
  this.mockServer.expect(requestTo("http://localhost:8080/kaaTest/put")).andExpect(method(HttpMethod.PUT)).andRespond(response);
  String result = testMessage.getMessage(kaaRestTemplate, TestHttpMethods.PUT);
  this.mockServer.verify();
  assertThat(result, allOf(containsString("SUCCESS")));
}
 

import org.springframework.test.web.client.ResponseCreator; //导入依赖的package包/类
@Test
public void deleteSuccessRequestTest() throws Exception {
  ResponseCreator response = withSuccess();
  this.mockServer.expect(requestTo("http://localhost:8080/kaaTest/delete")).andExpect(method(HttpMethod.DELETE)).andRespond(response);
  String result = testMessage.getMessage(kaaRestTemplate, TestHttpMethods.DELETE);
  this.mockServer.verify();
  assertThat(result, allOf(containsString("SUCCESS")));
}
 

import org.springframework.test.web.client.ResponseCreator; //导入依赖的package包/类
@Test
public void deleteBadRequestTest_400() throws Exception {
  ResponseCreator response = withBadRequest();
  this.mockServer.expect(requestTo("http://localhost:8080/kaaTest/delete")).andExpect(method(HttpMethod.DELETE)).andRespond(response);
  String result = testMessage.getMessage(kaaRestTemplate, TestHttpMethods.DELETE);
  this.mockServer.verify();
  assertThat(result, allOf(containsString("FAILED"), containsString("400")));
}
 

import org.springframework.test.web.client.ResponseCreator; //导入依赖的package包/类
/**
 * Set the mock REST server to expect a GET request with the specified URL, and to return the specified response.
 * @param url               The URL to expect
 * @param responseCreator   Used to create the response to return
 */
private void mockServerRequest(String url, ResponseCreator responseCreator) {
    server.expect(requestTo(url)).andExpect(method(HttpMethod.GET)).andRespond(responseCreator);
}