2

我陷入了这种奇怪的情况，有时我的 HTTP 请求没有发出，或者我偶尔没有收到对我的请求的 HTTP 响应。我的应用程序会定期向其他 3rd 方服务发出几个（100 次）http 请求，其中大部分都可以正常工作。我使用带有自定义 HttpRequestIntercerptor 和 HttpResponseInterceptor 的 CloseableHttpAsyncClient（4.0 版）。这些主要是为了调试目的而添加的，RequestInterceptor 是链中的最后一个拦截器，而 ResponseInterceptor 是第一个拦截器。这个想法是在发送实际请求之前的最后阶段记录每个 http 请求，并在第一次接收到每个 http 响应时记录它。

我有以下模式来设置异步客户端：

    HttpAsyncClientBuilder asyncClientBuilder = HttpAsyncClientBuilder.create();
    asyncClientBuilder.addInterceptorLast(new MyHttpRequestInterceptor());
    asyncClientBuilder.addInterceptorFirst(new MyHttpResponseInterceptor());
    IOReactorConfig reactorConfig = IOReactorConfig.DEFAULT;

    reactorConfig.setConnectTimeout(5 * 60 * 1000); // 5 mins 
    reactorConfig.setSoTimeout(5 * 60 * 1000); // 5 mins
    asyncClientBuilder.setDefaultIOReactorConfig(reactorConfig);
    System.setProperty("http.maxConnections", "100");

    this.asyncHttpClient = asyncClientBuilder.useSystemProperties().build();
    this.asyncHttpClient.start();

为了提出请求，我这样做：

HttpGet httpGet = new HttpGet("some url");
asyncHttpClient.execute(httpGet, new AsyncHTTPResponseHandler(requestMetadata));

这是我的 AsyncHTTPResponseHandler 类：

class AsyncHTTPResponseHandler implements FutureCallback<HttpResponse> {

    // local copy of the request for reference while processing the response.
    private RequestMetadata requestMetadata;

    public AsyncHTTPResponseHandler(final RequestMetadata requestMetadata) {
        this.setRequestMetadata(requestMetadata);
        Thread.currentThread().setUncaughtExceptionHandler(new HttpUncaughtExceptionHandler(requestMetadata));
    }

    @Override
    public void cancelled() {
        logger.error("AsyncHTTPResponseHandler#Http request id: {} cancelled",
                requestMetadata.getRequestId()));
    }

    @Override
    public void completed(HttpResponse response) {
        logger.debug("Received HTTP Response for request id: {}",
                requestMetadata.getRequestId());
        //handleHttpResponse(requestMetadata, response);
    }

    @Override
    public void failed(Exception e) {
        logger.error("AsyncHTTPResponseHandler#Error in Http request id: " + requestMetadata.getRequestId(), e);
    }

}

基于此设置，我根据拦截器日志看到以下情况： 1. 我的应用程序 http 请求触发了异步客户端 HttpRequest，我得到了 HttpResponse -- Success。2. 我的应用程序 http 请求触发了一个 asyncclient HttpRequest（拦截器记录它），我没有得到这个请求的 HttpResponse --- 不知道为什么？3. 我的应用程序http请求没有触发asyncclient HttpRequest（拦截器没有记录它）并且我没有得到这个请求的HttpResponse ---不知道为什么？

关于我可以做些什么来解决这个问题或进一步调试这个问题的任何提示或建议？

谢谢！！

4

1 回答 1

0

所以，我想我会在这里分享我的发现和解决方案。

我们遇到了与此错误类似的症状：https ://issues.apache.org/jira/browse/HTTPASYNC-79

如果您为“org.apache.http.impl.nio”包启用调试日志记录，那么您可以看到交换。注意：日志将非常详细。

该问题已通过将 HttpAsyncClient 库从 4.0 升级到 4.0.2 得到解决。我还启用了套接字和连接超时。您应该在日志文件中看到超时异常。

这是我的 HttpAsyncClient 实例现在的样子：

    HttpAsyncClientBuilder asyncClientBuilder = HttpAsyncClientBuilder.create();
    asyncClientBuilder.addInterceptorLast(new MyHttpRequestInterceptor());
    asyncClientBuilder.addInterceptorFirst(new MyHttpResponseInterceptor());

    // reactor config
    IOReactorConfig reactorConfig = IOReactorConfig.custom()
            .setConnectTimeout(TIMEOUT_5_MINS_IN_MILLIS)
            .setSoTimeout(TIMEOUT_5_MINS_IN_MILLIS).build();

    asyncClientBuilder.setDefaultIOReactorConfig(reactorConfig);

    // request config
    RequestConfig requestConfig = RequestConfig.custom()
            .setConnectTimeout(TIMEOUT_5_MINS_IN_MILLIS)
            .setConnectionRequestTimeout(TIMEOUT_5_MINS_IN_MILLIS)
            .setSocketTimeout(TIMEOUT_5_MINS_IN_MILLIS).build();
    asyncClientBuilder.setDefaultRequestConfig(requestConfig);

    // connection config
    ConnectionConfig connectionConfig = ConnectionConfig.custom()
            .setMalformedInputAction(CodingErrorAction.IGNORE)
            .setUnmappableInputAction(CodingErrorAction.IGNORE)
            .build();
    asyncClientBuilder.setDefaultConnectionConfig(connectionConfig);

    System.setProperty("http.maxConnections", "100");
    System.setProperty("http.conn-manager.timeout", "300000"); // 5 mins

    this.asyncHttpClient = asyncClientBuilder.useSystemProperties().build();
于 2015-01-29T22:30:54.197 回答