[
https://issues.apache.org/jira/browse/HTTPASYNC-98?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunqi updated HTTPASYNC-98:
---------------------------
Attachment: TimeOutServlet.java
test.log
> http request throw SocketTimeoutException in 1 ms
> --------------------------------------------------
>
> Key: HTTPASYNC-98
> URL: https://issues.apache.org/jira/browse/HTTPASYNC-98
> Project: HttpComponents HttpAsyncClient
> Issue Type: Bug
> Affects Versions: Future
> Environment: httpasyncclient-4.0.2.jar
> httpclient-4.3.2.jar
> httpcore-4.3.2.jar
> httpcore-nio-4.3.2.jar
> jdk 1.7.0_75
> tomcat 7
> Reporter: sunqi
> Priority: Critical
> Attachments: TimeOutServlet.java, test.log
>
>
> use demo as this :
> package com.taobao.amdc.web.servlet;
> import java.io.IOException;
> import java.net.URI;
> import java.util.concurrent.CountDownLatch;
> import java.util.concurrent.TimeUnit;
> import java.util.concurrent.atomic.AtomicInteger;
> import javax.servlet.ServletException;
> import javax.servlet.http.HttpServlet;
> import javax.servlet.http.HttpServletRequest;
> import javax.servlet.http.HttpServletResponse;
> import org.apache.http.HttpResponse;
> import org.apache.http.HttpStatus;
> import org.apache.http.client.config.CookieSpecs;
> import org.apache.http.client.config.RequestConfig;
> import org.apache.http.client.methods.HttpGet;
> import org.apache.http.client.utils.URIBuilder;
> import org.apache.http.concurrent.FutureCallback;
> import org.apache.http.impl.nio.client.CloseableHttpAsyncClient;
> import org.apache.http.impl.nio.client.HttpAsyncClients;
> import org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager;
> import org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor;
> import org.apache.http.impl.nio.reactor.IOReactorConfig;
> import org.apache.http.nio.reactor.ConnectingIOReactor;
> import org.apache.http.nio.reactor.IOReactorException;
> import org.slf4j.Logger;
> import org.slf4j.LoggerFactory;
> public class TimeOutServlet extends HttpServlet {
>
> /**
> *
> */
> private static final long serialVersionUID = 1L;
> private CloseableHttpAsyncClient httpAsyncClient;
> private String healthCheckPath = "/status.taobao";
> private int port = 80;
> private static final Logger logger = LoggerFactory
> .getLogger(TimeOutServlet.class);
> @Override
> public void init() throws ServletException {
> IOReactorConfig ioReactorConfig =
> IOReactorConfig
> .custom()
> .setIoThreadCount(
> 2)
>
> .setSoKeepAlive(true)
> .build();
> ConnectingIOReactor ioReactor = null;
> try {
> ioReactor = new
> DefaultConnectingIOReactor(
> ioReactorConfig);
> } catch (IOReactorException e) {
> e.printStackTrace();
> }
> PoolingNHttpClientConnectionManager connManager
> = new PoolingNHttpClientConnectionManager(
> ioReactor);
> connManager.setMaxTotal(2048);
> connManager.setDefaultMaxPerRoute(100);
> if (connManager != null) {
> httpAsyncClient = HttpAsyncClients.custom()
>
> .setConnectionManager(connManager).build();
> httpAsyncClient.start();
> }
> }
>
>
> private static String ips[]={
> "1.1.1.1",
> "10.125.197.132",
> "2.2.2.2",
> "10.218.128.9",
> "3.3.3.3",
> "4.4.4.4"
> };
>
> private static String workIps[]={
>
> "100.81.0.149",
> "10.218.134.29",
> "10.218.129.215",
> "10.101.97.141"
> };
> public void doGet(HttpServletRequest req, HttpServletResponse res)
> throws ServletException, IOException {
> try {
> AtomicInteger count=new AtomicInteger(0);
>
> CountDownLatch cdl=new
> CountDownLatch(ips.length);
> for(String ip:ips){
> HttpGet h=buildHttpGet(ip);
> httpAsyncClient.execute(h, new
> CallBackHandler(h,cdl,count));
> }
> cdl.await(3000,TimeUnit.MILLISECONDS);
>
>
> CountDownLatch cdl1=new
> CountDownLatch(workIps.length);
> for(String ip:workIps){
> HttpGet h=buildHttpGet(ip);
> httpAsyncClient.execute(h, new
> CallBackHandler(h,cdl1,count));
> }
> cdl1.await(3000,TimeUnit.MILLISECONDS);
>
>
> res.getWriter().println("total ip:
> "+(ips.length+workIps.length)+" , success : "+count);
> } catch (Exception e) {
> }
> }
> private HttpGet buildHttpGet(String ip) {
> try {
> URI uri = new URIBuilder().setScheme("http").setHost(ip)
>
> .setPort(port).setPath(healthCheckPath).build();
> RequestConfig requestConfig = RequestConfig.custom()
> .setSocketTimeout(1000)
> .setConnectTimeout(500)
> .setConnectionRequestTimeout(500)
> .setStaleConnectionCheckEnabled(false)
>
> .setCookieSpec(CookieSpecs.IGNORE_COOKIES)
> .build();
> HttpGet httpGet = new HttpGet();
> httpGet.setURI(uri);
> httpGet.setConfig(requestConfig);
> return httpGet;
> } catch (Exception t) {
> logger.error(t.getMessage(), t);
> }
> return null;
> }
> class CallBackHandler implements FutureCallback<HttpResponse> {
>
> private long t;
> private HttpGet h;
> private CountDownLatch cdl;
> private AtomicInteger count;
> public CallBackHandler(HttpGet h,CountDownLatch
> cdl,AtomicInteger count) {
> this.cdl=cdl;
> this.h=h;
> this.t=System.currentTimeMillis();
> this.count=count;
> }
> @Override
> public void completed(HttpResponse result) {
> cdl.countDown();
> if (null == result || null == result.getStatusLine()
> || HttpStatus.SC_OK !=
> result.getStatusLine().getStatusCode()) {
> logger.error(h.toString()+" http response is
> null or statusCode is not 200");
> } else{
> count.incrementAndGet();
> }
> }
> @Override
> public void failed(Exception ex) {
> cdl.countDown();
> logger.error("request is failed: " + h.toString()+"
> time used : "+(System.currentTimeMillis()-t)+" ms", ex);
> }
> @Override
> public void cancelled() {
> cdl.countDown();
> logger.error("request is canceled {} ", h.toString());
> }
> }
> }
> the ip 1.1.1.1,2.2.2.2,3.3.3.3,4.4.4.4 is can't connected,and other ip is
> work,
> run many times ,we well find log as this :
> 2015-12-31 15:51:21 [ - ] UserAgent: ERROR servlet.TimeOutServlet - request
> is failed: GET http://4.4.4.4:80/status.taobao HTTP/1.1 time used : 1011 ms
> java.net.SocketTimeoutException
> at
> org.apache.http.nio.pool.RouteSpecificPool.timeout(RouteSpecificPool.java:170)
> at
> org.apache.http.nio.pool.AbstractNIOConnPool.requestTimeout(AbstractNIOConnPool.java:546)
> at
> org.apache.http.nio.pool.AbstractNIOConnPool$InternalSessionRequestCallback.timeout(AbstractNIOConnPool.java:779)
> at
> org.apache.http.impl.nio.reactor.SessionRequestImpl.timeout(SessionRequestImpl.java:177)
> at
> org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processTimeouts(DefaultConnectingIOReactor.java:212)
> at
> org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processEvents(DefaultConnectingIOReactor.java:157)
> at
> org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor.execute(AbstractMultiworkerIOReactor.java:348)
> at
> org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager.execute(PoolingNHttpClientConnectionManager.java:189)
> at
> org.apache.http.impl.nio.client.CloseableHttpAsyncClientBase.doExecute(CloseableHttpAsyncClientBase.java:67)
> at
> org.apache.http.impl.nio.client.CloseableHttpAsyncClientBase.access$000(CloseableHttpAsyncClientBase.java:38)
> at
> org.apache.http.impl.nio.client.CloseableHttpAsyncClientBase$1.run(CloseableHttpAsyncClientBase.java:57)
> at java.lang.Thread.run(Thread.java:745)
> 2015-12-31 15:51:21 [ - ] UserAgent: ERROR servlet.TimeOutServlet - request
> is failed: GET http://100.81.0.149:80/status.taobao HTTP/1.1 time used : 1 ms
> java.net.SocketTimeoutException
> at
> org.apache.http.nio.protocol.HttpAsyncRequestExecutor.timeout(HttpAsyncRequestExecutor.java:285)
> at
> org.apache.http.impl.nio.client.LoggingAsyncRequestExecutor.timeout(LoggingAsyncRequestExecutor.java:120)
> at
> org.apache.http.impl.nio.client.InternalIODispatch.onTimeout(InternalIODispatch.java:84)
> at
> org.apache.http.impl.nio.client.InternalIODispatch.onTimeout(InternalIODispatch.java:37)
> at
> org.apache.http.impl.nio.reactor.AbstractIODispatch.timeout(AbstractIODispatch.java:172)
> at
> org.apache.http.impl.nio.reactor.BaseIOReactor.sessionTimedOut(BaseIOReactor.java:255)
> at
> org.apache.http.impl.nio.reactor.AbstractIOReactor.timeoutCheck(AbstractIOReactor.java:491)
> at
> org.apache.http.impl.nio.reactor.BaseIOReactor.validate(BaseIOReactor.java:205)
> at
> org.apache.http.impl.nio.reactor.AbstractIOReactor.execute(AbstractIOReactor.java:281)
> at
> org.apache.http.impl.nio.reactor.BaseIOReactor.execute(BaseIOReactor.java:105)
> at
> org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor$Worker.run(AbstractMultiworkerIOReactor.java:584)
> at java.lang.Thread.run(Thread.java:745)
> 2015-12-31 15:51:21 [ - ] UserAgent: ERROR servlet.TimeOutServlet - request
> is failed: GET http://10.218.129.215:80/status.taobao HTTP/1.1 time used : 1
> ms
> java.net.SocketTimeoutException
> at
> org.apache.http.nio.protocol.HttpAsyncRequestExecutor.timeout(HttpAsyncRequestExecutor.java:285)
> at
> org.apache.http.impl.nio.client.LoggingAsyncRequestExecutor.timeout(LoggingAsyncRequestExecutor.java:120)
> at
> org.apache.http.impl.nio.client.InternalIODispatch.onTimeout(InternalIODispatch.java:84)
> at
> org.apache.http.impl.nio.client.InternalIODispatch.onTimeout(InternalIODispatch.java:37)
> at
> org.apache.http.impl.nio.reactor.AbstractIODispatch.timeout(AbstractIODispatch.java:172)
> at
> org.apache.http.impl.nio.reactor.BaseIOReactor.sessionTimedOut(BaseIOReactor.java:255)
> at
> org.apache.http.impl.nio.reactor.AbstractIOReactor.timeoutCheck(AbstractIOReactor.java:491)
> the work ip request throw java.net.SocketTimeoutException in 1ms
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
