AsyncHttpClient的默認配置源碼流程解讀
序
本文主要研究一下AsyncHttpClient的默認配置
maven
<dependency>
<groupId>org.asynchttpclient</groupId>
<artifactId>async-http-client</artifactId>
<version>2.2.0</version>
</dependency>AsyncHttpClientConfig
org/asynchttpclient/AsyncHttpClientConfig.java
public interface AsyncHttpClientConfig {
/**
* @return the version of AHC
*/
String getAhcVersion();
/**
* Return the name of {@link AsyncHttpClient}, which is used for thread naming and debugging.
*
* @return the name.
*/
String getThreadPoolName();
/**
* Return the maximum number of connections an {@link AsyncHttpClient} can handle.
*
* @return the maximum number of connections an {@link AsyncHttpClient} can handle.
*/
int getMaxConnections();
/**
* Return the maximum number of connections per hosts an {@link AsyncHttpClient} can handle.
*
* @return the maximum number of connections per host an {@link AsyncHttpClient} can handle.
*/
int getMaxConnectionsPerHost();
/**
* Return the maximum time in millisecond an {@link AsyncHttpClient} can wait when connecting to a remote host
*
* @return the maximum time in millisecond an {@link AsyncHttpClient} can wait when connecting to a remote host
*/
int getConnectTimeout();
/**
* Return the maximum time in millisecond an {@link AsyncHttpClient} can stay idle.
*
* @return the maximum time in millisecond an {@link AsyncHttpClient} can stay idle.
*/
int getReadTimeout();
/**
* Return the maximum time in millisecond an {@link AsyncHttpClient} will keep connection in pool.
*
* @return the maximum time in millisecond an {@link AsyncHttpClient} will keep connection in pool.
*/
int getPooledConnectionIdleTimeout();
/**
* @return the period in millis to clean the pool of dead and idle connections.
*/
int getConnectionPoolCleanerPeriod();
/**
* Return the maximum time in millisecond an {@link AsyncHttpClient} waits until the response is completed.
*
* @return the maximum time in millisecond an {@link AsyncHttpClient} waits until the response is completed.
*/
int getRequestTimeout();
/**
* Is HTTP redirect enabled
*
* @return true if enabled.
*/
boolean isFollowRedirect();
/**
* Get the maximum number of HTTP redirect
*
* @return the maximum number of HTTP redirect
*/
int getMaxRedirects();
/**
* Is the {@link ChannelPool} support enabled.
*
* @return true if keep-alive is enabled
*/
boolean isKeepAlive();
/**
* Return the USER_AGENT header value
*
* @return the USER_AGENT header value
*/
String getUserAgent();
/**
* Is HTTP compression enforced.
*
* @return true if compression is enforced
*/
boolean isCompressionEnforced();
/**
* Return the {@link java.util.concurrent.ThreadFactory} an {@link AsyncHttpClient} use for handling asynchronous response.
*
* @return the {@link java.util.concurrent.ThreadFactory} an {@link AsyncHttpClient} use for handling asynchronous response. If no {@link ThreadFactory} has been explicitly
* provided, this method will return <code>null</code>
*/
ThreadFactory getThreadFactory();
/**
* An instance of {@link ProxyServer} used by an {@link AsyncHttpClient}
*
* @return instance of {@link ProxyServer}
*/
ProxyServerSelector getProxyServerSelector();
/**
* Return an instance of {@link SslContext} used for SSL connection.
*
* @return an instance of {@link SslContext} used for SSL connection.
*/
SslContext getSslContext();
/**
* Return the current {@link Realm}
*
* @return the current {@link Realm}
*/
Realm getRealm();
/**
* Return the list of {@link RequestFilter}
*
* @return Unmodifiable list of {@link ResponseFilter}
*/
List<RequestFilter> getRequestFilters();
/**
* Return the list of {@link ResponseFilter}
*
* @return Unmodifiable list of {@link ResponseFilter}
*/
List<ResponseFilter> getResponseFilters();
/**
* Return the list of {@link java.io.IOException}
*
* @return Unmodifiable list of {@link java.io.IOException}
*/
List<IOExceptionFilter> getIoExceptionFilters();
/**
* Return cookie store that is used to store and retrieve cookies
*
* @return {@link CookieStore} object
*/
CookieStore getCookieStore();
/**
* Return the number of time the library will retry when an {@link java.io.IOException} is throw by the remote server
*
* @return the number of time the library will retry when an {@link java.io.IOException} is throw by the remote server
*/
int getMaxRequestRetry();
/**
* @return the disableUrlEncodingForBoundRequests
*/
boolean isDisableUrlEncodingForBoundRequests();
/**
* @return true if AHC is to use a LAX cookie encoder, eg accept illegal chars in cookie value
*/
boolean isUseLaxCookieEncoder();
/**
* In the case of a POST/Redirect/Get scenario where the server uses a 302 for the redirect, should AHC respond to the redirect with a GET or whatever the original method was.
* Unless configured otherwise, for a 302, AHC, will use a GET for this case.
*
* @return <code>true</code> if strict 302 handling is to be used, otherwise <code>false</code>.
*/
boolean isStrict302Handling();
/**
* @return the maximum time in millisecond an {@link AsyncHttpClient} will keep connection in the pool, or -1 to keep connection while possible.
*/
int getConnectionTtl();
boolean isUseOpenSsl();
boolean isUseInsecureTrustManager();
/**
* @return true to disable all HTTPS behaviors AT ONCE, such as hostname verification and SNI
*/
boolean isDisableHttpsEndpointIdentificationAlgorithm();
/**
* @return the array of enabled protocols
*/
String[] getEnabledProtocols();
/**
* @return the array of enabled cipher suites
*/
String[] getEnabledCipherSuites();
/**
* @return the size of the SSL session cache, 0 means using the default value
*/
int getSslSessionCacheSize();
/**
* @return the SSL session timeout in seconds, 0 means using the default value
*/
int getSslSessionTimeout();
//......
}AsyncHttpClientConfig接口定義了一系列獲取配置的接口,比如getMaxConnections、getConnectTimeout、getReadTimeout、getPooledConnectionIdleTimeout等
DefaultAsyncHttpClientConfig
org/asynchttpclient/DefaultAsyncHttpClientConfig.java
public class DefaultAsyncHttpClientConfig implements AsyncHttpClientConfig {
//......
public static class Builder {
// timeouts
// keep-alive
// ssl
// cookie store
// tuning
// internals
}
}DefaultAsyncHttpClientConfig實現(xiàn)了AsyncHttpClientConfig接口,它還定義了一個Builder來用于創(chuàng)建AsyncHttpClient,其配置主要分為timeouts、keep-alive、ssl、cookie store、tuning、internals幾個部分,它們的默認值讀取的是jar包的ahc-default.properties的配置
timeouts
// org.asynchttpclient.connectTimeout=5000
private int connectTimeout = defaultConnectTimeout();
// org.asynchttpclient.requestTimeout=60000
private int requestTimeout = defaultRequestTimeout();
// org.asynchttpclient.readTimeout=60000
private int readTimeout = defaultReadTimeout();
// org.asynchttpclient.shutdownQuietPeriod=2000
private int shutdownQuietPeriod = defaultShutdownQuietPeriod();
// org.asynchttpclient.shutdownTimeout=15000
private int shutdownTimeout = defaultShutdownTimeout();connectTimeout默認為5s、requestTimeout默認為60s、readTimeout默認為60s、shutdownQuietPeriod默認為2s、shutdownTimeout默認為15s
keep-alive
// org.asynchttpclient.keepAlive=true
private boolean keepAlive = defaultKeepAlive();
// org.asynchttpclient.pooledConnectionIdleTimeout=60000
private int pooledConnectionIdleTimeout = defaultPooledConnectionIdleTimeout();
// org.asynchttpclient.connectionPoolCleanerPeriod=1000
private int connectionPoolCleanerPeriod = defaultConnectionPoolCleanerPeriod();
// org.asynchttpclient.connectionTtl=-1
private int connectionTtl = defaultConnectionTtl();
// org.asynchttpclient.maxConnections=-1
private int maxConnections = defaultMaxConnections();
// org.asynchttpclient.maxConnectionsPerHost=-1
private int maxConnectionsPerHost = defaultMaxConnectionsPerHost();
private ChannelPool channelPool;
private KeepAliveStrategy keepAliveStrategy = new DefaultKeepAliveStrategy();默認開啟keepAlive、pooledConnectionIdleTimeout默認為60s、connectionPoolCleanerPeriod默認為1s、connectionTtl默認為-1、maxConnectionsPerHost默認為-1
tuning
// org.asynchttpclient.tcpNoDelay=true
private boolean tcpNoDelay = defaultTcpNoDelay();
// org.asynchttpclient.soReuseAddress=false
private boolean soReuseAddress = defaultSoReuseAddress();
// org.asynchttpclient.soLinger=-1
private int soLinger = defaultSoLinger();
// org.asynchttpclient.soSndBuf=-1
private int soSndBuf = defaultSoSndBuf();
// org.asynchttpclient.soRcvBuf=-1
private int soRcvBuf = defaultSoRcvBuf();tcpNoDelay默認為true、soReuseAddress默認為false、soLinger、soSndBuf、soRcvBuf默認為-1
internals
// org.asynchttpclient.threadPoolName=AsyncHttpClient
private String threadPoolName = defaultThreadPoolName();
// org.asynchttpclient.httpClientCodecMaxInitialLineLength=4096
private int httpClientCodecMaxInitialLineLength = defaultHttpClientCodecMaxInitialLineLength();
// org.asynchttpclient.httpClientCodecMaxHeaderSize=8192
private int httpClientCodecMaxHeaderSize = defaultHttpClientCodecMaxHeaderSize();
// org.asynchttpclient.httpClientCodecMaxChunkSize=8192
private int httpClientCodecMaxChunkSize = defaultHttpClientCodecMaxChunkSize();
// org.asynchttpclient.httpClientCodecInitialBufferSize=128
private int httpClientCodecInitialBufferSize = defaultHttpClientCodecInitialBufferSize();
// org.asynchttpclient.chunkedFileChunkSize=8192
private int chunkedFileChunkSize = defaultChunkedFileChunkSize();
// org.asynchttpclient.useNativeTransport=false
private boolean useNativeTransport = defaultUseNativeTransport();
private ByteBufAllocator allocator;
private Map<ChannelOption<Object>, Object> channelOptions = new HashMap<>();
private EventLoopGroup eventLoopGroup;
private Timer nettyTimer;
private ThreadFactory threadFactory;
private Consumer<Channel> httpAdditionalChannelInitializer;
private Consumer<Channel> wsAdditionalChannelInitializer;
private ResponseBodyPartFactory responseBodyPartFactory = ResponseBodyPartFactory.EAGER;
// org.asynchttpclient.ioThreadsCount=0
private int ioThreadsCount = defaultIoThreadsCount();threadPoolName默認為AsyncHttpClient、httpClientCodecMaxInitialLineLength默認為4096、httpClientCodecMaxHeaderSize默認為8192、httpClientCodecMaxChunkSize默認為8192、httpClientCodecInitialBufferSize默認為128、chunkedFileChunkSize默認為8192、ioThreadsCount默認為0
小結
DefaultAsyncHttpClientConfig實現(xiàn)了AsyncHttpClientConfig接口,它還定義了一個Builder來用于創(chuàng)建AsyncHttpClient,其配置主要分為timeouts、keep-alive、ssl、cookie store、tuning、internals幾個部分,它們的默認值讀取的是jar包的ahc-default.properties的配置。
以上就是AsyncHttpClient的默認配置源碼流程解讀的詳細內(nèi)容,更多關于AsyncHttpClient默認配置的資料請關注腳本之家其它相關文章!
- AsyncHttpClient的TimeoutTimerTask連接池異步超時
- AsyncHttpClient?RequestFilter請求篩選源碼解讀
- AsyncHttpClient IOExceptionFilter異常過濾器
- AsyncHttpClient KeepAliveStrategy源碼流程解讀
- AsyncHttpClient exception異常源碼流程解析
- AsyncHttpClient?ChannelPool線程池頻道池源碼流程解析
- AsyncHttpClient的ConnectionSemaphore方法源碼流程解讀
- AsyncHttpClient?ClientStats源碼流程解讀
相關文章
springboot集成redis實現(xiàn)簡單秒殺系統(tǒng)
這篇文章主要為大家詳細介紹了springboot集成redis實現(xiàn)簡單秒殺系統(tǒng),文中示例代碼介紹的非常詳細,具有一定的參考價值,感興趣的小伙伴們可以參考一下2019-12-12
spring cloud hystrix 超時時間使用方式詳解
這篇文章主要介紹了spring cloud hystrix 超時時間使用方式,本文給大家介紹的非常詳細,對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下2021-01-01
mybatisPlus中apply的使用以進行聯(lián)表等復雜sql語句詳解
在MyBatis-Plus中,`apply()`方法可以用于添加任意的SQL片段,包括聯(lián)表查詢,使用`apply()`方法的好處是可以直接添加原生的SQL片段,而不受MyBatis-Plus提供的常規(guī)查詢條件構建方法的限制,但是,使用`apply()`方法需要注意安全性和性能問題2025-03-03
java字符串比較獲取字符串出現(xiàn)次數(shù)的示例
java獲取一個字符串在整個字符串出現(xiàn)的次數(shù),下面寫出我的思路和二個實現(xiàn)方法,大家參考使用吧2014-01-01
SpringBoot集成Spring Security的方法
Spring security,是一個強大的和高度可定制的身份驗證和訪問控制框架。這篇文章主要介紹了SpringBoot集成Spring Security的操作方法,本文給大家介紹的非常詳細,對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下2020-07-07

