AsyncHttpClient的默認(rèn)配置源碼流程解讀
序
本文主要研究一下AsyncHttpClient的默認(rèn)配置
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實(shí)現(xiàn)了AsyncHttpClientConfig接口,它還定義了一個(gè)Builder來用于創(chuàng)建AsyncHttpClient,其配置主要分為timeouts、keep-alive、ssl、cookie store、tuning、internals幾個(gè)部分,它們的默認(rèn)值讀取的是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默認(rèn)為5s、requestTimeout默認(rèn)為60s、readTimeout默認(rèn)為60s、shutdownQuietPeriod默認(rèn)為2s、shutdownTimeout默認(rèn)為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();
默認(rèn)開啟keepAlive、pooledConnectionIdleTimeout默認(rèn)為60s、connectionPoolCleanerPeriod默認(rèn)為1s、connectionTtl默認(rèn)為-1、maxConnectionsPerHost默認(rèn)為-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默認(rèn)為true、soReuseAddress默認(rèn)為false、soLinger、soSndBuf、soRcvBuf默認(rèn)為-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默認(rèn)為AsyncHttpClient、httpClientCodecMaxInitialLineLength默認(rèn)為4096、httpClientCodecMaxHeaderSize默認(rèn)為8192、httpClientCodecMaxChunkSize默認(rèn)為8192、httpClientCodecInitialBufferSize默認(rèn)為128、chunkedFileChunkSize默認(rèn)為8192、ioThreadsCount默認(rèn)為0
小結(jié)
DefaultAsyncHttpClientConfig實(shí)現(xiàn)了AsyncHttpClientConfig接口,它還定義了一個(gè)Builder來用于創(chuàng)建AsyncHttpClient,其配置主要分為timeouts、keep-alive、ssl、cookie store、tuning、internals幾個(gè)部分,它們的默認(rèn)值讀取的是jar包的ahc-default.properties的配置。
以上就是AsyncHttpClient的默認(rèn)配置源碼流程解讀的詳細(xì)內(nèi)容,更多關(guān)于AsyncHttpClient默認(rèn)配置的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章!
- AsyncHttpClient的TimeoutTimerTask連接池異步超時(shí)
- AsyncHttpClient?RequestFilter請(qǐng)求篩選源碼解讀
- AsyncHttpClient IOExceptionFilter異常過濾器
- AsyncHttpClient KeepAliveStrategy源碼流程解讀
- AsyncHttpClient exception異常源碼流程解析
- AsyncHttpClient?ChannelPool線程池頻道池源碼流程解析
- AsyncHttpClient的ConnectionSemaphore方法源碼流程解讀
- AsyncHttpClient?ClientStats源碼流程解讀
相關(guān)文章
springboot集成redis實(shí)現(xiàn)簡單秒殺系統(tǒng)
這篇文章主要為大家詳細(xì)介紹了springboot集成redis實(shí)現(xiàn)簡單秒殺系統(tǒng),文中示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2019-12-12spring cloud hystrix 超時(shí)時(shí)間使用方式詳解
這篇文章主要介紹了spring cloud hystrix 超時(shí)時(shí)間使用方式,本文給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2021-01-01mybatisPlus中apply的使用以進(jìn)行聯(lián)表等復(fù)雜sql語句詳解
在MyBatis-Plus中,`apply()`方法可以用于添加任意的SQL片段,包括聯(lián)表查詢,使用`apply()`方法的好處是可以直接添加原生的SQL片段,而不受MyBatis-Plus提供的常規(guī)查詢條件構(gòu)建方法的限制,但是,使用`apply()`方法需要注意安全性和性能問題2025-03-03java字符串比較獲取字符串出現(xiàn)次數(shù)的示例
java獲取一個(gè)字符串在整個(gè)字符串出現(xiàn)的次數(shù),下面寫出我的思路和二個(gè)實(shí)現(xiàn)方法,大家參考使用吧2014-01-01SpringBoot集成Spring Security的方法
Spring security,是一個(gè)強(qiáng)大的和高度可定制的身份驗(yàn)證和訪問控制框架。這篇文章主要介紹了SpringBoot集成Spring Security的操作方法,本文給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2020-07-07Java微信公眾號(hào)開發(fā)之通過微信公眾號(hào)獲取用戶信息
這篇文章主要介紹了Java微信公眾號(hào)開發(fā)之通過微信公眾號(hào)獲取用戶信息,需要的朋友可以參考下2017-05-05