import feign.okhttp.OkHttpClient; //导入依赖的package包/类
@Bean
public Client feignClient() {
    RibbonClient.Builder builder = RibbonClient.builder();

    if (httpClient != null) {
        builder.delegate(new OkHttpClient(httpClient));
    } else {
        builder.delegate(new OkHttpClient());
    }

    if (lbClientFactory != null) {
        builder.lbClientFactory(lbClientFactory);
    }

    return builder.build();
}
 

import feign.okhttp.OkHttpClient; //导入依赖的package包/类
public static HystrixFeign.Builder simpleFeignBuilder() {
    JacksonDecoder decoder = new JacksonDecoder(defaultObjectMapper);
    return HystrixFeign.builder()
            .setterFactory(new DefaultSetterFactory())
            .logger(new Slf4jLogger())
            .logLevel(Logger.Level.FULL)
            .retryer(new Retryer.Default())
            .contract(new Contract.Default())
            .client(new OkHttpClient())
            .options(new Request.Options())
            .encoder(new JacksonEncoder(defaultObjectMapper))
            .decoder(decoder)
            .errorDecoder(new AccessApiErrorDecoder(decoder));
}
 

import feign.okhttp.OkHttpClient; //导入依赖的package包/类
@Test
public void buildClient() throws Exception {
    clientBuilder = new HttpClientBuilder(config);

    OkHttpClient client = (OkHttpClient) clientBuilder.buildClient();

    // Not much we can assert besides not null
    assertNotNull(client);
}
 

import feign.okhttp.OkHttpClient; //导入依赖的package包/类
protected Feign getClient() {
    return Feign.builder()
            .client(new TracingClient(new OkHttpClient(), mockTracer,
                    Collections.<FeignSpanDecorator>singletonList(new FeignSpanDecorator.StandardTags())))
            .retryer(new Retryer.Default(100, SECONDS.toMillis(1), NUMBER_OF_RETRIES))
            .build();
}
 

import feign.okhttp.OkHttpClient; //导入依赖的package包/类
/**
 * Startup weed manager.
 */
public void start() {
    leaderMasterUrl = assembleUrl(host, port);
    leaderMaster = Feign.builder()
            .client(new OkHttpClient())
            .decoder(new JacksonDecoder())
            .target(WeedMasterClient.class, String.format("http://%s", leaderMasterUrl));

    fetchMasters(leaderMaster.cluster());

    masterHealthCheckThread.start();
    volumeHealthCheckThread.start();
}
 

import feign.okhttp.OkHttpClient; //导入依赖的package包/类
/**
 * Fetch volume server.
 *
 * @param volumeId   Volume id.
 * @param collection Collection.
 * @return ids.
 */
private Set<String> fetchVolume(int volumeId, String collection) {
    Locations locations = getMasterClient().lookup(volumeId, collection);
    Set<String> ids = new HashSet<>();
    locations.getLocations().forEach(location -> {
        final String id = String.format("%s#%s", location.getUrl(), location.getUrl());
        ids.add(id);
        volumeClients.putIfAbsent(id, Feign.builder()
                .client(new OkHttpClient())
                .decoder(new JacksonDecoder())
                .target(WeedVolumeClient.class, String.format("http://%s", location.getPublicUrl())));
    });
    return ids;
}
 

import feign.okhttp.OkHttpClient; //导入依赖的package包/类
/**
 * Fetch master cluster information.
 *
 * @param cluster Master cluster information.
 */
private void fetchMasters(Cluster cluster) {
    if (!leaderMasterUrl.equals(cluster.getLeader())) {
        leaderMasterUrl = cluster.getLeader();
        log.info("Weed leader master server is change to [{}]", leaderMasterUrl);
        leaderMaster = Feign.builder()
                .client(new OkHttpClient())
                .decoder(new JacksonDecoder())
                .target(WeedMasterClient.class, String.format("http://%s", leaderMaster));
    }

    // Cleanup peer master
    Set<String> removeSet = peerMasters.keySet().stream().filter(
            key -> !cluster.getPeers().contains(key) && !cluster.getLeader().equals(key))
            .collect(Collectors.toSet());

    peerMasters.remove(leaderMasterUrl);
    removeSet.forEach(key -> peerMasters.remove(key));

    cluster.getPeers().forEach(url -> {
        if (!peerMasters.containsKey(url)) {
            peerMasters.put(url,
                    Feign.builder()
                            .client(new OkHttpClient())
                            .decoder(new JacksonDecoder())
                            .target(WeedMasterClient.class, String.format("http://%s", url)));
        }
    });
}
 

import feign.okhttp.OkHttpClient; //导入依赖的package包/类
@Before
public void setup(){

    ObjectMapper esClientMapper = new ObjectMapper()
            .configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false)
            .setPropertyNamingStrategy(PropertyNamingStrategy.CAMEL_CASE_TO_LOWER_CASE_WITH_UNDERSCORES);

    esClient = Feign.builder()
            .client(new OkHttpClient())
            .decoder(new JacksonDecoder(esClientMapper))
            .encoder(new BodyStringEncoder(esClientMapper))
            .target(ESClient.class, "http://localhost:9222");
}
 

import feign.okhttp.OkHttpClient; //导入依赖的package包/类
@Override
public Object postProcessBeforeInitialization(Object bean, String beanName)
		throws BeansException {
	if (bean instanceof OkHttpClient) {
		return getTraceFeignObjectWrapper().wrap(bean);
	}
	return bean;
}
 

import feign.okhttp.OkHttpClient; //导入依赖的package包/类
@Bean
public okhttp3.OkHttpClient client(OkHttpClientFactory httpClientFactory,
								   ConnectionPool connectionPool, FeignHttpClientProperties httpClientProperties) {
	Boolean followRedirects = httpClientProperties.isFollowRedirects();
	Integer connectTimeout = httpClientProperties.getConnectionTimeout();
	this.okHttpClient = httpClientFactory.createBuilder(false).
			connectTimeout(connectTimeout, TimeUnit.MILLISECONDS).
			followRedirects(followRedirects).
			connectionPool(connectionPool).build();
	return this.okHttpClient;
}
 

import feign.okhttp.OkHttpClient; //导入依赖的package包/类
@Bean
@ConditionalOnMissingBean(Client.class)
public Client feignClient(CachingSpringLoadBalancerFactory cachingFactory,
						  SpringClientFactory clientFactory, okhttp3.OkHttpClient okHttpClient) {
	OkHttpClient delegate = new OkHttpClient(okHttpClient);
	return new LoadBalancerFeignClient(delegate, cachingFactory, clientFactory);
}
 

import feign.okhttp.OkHttpClient; //导入依赖的package包/类
@Bean
public okhttp3.OkHttpClient client(OkHttpClientFactory httpClientFactory,
								   ConnectionPool connectionPool, FeignHttpClientProperties httpClientProperties) {
	Boolean followRedirects = httpClientProperties.isFollowRedirects();
	Integer connectTimeout = httpClientProperties.getConnectionTimeout();
	Boolean disableSslValidation = httpClientProperties.isDisableSslValidation();
	this.okHttpClient = httpClientFactory.createBuilder(disableSslValidation).
			connectTimeout(connectTimeout, TimeUnit.MILLISECONDS).
			followRedirects(followRedirects).
			connectionPool(connectionPool).build();
	return this.okHttpClient;
}
 

import feign.okhttp.OkHttpClient; //导入依赖的package包/类
@Bean
Feign.Builder customFeignBuilder() {
    return Feign.builder().client(new OkHttpClient(customOkHttpClient));
}
 

import feign.okhttp.OkHttpClient; //导入依赖的package包/类
@Bean
public OkHttpClient myOkHttpClient() {
	return new OkHttpClient();
}
 

import feign.okhttp.OkHttpClient; //导入依赖的package包/类
@Bean
@ConditionalOnMissingBean(Client.class)
public Client feignClient() {
	return new OkHttpClient(this.okHttpClient);
}