import com.mashape.unirest.http.options.Options; //导入依赖的package包/类
/**
 * configures the rest engine
 */
@Override
public void configure(final BreinConfig config) {
    final long connectionTimeout = config.getConnectionTimeout();
    final long socketTimeout = config.getSocketTimeout();

    if (connectionTimeout != 0 && socketTimeout != 0) {
        Options.refresh();
        Unirest.setTimeouts(connectionTimeout, socketTimeout);

        // we need to warm-up Unirest, see https://github.com/Mashape/unirest-java/issues/92
        final Future<HttpResponse<String>> future = Unirest
                .get("https://www.breinify.com").asStringAsync();

        while (!future.isDone()) {
            // wait for the request to return
        }
    }
}
 

import com.mashape.unirest.http.options.Options; //导入依赖的package包/类
@BeforeClass
public static void setupProxying() {
    DnsResolver dnsResolver = prepareProxiedDnsResolver();
    DefaultSchemePortResolver schemePortResolver = prepareSchemePortResolver();
    BasicHttpClientConnectionManager connManager = prepareConnectionManager(dnsResolver, schemePortResolver);
    HttpClient httpClient = prepareHttpClient(connManager);
    originalHttpClient = (HttpClient) Options.getOption(Option.HTTPCLIENT);
    Unirest.setHttpClient(httpClient);
}
 

import com.mashape.unirest.http.options.Options; //导入依赖的package包/类
/**
 * Set the connection timeout and socket timeout
 */
public static void setTimeouts(long connectionTimeout, long socketTimeout) {
	Options.setOption(Option.CONNECTION_TIMEOUT, connectionTimeout);
	Options.setOption(Option.SOCKET_TIMEOUT, socketTimeout);
	
	// Reload the client implementations
	Options.refresh();
}
 

import com.mashape.unirest.http.options.Options; //导入依赖的package包/类
/**
 * Set default header
 */
@SuppressWarnings("unchecked")
public static void setDefaultHeader(String name, String value) {
	Object headers = Options.getOption(Option.DEFAULT_HEADERS);
	if (headers == null) {
		headers = new HashMap<String, String>();
	}
	((Map<String, String>) headers).put(name, value);
	Options.setOption(Option.DEFAULT_HEADERS, headers);
}
 

import com.mashape.unirest.http.options.Options; //导入依赖的package包/类
private void refreshUnirestConnection() {
	Connection.closeAll();
	Options.refresh();
}
 

import com.mashape.unirest.http.options.Options; //导入依赖的package包/类
public static HttpClient getHttpClient() {
	return (HttpClient) Options.getOption(Option.HTTPCLIENT);
}
 

import com.mashape.unirest.http.options.Options; //导入依赖的package包/类
public static CloseableHttpAsyncClient getAsyncHttpClient() {
	return (CloseableHttpAsyncClient) Options.getOption(Option.ASYNCHTTPCLIENT);
}
 

import com.mashape.unirest.http.options.Options; //导入依赖的package包/类
/**
 * Set the HttpClient implementation to use for every synchronous request
 */
public static void setHttpClient(HttpClient httpClient) {
	Options.setOption(Option.HTTPCLIENT, httpClient);
}
 

import com.mashape.unirest.http.options.Options; //导入依赖的package包/类
/**
 * Clear default headers
 */
public static void clearDefaultHeaders() {
	Options.setOption(Option.DEFAULT_HEADERS, null);
}
 

import com.mashape.unirest.http.options.Options; //导入依赖的package包/类
/**
 * Set the asynchronous AbstractHttpAsyncClient implementation to use for every asynchronous request
 */
public static void setAsyncHttpClient(CloseableHttpAsyncClient asyncHttpClient) {
	Options.setOption(Option.ASYNCHTTPCLIENT, asyncHttpClient);
}
 

import com.mashape.unirest.http.options.Options; //导入依赖的package包/类
/**
 * Close the asynchronous client and its event loop. Use this method to close all the threads and allow an application to exit.  
 */
public static void shutdown() throws IOException {
	CloseableHttpAsyncClient asyncClient = (CloseableHttpAsyncClient) Options.getOption(Option.ASYNCHTTPCLIENT);
	if (asyncClient.isRunning()) asyncClient.close();
}
 

import com.mashape.unirest.http.options.Options; //导入依赖的package包/类
/**
 * With some frameworks it is necessary to refresh the unirest connection pool state
 * during runtime. This method does just that.
 */
public void startup() {
    Options.refresh();
}