Httpcomponents-client 连接释放逻辑源码研究

1/**
2     * Ensures that the entity content is fully consumed and the content stream, if exists,
3     * is closed.
4     *
5     * @param entity the entity to consume.
6     * @throws IOException if an error occurs reading the input stream
7     *
8     * @since 4.1
9     */
10    public static void consume(final HttpEntity entity) throws IOException {
11        if (entity == null) {
12            return;
13        }
14        if (entity.isStreaming()) {
15            final InputStream instream = entity.getContent();
16            if (instream != null) {
17                instream.close();
18            }
19        }
20    }

1 @Override
2    public InputStream getContent() throws IOException {
3        return new EofSensorInputStream(this.wrappedEntity.getContent(), this);
4    }

1 @Override
2    public void close() throws IOException {
3        // tolerate multiple calls to close()
4        selfClosed = true;
5        checkClose();
6    }
7
8protected void checkClose() throws IOException {
9
10        final InputStream toCloseStream = wrappedStream;
11        if (toCloseStream != null) {
12            try {
13                boolean scws = true; // should close wrapped stream?
14                if (eofWatcher != null) {
15                    scws = eofWatcher.streamClosed(toCloseStream);
16                }
17                if (scws) {
18                    toCloseStream.close();
19                }
20            } finally {
21                wrappedStream = null;
22            }
23        }
24    }

1@Override
2    public boolean streamClosed(final InputStream wrapped) throws IOException {
3        try {
4            final boolean open = connHolder != null && !connHolder.isReleased();
5            // this assumes that closing the stream will
6            // consume the remainder of the response body:
7            try {
8                if (wrapped != null) {
9                    wrapped.close();
10                }
11                releaseConnection();
12            } catch (final SocketException ex) {
13                if (open) {
14                    throw ex;
15                }
16            }
17        } catch (final IOException ex) {
18            abortConnection();
19            throw ex;
20        } catch (final RuntimeException ex) {
21            abortConnection();
22            throw ex;
23        } finally {
24            cleanup();
25        }
26        return false;
27    }