Package one.nio.http

Class HttpClient

java.lang.Object

java.util.AbstractCollection<Socket>

java.util.AbstractList<Socket>

java.util.AbstractSequentialList<Socket>

java.util.LinkedList<Socket>

one.nio.pool.Pool<Socket>

one.nio.pool.SocketPool

one.nio.http.HttpClient

All Implemented Interfaces:

Closeable, Serializable, AutoCloseable, Cloneable, Iterable<Socket>, Collection<Socket>, Deque<Socket>, List<Socket>, Queue<Socket>, SequencedCollection<Socket>, SocketPoolMXBean

public class HttpClient
extends SocketPool

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) class	HttpClient.ChunkedLineReader
(package private) static class	HttpClient.EventImpl
(package private) static class	HttpClient.ResponseReader
(package private) class	HttpClient.ServerSentEventsReader

Field Summary

Fields

Modifier and Type	Field	Description
protected int	bufferSize
private static final org.slf4j.Logger	log
protected String[]	permanentHeaders

Fields inherited from class one.nio.pool.SocketPool

connectTimeout, host, port, proxy, readTimeout, sslContext, thinLto, tos

Fields inherited from class one.nio.pool.Pool

closed, createdCount, fifo, initialCount, keepEmpty, maxCount, timeout, timeouts, waitingThreads

Fields inherited from class java.util.AbstractList

modCount

Constructor Summary

Constructors

Constructor	Description
HttpClient(ConnectionString conn)
HttpClient(ConnectionString conn, String... permanentHeaders)

Method Summary

Modifier and Type	Method	Description
Response	connect(String uri, String... headers)
Request	createRequest(int method, String uri, String... headers)
Response	delete(String uri, String... headers)
Response	get(String uri, String... headers)
Response	head(String uri, String... headers)
Response	invoke(Request request)
Response	invoke(Request request, int timeout)
EventSourceResponse	openEvents(String uri, String... headers)
EventSourceResponse	openEvents(Request request, int timeout)
Response	options(String uri, String... headers)
Response	patch(String uri, byte[] body, String... headers)
Response	patch(String uri, String... headers)
Response	post(String uri, byte[] body, String... headers)
Response	post(String uri, String... headers)
Response	put(String uri, byte[] body, String... headers)
Response	put(String uri, String... headers)
EventSourceResponse	reopenEvents(Request request, String lastId, int timeout)
protected void	setProperties(ConnectionString conn)
Response	trace(String uri, String... headers)

Methods inherited from class one.nio.pool.SocketPool

createObject, destroyObject, getBusyCount, getConnectTimeout, getFifo, getIdleCount, getMaxCount, getProxy, getReadTimeout, getSslContext, getTimeout, getTimeouts, getWaitingThreads, name, setConnectTimeout, setFifo, setMaxCount, setProxy, setReadTimeout, setSslContext, setTimeout

Methods inherited from class one.nio.pool.Pool

borrowObject, close, initialize, invalidateAll, invalidateObject, isClosed, returnObject

Methods inherited from class java.util.LinkedList

add, add, addAll, addAll, addFirst, addLast, clear, clone, contains, descendingIterator, element, get, getFirst, getLast, indexOf, lastIndexOf, listIterator, offer, offerFirst, offerLast, peek, peekFirst, peekLast, poll, pollFirst, pollLast, pop, push, remove, remove, remove, removeFirst, removeFirstOccurrence, removeLast, removeLastOccurrence, reversed, set, size, spliterator, toArray, toArray

Methods inherited from class java.util.AbstractSequentialList

iterator

Methods inherited from class java.util.AbstractList

equals, hashCode, listIterator, removeRange, subList

Methods inherited from class java.util.AbstractCollection

containsAll, isEmpty, removeAll, retainAll, toString

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.Collection

parallelStream, removeIf, stream, toArray

Methods inherited from interface java.util.Deque

iterator

Methods inherited from interface java.lang.Iterable

forEach

Methods inherited from interface java.util.List

containsAll, equals, hashCode, isEmpty, iterator, listIterator, removeAll, replaceAll, retainAll, sort, subList

Methods inherited from interface one.nio.pool.SocketPoolMXBean

invalidateAll, isClosed

Field Details

log

private static final org.slf4j.Logger log

permanentHeaders

protected String[] permanentHeaders

bufferSize

protected int bufferSize

Constructor Details

HttpClient

public HttpClient(ConnectionString conn)

HttpClient

public HttpClient(ConnectionString conn,
 String... permanentHeaders)

Method Details

setProperties

protected void setProperties(ConnectionString conn)

Overrides:

setProperties in class SocketPool

invoke

public Response invoke(Request request)
                throws InterruptedException,
PoolException,
IOException,
HttpException

Throws:

InterruptedException

PoolException

IOException

HttpException

invoke

public Response invoke(Request request,
 int timeout)
                throws InterruptedException,
PoolException,
IOException,
HttpException

Throws:

InterruptedException

PoolException

IOException

HttpException

get

public Response get(String uri,
 String... headers)
             throws InterruptedException,
PoolException,
IOException,
HttpException

Throws:

InterruptedException

PoolException

IOException

HttpException

openEvents

public EventSourceResponse openEvents(String uri,
 String... headers)
                               throws InterruptedException,
PoolException,
IOException,
HttpException

Throws:

InterruptedException

PoolException

IOException

HttpException

delete

public Response delete(String uri,
 String... headers)
                throws InterruptedException,
PoolException,
IOException,
HttpException

Throws:

InterruptedException

PoolException

IOException

HttpException

post

public Response post(String uri,
 String... headers)
              throws InterruptedException,
PoolException,
IOException,
HttpException

Throws:

InterruptedException

PoolException

IOException

HttpException

post

public Response post(String uri,
 byte[] body,
 String... headers)
              throws InterruptedException,
PoolException,
IOException,
HttpException

Throws:

InterruptedException

PoolException

IOException

HttpException

put

public Response put(String uri,
 String... headers)
             throws InterruptedException,
PoolException,
IOException,
HttpException

Throws:

InterruptedException

PoolException

IOException

HttpException

put

public Response put(String uri,
 byte[] body,
 String... headers)
             throws InterruptedException,
PoolException,
IOException,
HttpException

Throws:

InterruptedException

PoolException

IOException

HttpException

patch

public Response patch(String uri,
 String... headers)
               throws InterruptedException,
PoolException,
IOException,
HttpException

Throws:

InterruptedException

PoolException

IOException

HttpException

patch

public Response patch(String uri,
 byte[] body,
 String... headers)
               throws InterruptedException,
PoolException,
IOException,
HttpException

Throws:

InterruptedException

PoolException

IOException

HttpException

head

public Response head(String uri,
 String... headers)
              throws InterruptedException,
PoolException,
IOException,
HttpException

Throws:

InterruptedException

PoolException

IOException

HttpException

options

public Response options(String uri,
 String... headers)
                 throws InterruptedException,
PoolException,
IOException,
HttpException

Throws:

InterruptedException

PoolException

IOException

HttpException

trace

public Response trace(String uri,
 String... headers)
               throws InterruptedException,
PoolException,
IOException,
HttpException

Throws:

InterruptedException

PoolException

IOException

HttpException

connect

public Response connect(String uri,
 String... headers)
                 throws InterruptedException,
PoolException,
IOException,
HttpException

Throws:

InterruptedException

PoolException

IOException

HttpException

openEvents

public EventSourceResponse openEvents(Request request,
 int timeout)
                               throws InterruptedException,
PoolException,
IOException,
HttpException

Throws:

InterruptedException

PoolException

IOException

HttpException

reopenEvents

public EventSourceResponse reopenEvents(Request request,
 String lastId,
 int timeout)
                                 throws InterruptedException,
PoolException,
IOException,
HttpException

Throws:

InterruptedException

PoolException

IOException

HttpException

createRequest

public Request createRequest(int method,
 String uri,
 String... headers)