import org.springframework.mock.http.client.MockClientHttpRequest; //导入依赖的package包/类
@Override
public void run() {
    MockClientHttpRequest request = new MockClientHttpRequest();
    MockClientHttpResponse response = new MockClientHttpResponse(new byte[0], HttpStatus.OK);
    ClientHttpRequestExecution execution = mock(ClientHttpRequestExecution.class);

    response.getHeaders().add("X-RateLimit-Remaining", "50");
    response.getHeaders().add("X-RateLimit-Reset", String.valueOf((System.currentTimeMillis() / 1000) + 1));

    try {
        when(execution.execute(request, new byte[0])).thenReturn(response);

        this.interceptor.intercept(request, new byte[0], execution);
    } catch (IOException e) {
    } finally {
        this.latch.countDown();
    }
}
 

import org.springframework.mock.http.client.MockClientHttpRequest; //导入依赖的package包/类
@Test
public void block() throws InterruptedException, IOException {
    CountDownLatch latch = new CountDownLatch(1);

    MockClientHttpRequest request = new MockClientHttpRequest();
    MockClientHttpResponse response = new MockClientHttpResponse(new byte[0], HttpStatus.OK);
    ClientHttpRequestExecution execution = mock(ClientHttpRequestExecution.class);

    request.setMethod(HttpMethod.GET);
    request.setURI(URI.create("http://localhost"));

    when(execution.execute(request, new byte[0])).thenReturn(response);

    new Thread(new Trigger(this.interceptor, latch)).start();
    latch.await();

    this.interceptor.intercept(request, new byte[0], execution);
}
 

import org.springframework.mock.http.client.MockClientHttpRequest; //导入依赖的package包/类
@Test
public void canBufferResponses() throws IOException
{
	MockClientHttpRequest request = new MockClientHttpRequest();
	MockClientHttpResponse response = new MockClientHttpResponse(singleUseStream("hello".getBytes()), OK);
	request.setResponse(response);
	when(requestFactory.createRequest(URI.create("http://example.com"), GET)).thenReturn(request);
	
	loggingCustomizer.customize(restTemplate);
	
	ClientHttpResponse actualResponse = restTemplate.getRequestFactory()
		.createRequest(URI.create("http://example.com"), GET)
		.execute();
	assertThat(copyToByteArray(actualResponse.getBody()), equalTo("hello".getBytes()));
}
 

import org.springframework.mock.http.client.MockClientHttpRequest; //导入依赖的package包/类
@Test
public void canLogRequestUsingDefaultCharset() throws IOException, URISyntaxException
{
	MockClientHttpRequest request = new MockClientHttpRequest(POST, new URI("/hello"));
	byte[] body = "world £".getBytes(ISO_8859_1);
	when(execution.execute(request, body)).thenReturn(new MockClientHttpResponse(new byte[0], OK));
	
	loggingInterceptor.intercept(request, body, execution);
	
	verify(log).debug("Request: POST /hello world £");
}
 

import org.springframework.mock.http.client.MockClientHttpRequest; //导入依赖的package包/类
@Test
public void canLogRequestUsingCharset() throws IOException, URISyntaxException
{
	MockClientHttpRequest request = new MockClientHttpRequest(POST, new URI("/hello"));
	request.getHeaders().setContentType(parseMediaType("text/plain;charset=UTF-8"));
	byte[] body = "world £".getBytes(UTF_8);
	when(execution.execute(request, body)).thenReturn(new MockClientHttpResponse(new byte[0], OK));
	
	loggingInterceptor.intercept(request, body, execution);
	
	verify(log).debug("Request: POST /hello world £");
}
 

import org.springframework.mock.http.client.MockClientHttpRequest; //导入依赖的package包/类
@Test
public void canLogResponseUsingDefaultCharset() throws IOException, URISyntaxException
{
	MockClientHttpRequest request = new MockClientHttpRequest();
	byte[] body = "hello £".getBytes(ISO_8859_1);
	when(execution.execute(request, new byte[0])).thenReturn(new MockClientHttpResponse(body, OK));
	
	loggingInterceptor.intercept(request, new byte[0], execution);
	
	verify(log).debug("Response: 200 hello £");
}
 

import org.springframework.mock.http.client.MockClientHttpRequest; //导入依赖的package包/类
@Test
public void canLogResponseUsingCharset() throws IOException, URISyntaxException
{
	MockClientHttpRequest request = new MockClientHttpRequest();
	byte[] body = "hello £".getBytes(UTF_8);
	MockClientHttpResponse response = new MockClientHttpResponse(body, OK);
	response.getHeaders().setContentType(parseMediaType("text/plain;charset=UTF-8"));
	when(execution.execute(request, new byte[0])).thenReturn(response);
	
	loggingInterceptor.intercept(request, new byte[0], execution);
	
	verify(log).debug("Response: 200 hello £");
}
 

import org.springframework.mock.http.client.MockClientHttpRequest; //导入依赖的package包/类
private RequestMatcher aqlContent(String buildName, String buildNumber) {
	return (request) -> {
		String body = ((MockClientHttpRequest) request).getBodyAsString();
		Matcher matcher = AQL_PATTERN.matcher(body);
		assertThat(matcher.matches()).isTrue();
		String actualJson = matcher.group(1);
		String expectedJson = "{\"@build.name\": \"" + buildName
				+ "\", \"@build.number\": \"" + buildNumber + "\"}";
		assertJson(expectedJson, actualJson);
	};
}
 

import org.springframework.mock.http.client.MockClientHttpRequest; //导入依赖的package包/类
private RequestMatcher jsonContent(Resource expected) {
	return (request) -> {
		String actualJson = ((MockClientHttpRequest) request).getBodyAsString();
		String expectedJson = FileCopyUtils.copyToString(new InputStreamReader(
				expected.getInputStream(), Charset.forName("UTF-8")));
		assertJson(actualJson, expectedJson);
	};
}
 

import org.springframework.mock.http.client.MockClientHttpRequest; //导入依赖的package包/类
/**
 * Apply the XPath and assert it with the given {@code Matcher<Node>}.
 */
public <T> RequestMatcher node(final Matcher<? super Node> matcher) {
	return new AbstractXpathRequestMatcher() {
		@Override
		protected void matchInternal(MockClientHttpRequest request) throws Exception {
			xpathHelper.assertNode(request.getBodyAsBytes(), DEFAULT_ENCODING, matcher);
		}
	};
}
 

import org.springframework.mock.http.client.MockClientHttpRequest; //导入依赖的package包/类
/**
 * Assert that content exists at the given XPath.
 */
public <T> RequestMatcher exists() {
	return new AbstractXpathRequestMatcher() {
		@Override
		protected void matchInternal(MockClientHttpRequest request) throws Exception {
			xpathHelper.exists(request.getBodyAsBytes(), DEFAULT_ENCODING);
		}
	};
}
 

import org.springframework.mock.http.client.MockClientHttpRequest; //导入依赖的package包/类
/**
 * Assert that content does not exist at the given XPath.
 */
public <T> RequestMatcher doesNotExist() {
	return new AbstractXpathRequestMatcher() {
		@Override
		protected void matchInternal(MockClientHttpRequest request) throws Exception {
			xpathHelper.doesNotExist(request.getBodyAsBytes(), DEFAULT_ENCODING);
		}
	};
}
 

import org.springframework.mock.http.client.MockClientHttpRequest; //导入依赖的package包/类
/**
 * Apply the XPath and assert the number of nodes found with the given
 * {@code Matcher<Integer>}.
 */
public <T> RequestMatcher nodeCount(final Matcher<Integer> matcher) {
	return new AbstractXpathRequestMatcher() {
		@Override
		protected void matchInternal(MockClientHttpRequest request) throws Exception {
			xpathHelper.assertNodeCount(request.getBodyAsBytes(), DEFAULT_ENCODING, matcher);
		}
	};
}
 

import org.springframework.mock.http.client.MockClientHttpRequest; //导入依赖的package包/类
/**
 * Apply the XPath and assert the String content found with the given matcher.
 */
public <T> RequestMatcher string(final Matcher<? super String> matcher) {
	return new AbstractXpathRequestMatcher() {
		@Override
		protected void matchInternal(MockClientHttpRequest request) throws Exception {
			xpathHelper.assertString(request.getBodyAsBytes(), DEFAULT_ENCODING, matcher);
		}
	};
}
 

import org.springframework.mock.http.client.MockClientHttpRequest; //导入依赖的package包/类
/**
 * Apply the XPath and assert the number found with the given matcher.
 */
public <T> RequestMatcher number(final Matcher<? super Double> matcher) {
	return new AbstractXpathRequestMatcher() {
		@Override
		protected void matchInternal(MockClientHttpRequest request) throws Exception {
			xpathHelper.assertNumber(request.getBodyAsBytes(), DEFAULT_ENCODING, matcher);
		}
	};
}
 

import org.springframework.mock.http.client.MockClientHttpRequest; //导入依赖的package包/类
/**
 * Apply the XPath and assert the boolean value found.
 */
public <T> RequestMatcher booleanValue(final Boolean value) {
	return new AbstractXpathRequestMatcher() {
		@Override
		protected void matchInternal(MockClientHttpRequest request) throws Exception {
			xpathHelper.assertBoolean(request.getBodyAsBytes(), DEFAULT_ENCODING, value);
		}
	};
}
 

import org.springframework.mock.http.client.MockClientHttpRequest; //导入依赖的package包/类
@Override
public final void match(ClientHttpRequest request) throws IOException, AssertionError {
	try {
		MockClientHttpRequest mockRequest = (MockClientHttpRequest) request;
		matchInternal(mockRequest);
	}
	catch (Exception e) {
		throw new AssertionError("Failed to parse XML request content: " + e.getMessage());
	}
}
 

import org.springframework.mock.http.client.MockClientHttpRequest; //导入依赖的package包/类
/**
 * Get the body of the request as a UTF-8 string and appply the given {@link Matcher}.
 */
public RequestMatcher string(final Matcher<? super String> matcher) {
	return new RequestMatcher() {
		@Override
		public void match(ClientHttpRequest request) throws IOException, AssertionError {
			MockClientHttpRequest mockRequest = (MockClientHttpRequest) request;
			assertThat("Request content", mockRequest.getBodyAsString(), matcher);
		}
	};
}
 

import org.springframework.mock.http.client.MockClientHttpRequest; //导入依赖的package包/类
/**
 * Compare the body of the request to the given byte array.
 */
public RequestMatcher bytes(final byte[] expectedContent) {
	return new RequestMatcher() {
		@Override
		public void match(ClientHttpRequest request) throws IOException, AssertionError {
			MockClientHttpRequest mockRequest = (MockClientHttpRequest) request;
			assertEquals("Request content", expectedContent, mockRequest.getBodyAsBytes());
		}
	};
}
 

import org.springframework.mock.http.client.MockClientHttpRequest; //导入依赖的package包/类
/**
 * Parse the request content as {@link Node} and apply the given {@link Matcher}.
 */
public RequestMatcher node(final Matcher<? super Node> matcher) {
	return new AbstractXmlRequestMatcher() {
		@Override
		protected void matchInternal(MockClientHttpRequest request) throws Exception {
			xmlHelper.assertNode(request.getBodyAsString(), matcher);
		}
	};
}