import org.springframework.cloud.netflix.ribbon.RibbonAutoConfiguration; //导入依赖的package包/类
@Test
public void testLoadBalancedRetryFactoryBean() {
	new ApplicationContextRunner()
		.withPropertyValues("ribbon.okhttp.enabled=true")
		.withConfiguration(AutoConfigurations.of(RibbonAutoConfiguration.class,
			LoadBalancerAutoConfiguration.class,
			HttpClientConfiguration.class, RibbonClientConfiguration.class))
		.withUserConfiguration(
			OkHttpLoadBalancingClientTests.OkHttpClientConfiguration.class)
		.run(context -> {
			Map<String, LoadBalancedRetryPolicyFactory> factories = context.getBeansOfType(LoadBalancedRetryPolicyFactory.class);
			assertThat(factories.values(), hasSize(1));
			assertThat(factories.values().toArray()[0], instanceOf(LoadBalancedRetryPolicyFactory.NeverRetryFactory.class));
			Map<String, OkHttpLoadBalancingClient> clients = context.getBeansOfType(OkHttpLoadBalancingClient.class);
			assertThat(clients.values(), hasSize(1));
			assertThat(clients.values().toArray()[0], instanceOf(OkHttpLoadBalancingClient.class));
		});
}
 

import org.springframework.cloud.netflix.ribbon.RibbonAutoConfiguration; //导入依赖的package包/类
private OkHttpClient getHttpClient(Class<?> defaultConfigurationClass,
								   IClientConfig configOverride,
								   SpringClientFactory factory) throws Exception {
	factory.setApplicationContext(new AnnotationConfigApplicationContext(
			RibbonAutoConfiguration.class, OkHttpClientConfiguration.class, defaultConfigurationClass));

	OkHttpLoadBalancingClient client = factory.getClient("service",
			OkHttpLoadBalancingClient.class);

	return client.getOkHttpClient(configOverride, false);
}
 

import org.springframework.cloud.netflix.ribbon.RibbonAutoConfiguration; //导入依赖的package包/类
@Test
public void testConnections() throws Exception {
	SpringClientFactory factory = new SpringClientFactory();
	factory.setApplicationContext(new AnnotationConfigApplicationContext(
			RibbonAutoConfiguration.class, Connections.class));
	RetryableRibbonLoadBalancingHttpClient client = factory.getClient("service",
			RetryableRibbonLoadBalancingHttpClient.class);

	HttpClient delegate = client.getDelegate();
	PoolingHttpClientConnectionManager connManager = (PoolingHttpClientConnectionManager) ReflectionTestUtils.getField(delegate, "connManager");
	assertThat(connManager.getMaxTotal(), is(101));
	assertThat(connManager.getDefaultMaxPerRoute(), is(201));
}
 

import org.springframework.cloud.netflix.ribbon.RibbonAutoConfiguration; //导入依赖的package包/类
private RequestConfig getBuiltRequestConfig(Class<?> defaultConfigurationClass,
											IClientConfig configOverride, SpringClientFactory factory)
		throws Exception {

	factory.setApplicationContext(new AnnotationConfigApplicationContext(HttpClientConfiguration.class,
			RibbonAutoConfiguration.class, defaultConfigurationClass));
	String serviceName = "foo";
	String host = serviceName;
	int port = 80;
	URI uri = new URI("http://" + host + ":" + port);
	CloseableHttpClient delegate = mock(CloseableHttpClient.class);
	RibbonLoadBalancingHttpClient client = factory.getClient("service",
			RibbonLoadBalancingHttpClient.class);

	ReflectionTestUtils.setField(client, "delegate", delegate);
	ReflectionTestUtils.setField(client, "lb", loadBalancer);
	CloseableHttpResponse httpResponse  = mock(CloseableHttpResponse.class);
	StatusLine statusLine = mock(StatusLine.class);
	doReturn(200).when(statusLine).getStatusCode();
	doReturn(statusLine).when(httpResponse).getStatusLine();
	given(delegate.execute(any(HttpUriRequest.class))).willReturn(
			httpResponse);
	RibbonApacheHttpRequest request = mock(RibbonApacheHttpRequest.class);
	doReturn(uri).when(request).getURI();
	doReturn(request).when(request).withNewUri(any(URI.class));
	given(request.toRequest(any(RequestConfig.class))).willReturn(
			mock(HttpUriRequest.class));

	client.execute(request, configOverride);

	ArgumentCaptor<RequestConfig> requestConfigCaptor = ArgumentCaptor
			.forClass(RequestConfig.class);
	verify(request, times(1)).toRequest(requestConfigCaptor.capture());
	return requestConfigCaptor.getValue();
}
 

import org.springframework.cloud.netflix.ribbon.RibbonAutoConfiguration; //导入依赖的package包/类
@Test
public void validLoadBalanced() {
	AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext(
			LoadBalancerAutoConfiguration.class,
			RibbonAutoConfiguration.class,
			FeignRibbonClientAutoConfiguration.class,
			GoodServiceIdConfiguration.class);
	assertNotNull(context.getBean(GoodServiceIdConfiguration.Client.class));
	context.close();
}
 

import org.springframework.cloud.netflix.ribbon.RibbonAutoConfiguration; //导入依赖的package包/类
@Before
public void setUp() {
	context = new SpringApplicationBuilder().web(false)
			.sources(RibbonAutoConfiguration.class, LoadBalancerAutoConfiguration.class, RibbonClientConfiguration.class,
					FeignRibbonClientAutoConfiguration.class).run();
}