java - 使用 Http.Core 与 Http.Client 4 对话获取 ConnectionClosedException？

Question

我正在尝试使用 http.core 和客户端 4.3。总的来说，它运作良好，并且处理起来非常愉快。但是，我在一次传输中收到了 ConnectionClosedException，但我不明白为什么。据我所知，其他人工作得很好。

一切都以非常直接的方式遵循示例。如果不是，则尽可能多地重写以消除这种情况。

1. 有 2 个服务器，都运行相同的代码 [A & B]
2. A HttpClient 向 B 发送请求“AX”(POST)
3. B HttpService 收到“AX”帖子，对其进行处理
4. B HttpClient 在不同端口上向 A 发送回复“BR”(POST)
   1. 稍后 这应该发生在与 A 的连接关闭之后，或者尽可能接近
   2. 现在代码实际上并不关心
5. A 收到 B 的回复(在不同的线程上)并做事

在问题场景中，A作为服务器运行，B正在发送POST。抱歉，它并不总是很清楚，因为在一个事务中，双方最终都运行服务器和客户端代码。

1. A 发送 POST 到 B:8080。在线返回正确的响应，一切正常。
2. 到 B:8080 的 POST 连接正确关闭
3. B 向A 发送新的 POST(如 ACK)(例如... B:53991 => A: 9000).
   
   1. A 处理一切。没问题
   2. 异常 ConnectionClosedException

因为我不确定它为什么会发生，所以我试着把我认为相关的所有内容都放在那里。我现在唯一的想法是，它与确保我添加/更改连接控制 header 有关，但我看不出这会产生什么影响。

堆栈跟踪来自机器“A”，当来自 B 的回复到来时

org.apache.http.ConnectionClosedException: Client closed connection
    at org.apache.http.impl.io.DefaultHttpRequestParser.parseHead(DefaultHttpRequestParser.java:133)
    at org.apache.http.impl.io.DefaultHttpRequestParser.parseHead(DefaultHttpRequestParser.java:54)
    at org.apache.http.impl.io.AbstractMessageParser.parse(AbstractMessageParser.java:260)
    at org.apache.http.impl.DefaultBHttpServerConnection.receiveRequestHeader(DefaultBHttpServerConnection.java:131)
    at org.apache.http.protocol.HttpService.handleRequest(HttpService.java:307)
    at com.me.HttpRequestHandlerThread.processConnection(HttpRequestHandlerThread.java:45)
    at com.me.net.http.HttpRequestHandlerThread.run(HttpRequestHandlerThread.java:70)
com.me.ExceptionHolder: Client closed connection
    at com.me.log.Log.logIdiocy(Log.java:77)
    at com.me.log.Log.error(Log.java:54)
    at com.me.net.http.HttpRequestHandlerThread.run(HttpRequestHandlerThread.java:72)
Caused by: org.apache.http.ConnectionClosedException: Client closed connection
    at org.apache.http.impl.io.DefaultHttpRequestParser.parseHead(DefaultHttpRequestParser.java:133)
    at org.apache.http.impl.io.DefaultHttpRequestParser.parseHead(DefaultHttpRequestParser.java:54)
    at org.apache.http.impl.io.AbstractMessageParser.parse(AbstractMessageParser.java:260)
    at org.apache.http.impl.DefaultBHttpServerConnection.receiveRequestHeader(DefaultBHttpServerConnection.java:131)
    at org.apache.http.protocol.HttpService.handleRequest(HttpService.java:307)
    at com.me.net.http.HttpRequestHandlerThread.processConnection(HttpRequestHandlerThread.java:45)
    at com.me.net.http.HttpRequestHandlerThread.run(HttpRequestHandlerThread.java:70)

这是在 B 上运行的代码，即本场景中的“客户端”。它正在尝试 POST 回复，确认已正确收到来自 A 的第一个 POST。确实没有太多要传输的，响应应该只是一个 HTTP 200:

try (CloseableHttpClient client = HttpClients.createDefault()) {
    final HttpPost post = new HttpPost(url);
    post.setHeaders(/* create application specific headers */);

    ByteArrayEntity entity = new ByteArrayEntity(IOUtils.toByteArray(myStream));
    post.setEntity(entity);

    ResponseHandler<Void> responseHandler = new ResponseHandler<Void>() {
        @Override
        public Void handleResponse(HttpResponse response) throws ClientProtocolException, IOException {
            StatusLine status = response.getStatusLine();
            if (!NetUtil.isValidResponseCode(response)) {
                throw new ClientProtocolException("Unexpected Error! Oops");
            }
            // consume the response, if there is one, so the connection will close properly
            EntityUtils.consumeQuietly(response.getEntity());
            return null;
        }
    };

    try {
        client.execute(post, responseHandler);
    } catch (ClientProtocolException ex) { 
        // logic to queue a resend for 10 minutes later.  not triggered
        throw ex;
    }
}

On A:这称为异步，因为响应不是通过相同的 http 连接进入的。

主要的请求处理程序做了更多的工作，但令人惊讶的是，在处理程序/服务器端实际控制 HTTP 的代码非常少。伟大的图书馆......我以某种方式滥用。这是实际的处理程序，一切都简化了一点，删除了验证等。

public class AsyncReceiverHandler implements HttpRequestHandler {

    @Override
    public void handle(HttpRequest request, HttpResponse response, HttpContext context) throws HttpException, IOException {
        // error if not post, other logic.  not touching http.  no errors
        DefaultBHttpServerConnection connection = (DefaultBHttpServerConnection) context.getAttribute("connection");
        Package pkg = NetUtil.createPackageFrom(connection); // just reads sender ip/port
        NetUtil.copyHttpHeaders(request, pkg); 
        try {
            switch (recieive(request, pkg)) {
                case EH_OK:
                    response.setStatusCode(HttpStatus.SC_OK);
                    break;
                case OHNOES_BAD_INPUT:
                    response.setStatusCode(HttpStatus.SC_BAD_REQUEST);
                    response.setEntity(new StringEntity("No MDN entity found in request body"));
                // bunch of other cases, but are not triggered.  xfer was a-ok
            }
        } catch (Exception ex) {
            //log
        } 
    }
    private MyStatus receiveMdn(HttpRequest request, Package pkg) throws Exceptions..., IOException {
        // validate request, get entity, make package, no issues
        HttpEntity resEntity = ((HttpEntityEnclosingRequest) request).getEntity();

        try {
            byte[] data = EntityUtils.toByteArray(resEntity);
            // package processing logic, validation, fairly quick, no errors thrown
        } catch (Exceptions... ex) {
            throw ExceptionHolder(ex);
        }
    }
}

这是请求处理线程。这个和服务器几乎是从样本中逐字提取的。服务处理程序只是启动服务和 accept() 套接字。当它得到一个时，它会创建一个新的副本，并调用 start():

public HttpRequestHandlerThread(final HttpService httpService, final HttpServerConnection conn, HttpReceiverModule ownerModule) {
        super();
        this.httpService = httpService;
        this.conn = (DefaultBHttpServerConnection) conn;
    }
    private void processConnection() throws IOException, HttpException {
        while (!Thread.interrupted() && this.conn.isOpen()) {
            /* have the service create a handler and pass it the processed request/response/context */
            HttpContext context = new BasicHttpContext(null);
            this.httpService.handleRequest(this.conn, context);
        }
    }
    @Override
    public void run() {
        // just runs the main logic and reports exceptions. 
        try {
            processConnection();
        } catch (ConnectionClosedException ignored) {
            // logs error here (and others). 
        } finally {
            try { this.conn.shutdown(); } catch (IOException ignored) {}
        }
    }
}

Answer 1

好吧，这现在看起来很愚蠢，而且非常明显。我暂时忽略了这个问题并继续做其他事情，答案从潜意识中冒出来，就像他们会的那样。

我把这个标题加回去，一切都清理干净了:

post.setHeader("Connection", "close, TE")

不知何故，设置 Connection header 的行被删除了，这可能是我不小心造成的。他们中的很多人都设置好了，但它仍然存在，只是在这个代码路径中出错了。基本上，服务器希望此连接立即关闭，但 header 恢复为默认的 keep-alive。由于客户端在完成连接后立即关闭连接，这让服务器感到惊讶，否则服务器会被告知，并且正确地遵守了 :D 在反向路径中，一切正常。

因为我刚刚更改了旧堆栈以使用 HttpComponents 我没有查看 header 等，我只是假设我使用错误。老栈不介意。