|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
HttpAsyncRequestConsumer
implementation that relieves its
subclasses from having to manage internal state and provides a number of protected
event methods that they need to implement.HttpAsyncResponseConsumer
implementation that relieves its
subclasses from having to manage internal state and provides a number of protected
event methods that they need to implement.ContentDecoder
that serves as a base for all content
decoder implementations.ContentEncoder
that serves as a base for all content
encoder implementations.IOEventDispatch
implementation that supports both plain (non-encrypted)
and SSL encrypted HTTP connections.IOReactor
that can used as a subclass
for more specialized I/O reactors.NHttpMessageParser
that serves as a base for all message
parser implementations.AbstractMessageParser.AbstractMessageParser(SessionInputBuffer, LineParser,
MessageConstraints)
NHttpMessageWriter
that serves as a base for all message
writer implementations.AbstractMessageWriter.AbstractMessageWriter(SessionOutputBuffer, LineFormatter)
IOReactor
that can run multiple
BaseIOReactor
instances in separate worker threads and distribute
newly created I/O sessions equally across those I/O reactors for more
optimal resource utilization and better I/O performance.AbstractMultiworkerIOReactor.AbstractMultiworkerIOReactor(IOReactorConfig, ThreadFactory)
AbstractNIOConnPool.AbstractNIOConnPool(ConnectingIOReactor,
NIOConnFactory, SocketAddressResolver, int, int)
SelectionKey.OP_ACCEPT
readiness.
SelectionKey.OP_ACCEPT
event.
Throwable
object with the given time stamp
to the audit log.
Throwable
object to the audit log.
ByteBuffer
of the given size.
HttpAsyncRequestExecutor
and HttpAsyncRequester
HttpAsyncService
AbstractIOReactor
that serves as a base
for more advanced IOReactor
implementations.HttpAsyncClientExchangeHandler
that executes
a single HTTP request / response exchange.HttpAsyncRequestConsumer
.BasicAsyncClientExchangeHandler
.HttpAsyncRequestHandler
that delegates
the process of request handling to a HttpRequestHandler
.HttpAsyncRequestProducer
.HttpAsyncResponseConsumer
.HttpAsyncResponseProducer
.NIOConnFactory
implementation that creates
NHttpClientConnection
instances given a HttpHost
instance.BasicNIOConnFactory.BasicNIOConnFactory(SSLContext,
SSLSetupHandler, NHttpMessageParserFactory, NHttpMessageWriterFactory,
ByteBufferAllocator, ConnectionConfig)
BasicNIOConnFactory.BasicNIOConnFactory(SSLContext,
SSLSetupHandler, ConnectionConfig)
BasicNIOConnFactory.BasicNIOConnFactory(ConnectionConfig)
ConnPool
implementation that
represents a pool of non-blocking NHttpClientConnection
connections
identified by an HttpHost
instance.BasicNIOConnPool.BasicNIOConnPool(ConnectingIOReactor, NIOConnFactory, int)
BasicNIOConnPool.BasicNIOConnPool(ConnectingIOReactor,
ConnectionConfig)
PoolEntry
implementation that represents an entry
in a pool of non-blocking NHttpClientConnection
s identified by
an HttpHost
instance.IOSession
.
BufferInfo
HttpAsyncRequestExecutor
and HttpAsyncRequester
HttpAsyncService
BasicAsyncRequestProducer
or BasicAsyncResponseProducer
ByteBuffer
instances.SessionRequest
.
SocketChannel
entry maintained by the I/O reactor.SessionRequest
.
SelectionKey.OP_CONNECT
readiness.
SelectionKey.OP_CONNECT
event.
SSLBuffer
of size
.
AbstractAsyncRequestConsumer.onContentReceived(ContentDecoder, IOControl)
instead.
AbstractAsyncResponseConsumer.onContentReceived(ContentDecoder, IOControl)
instead.
ContentDecoder
.
ContentDecoder
.
ContentDecoder
.
SharedInputBuffer.consumeContent(ContentDecoder, IOControl)
BasicAsyncRequestProducer
or BasicAsyncResponseProducer
BasicAsyncRequestProducer
or BasicAsyncResponseProducer
ContentInputBuffer
.ReadableByteChannel
that delegates to a ContentDecoder
.WritableByteChannel
that delegates to a ContentEncoder
.InputStream
adaptor for ContentInputBuffer
.OutputStream
adaptor for ContentOutputBuffer
.HeapByteBufferAllocator
to be used
by HTTP connections for allocating ByteBuffer
objects.
HeapByteBufferAllocator
to be used
by HTTP connections for allocating ByteBuffer
objects.
HeapByteBufferAllocator
to be used
by HTTP connections for allocating ByteBuffer
objects.
HeapByteBufferAllocator
to be used
by HTTP connections for allocating ByteBuffer
objects.
DefaultNHttpClientConnection
based on the
given IOSession
.
DefaultNHttpServerConnection
based on the
given IOSession
.
DefaultNHttpClientConnection
based on the
given SSL IOSession
.
DefaultNHttpServerConnection
based on the
given IOSession
.
ContentDecoder
instances.
ContentEncoder
instances.
DefaultHttpRequestFactory
to be used
by HTTP connections for creating HttpRequest
objects.
DefaultHttpRequestFactory
to be used
by HTTP connections for creating HttpRequest
objects.
DefaultHttpResponseFactory
to be used
by HTTP connections for creating HttpResponse
objects.
DefaultHttpResponseFactory
to be used
by HTTP connections for creating HttpResponse
objects.
HttpMessage
instance based on the content of the input
buffer containing the first line of the incoming HTTP message.
SSLIOSession
decorating the given
IOSession
.
SSLIOSession
decorating the given
IOSession
.
SSLIOSession
decorating the given
IOSession
.
SSLIOSession
decorating the given
IOSession
.
DefaultHttpClientIODispatch
ConnectingIOReactor
.DefaultConnectingIOReactor.DefaultConnectingIOReactor(IOReactorConfig, ThreadFactory)
DefaultConnectingIOReactor.DefaultConnectingIOReactor(IOReactorConfig)
IOEventDispatch
implementation
that supports both plain (non-encrypted) and SSL encrypted client side HTTP
connections.DefaultHttpClientIODispatch.DefaultHttpClientIODispatch(
NHttpClientEventHandler, ConnectionConfig)
DefaultHttpClientIODispatch.DefaultHttpClientIODispatch(
NHttpClientEventHandler, SSLContext, SSLSetupHandler, ConnectionConfig)
DefaultHttpClientIODispatch.DefaultHttpClientIODispatch(
NHttpClientEventHandler, SSLContext, ConnectionConfig)
NHttpMessageParser
implementation
for HttpRequest
s.DefaultHttpRequestParser.DefaultHttpRequestParser(
SessionInputBuffer, LineParser, HttpRequestFactory, MessageConstraints)
NHttpMessageWriter
implementation
for HttpRequest
s.DefaultHttpRequestWriter.DefaultHttpRequestWriter(SessionOutputBuffer, LineFormatter)
NHttpMessageParser
implementation
for HttpResponse
s.DefaultHttpResponseParser.DefaultHttpResponseParser(
SessionInputBuffer, LineParser, HttpResponseFactory, MessageConstraints)
NHttpMessageWriter
implementation
for HttpResponse
s.DefaultHttpResponseWriter.DefaultHttpResponseWriter(SessionOutputBuffer, LineFormatter)
IOEventDispatch
implementation
that supports both plain (non-encrypted) and SSL encrypted server side HTTP
connections.DefaultHttpServerIODispatch.DefaultHttpServerIODispatch(
NHttpServerEventHandler, ConnectionConfig)
DefaultHttpServerIODispatch.DefaultHttpServerIODispatch(
NHttpServerEventHandler, SSLContext, SSLSetupHandler, ConnectionConfig)
DefaultHttpServerIODispatch.DefaultHttpServerIODispatch(
NHttpServerEventHandler, SSLContext, ConnectionConfig)
ListeningIOReactor
.DefaultListeningIOReactor.DefaultListeningIOReactor(IOReactorConfig, ThreadFactory)
DefaultListeningIOReactor.DefaultListeningIOReactor(IOReactorConfig)
NHttpClientConnection
interface.DefaultNHttpClientConnection.DefaultNHttpClientConnection(
IOSession, int, int, ByteBufferAllocator, CharsetDecoder, CharsetEncoder,
MessageConstraints, ContentLengthStrategy, ContentLengthStrategy,
NHttpMessageWriterFactory, NHttpMessageParserFactory)
NHttpClientConnection
s.DefaultNHttpClientConnectionFactory.DefaultNHttpClientConnectionFactory(
NHttpMessageParserFactory, NHttpMessageWriterFactory, ByteBufferAllocator,
ConnectionConfig)
DefaultNHttpClientConnectionFactory.DefaultNHttpClientConnectionFactory(
ConnectionConfig)
NHttpServerConnection
interface.DefaultNHttpServerConnection.DefaultNHttpServerConnection(
IOSession, int, int, ByteBufferAllocator, CharsetDecoder, CharsetEncoder,
MessageConstraints, ContentLengthStrategy, ContentLengthStrategy,
NHttpMessageParserFactory, NHttpMessageWriterFactory)
NHttpServerConnection
s.DefaultNHttpServerConnectionFactory.DefaultNHttpServerConnectionFactory(
ByteBufferAllocator, NHttpMessageParserFactory, NHttpMessageWriterFactory,
ConnectionConfig)
DefaultNHttpServerConnectionFactory.DefaultNHttpServerConnectionFactory(ConnectionConfig)
DefaultHttpServerIODispatch
ByteBuffer
instances using
ByteBuffer.allocateDirect(int)
.HttpAsyncContentProducer
that relies on
inefficient and potentially blocking I/O operation redirection through
Channels.newChannel(java.io.InputStream)
.Throwable
instance along with a time stamp.IOEventDispatch
.
ByteBufferAllocator
interface.SessionRequest
.
FileChannel
FileChannel
ReadableByteChannel
.
ReadableByteChannel
.
NByteArrayEntity.close()
NFileEntity.close()
NStringEntity.close()
WritableByteChannel
.
ConnectionReuseStrategy
implementation to be used
to determine whether or not the underlying connection can be kept alive
after a particular HTTP request / response exchange.
InputStream
.
UnsupportedOperationException
.
NIOReactorPNames.CONTENT_BUFFER_SIZE
parameter.
HttpContext
instance.
ioThreadCount
.
IOException
thrown during initialization
of this endpoint or null
, if initialization was successful.
IOException
instance if the request could not be
successfully executed due to an I/O error or null
if no
error occurred to this point.
NIOReactorPNames.GRACE_PERIOD
parameter.
HttpProcessor
implementation to be used to process
HTTP request and response messages for protocol compliance.
true
if interest Ops queueing is enabled, false
otherwise.
NIOReactorPNames.INTEREST_OPS_QUEUEING
parameter.
SocketOptions.SO_RCVBUF
parameter
for newly created sockets.
HttpRequest
NIOReactorPNames.SELECT_INTERVAL
parameter.
IOSession
instance associated with the given selection
key.
IOSession
instance created as a result of this request
or null
if the request is still pending.
SocketOptions.SO_SNDBUF
parameter
for newly created sockets.
SocketOptions.SO_LINGER
parameter
for newly created sockets.
RuntimeException
.
0
.
ByteBuffer
instances using
ByteBuffer.allocate(int)
.HttpAsyncClientExchangeHandler
represents a callback interface whose
methods get invoked when executing one or multiple HTTP message exchanges
on the client side.HttpAsyncContentProducer
is a callback interface whose methods
get invoked to stream out message content to a non-blocking HTTP connection.HttpAsyncExchange
represents a server-side HTTP message exchange
where an HTTP response can be deferred without blocking the I/O event thread
and triggered asynchronously at a later point of later time.HttpAsyncExpectationVerifier
defines a strategy to verify whether
or not an incoming HTTP request meets the target server's expectations.HttpAsyncRequestConsumer
is a callback interface whose methods
get invoked to process an HTTP request message and to stream message
content from a non-blocking HTTP connection on the server side.HttpAsyncRequester
is a utility class that can be used
in conjunction with HttpAsyncRequestExecutor
to initiate execution
of asynchronous HTTP requests.HttpAsyncRequester.HttpAsyncRequester(HttpProcessor,
ConnectionReuseStrategy)
HttpAsyncRequester
.
HttpAsyncClientExchangeHandler
HttpAsyncRequestExecutor
is a fully asynchronous HTTP client side
protocol handler based on the NIO (non-blocking) I/O model.HttpAsyncRequestExecutor
.
HttpAsyncRequestHandler
represents a routine for asynchronous
processing of a specific group of non-blocking HTTP requests.HttpAsyncRequestHandlerMapper
can be used to resolve an instance
of HttpAsyncRequestHandler
matching a particular HttpRequest
.UriHttpAsyncRequestHandlerMapper
HttpAsyncRequestHandlerMapper
HttpAsyncRequestProducer
is a callback interface whose methods
get invoked to generate an HTTP request message and to stream message
content to a non-blocking HTTP connection.HttpAsyncResponseConsumer
is a callback interface whose methods
get invoked to process an HTTP response message and to stream message
content from a non-blocking HTTP connection on the client side.HttpAsyncResponseProducer
is a callback interface whose methods
get invoked to generate an HTTP response message and to stream message
content to a non-blocking HTTP connection on the server side.HttpAsyncService
is a fully asynchronous HTTP server side protocol
handler based on the non-blocking (NIO) I/O model.HttpAsyncService.HttpAsyncService(HttpProcessor,
ConnectionReuseStrategy, HttpResponseFactory, HttpAsyncRequestHandlerMapper,
HttpAsyncExpectationVerifier)
HttpAsyncService.HttpAsyncService(HttpProcessor,
ConnectionReuseStrategy, HttpResponseFactory, HttpAsyncRequestHandlerMapper,
HttpAsyncExpectationVerifier)
HttpAsyncServerProtocolHandler
.
HttpAsyncServerProtocolHandler
.
HttpAsyncServerProtocolHandler
.
HttpAsyncServerProtocolHandler
.
HttpAsyncRequestExecutor
and HttpAsyncRequester
DefaultHttpRequestParser
DefaultHttpRequestWriter
DefaultHttpResponseParser
DefaultHttpResponseWriter
IOReactorConfig.Builder
.
IOSession
.true
if the entity has been received in its
entirety.
true
if the entity has been transferred in its
entirety.
true
is the session has been fully initialized,
false
otherwise.
SelectionKey
immediately.
true
if an HTTP request has been submitted to the
target server.
true
if an HTTP response has been submitted to the
client.
SocketOptions.SO_KEEPALIVE
parameter
for newly created sockets.
SocketOptions.SO_REUSEADDR
parameter
for newly created sockets.
SocketOptions.TCP_NODELAY
parameter
for newly created sockets.
ListenerEndpoint
.Closeable
objects (such as
HttpConnection
}).
Closeable
objects (such as
HttpConnection
}).
Closeable
objects (such as
HttpConnection
).
File
with the given content type.
File
with the given content type.
NFileEntity.NFileEntity(File, ContentType, boolean)
NFileEntity.NFileEntity(File, ContentType)
NHttpClientEventHandler
NHttpConnection
implementations and provides
functionality common to both client and server HTTP connections.NHttpConnectionBase.NHttpConnectionBase(IOSession, int, int, ByteBufferAllocator,
CharsetDecoder, CharsetEncoder, ContentLengthStrategy, ContentLengthStrategy)
NHttpConnection
instances.EntityAsyncContentProducer
NHttpMessageParser
instances.NHttpMessageWriter
instances.HttpAsyncRequestExecutor
and HttpAsyncRequester
HttpAsyncRequestHandler
UriHttpAsyncRequestHandlerMapper
HttpAsyncRequestHandlerResolver
HttpAsyncExchange
NHttpServerEventHandler
IOReactorConfig
IOReactorConfig
IOReactorConfig
String
object.ContentDecoder
.
ContentDecoder
.
SSLBufferManagementStrategy
that never releases the underlying buffer.HttpAsyncClientExchangeHandler
that executes a series of pipelined HTTP requests.PipeliningClientExchangeHandler
.
PipeliningClientExchangeHandler
.
ContentDecoder
implementation based on the
properties of the given HttpMessage
and generates an instance of
HttpEntity
matching the properties of the content decoder.
ContentEncoder
implementation based on the
properties of the given HttpMessage
.
Socket
by resetting some of its properties.
Selector
.
ContentEncoder
.
ContentEncoder
.
ContentEncoder
.
ContentEncoder
.
SharedOutputBuffer.produceContent(ContentEncoder, IOControl)
BasicAsyncRequestProducer
or BasicAsyncResponseProducer
len
bytes of data from this buffer into
an array of bytes.
SelectionKey.OP_READ
readiness.
SelectionKey.OP_READ
event on the given selection key.
HttpAsyncRequestHandler
as a handler for URIs
matching the given pattern.
NHttpRequestHandler
as a handler for URIs
matching the given pattern.
HttpAsyncRequestHandler
as a handler for URIs
matching the given pattern.
Selector
.
HttpAsyncRequestHandler
as a handler for URIs matching the given pattern.
SSLBufferManagementStrategy
that releases the underlying buffer when deactivated.AbstractAsyncRequestConsumer.buildResult(HttpContext)
instead.
AbstractAsyncRequestConsumer.onRequestReceived(HttpRequest)
instead.
SocketAddressResolver
SocketAddressResolver
SocketAddressResolver
SocketAddressResolver
AbstractAsyncResponseConsumer.buildResult(HttpContext)
instead.
AbstractAsyncResponseConsumer.onResponseReceived(HttpResponse)
instead.
IOSessionImpl
SessionInputBuffer
based on
the ExpandableBuffer
class.SessionInputBufferImpl.SessionInputBufferImpl(int, int, CharsetDecoder,
ByteBufferAllocator)
SessionInputBufferImpl.SessionInputBufferImpl(int, int, Charset)
SessionOutputBuffer
based on
the ExpandableBuffer
class.SessionOutputBufferImpl.SessionOutputBufferImpl(int, int, CharsetEncoder,
ByteBufferAllocator)
SessionOutputBufferImpl.SessionOutputBufferImpl(int, int, Charset)
SessionRequest
along
with the time the request was made.SessionRequest
.Cancellable
callback to be invoked in case the underlying
connection times out or gets terminated prematurely by the client.
NHttpConnectionFactory
instance.
ConnectionReuseStrategy
instance.
IOReactorConfig.Builder.setConnectTimeout(int)
NIOReactorPNames.CONTENT_BUFFER_SIZE
parameter.
ioThreadCount
.
ExceptionLogger
instance.
HttpAsyncExpectationVerifier
instance.
NIOReactorPNames.GRACE_PERIOD
parameter.
HttpAsyncRequestHandlerMapper
instance.
HttpProcessor
instance.
IOReactorConfig.Builder.setInterestOpQueued(boolean)
NIOReactorPNames.INTEREST_OPS_QUEUEING
parameter.
IOReactorConfig.Builder.setIoThreadCount(int)
IOReactorConfig.Builder.setRcvBufSize(int)
HttpResponseFactory
instance.
IOReactorConfig.Builder.setSelectInterval(long)
NIOReactorPNames.SELECT_INTERVAL
parameter.
Server
response header value.
IOReactorConfig.Builder.setShutdownGracePeriod(long)
IOReactorConfig.Builder.setSndBufSize(int)
IOReactorConfig.Builder.setSoKeepAlive(boolean)
IOReactorConfig.Builder.setSoLinger(int)
IOReactorConfig.Builder.setSoReuseAddress(boolean)
IOReactorConfig.Builder.setSoTimeout(int)
SSLContext
instance.
SSLSetupHandler
instance.
IOReactorConfig.Builder.setTcpNoDelay(boolean)
ContentInputBuffer
interface that can be
shared by multiple threads, usually the I/O dispatch of an I/O reactor and
a worker thread.SharedInputBuffer.SharedInputBuffer(int, ByteBufferAllocator)
ContentOutputBuffer
interface that can be
shared by multiple threads, usually the I/O dispatch of an I/O reactor and
a worker thread.SharedOutputBuffer.SharedOutputBuffer(int, ByteBufferAllocator)
ContentInputBuffer
interface.BasicAsyncRequestHandler
ContentOutputBuffer
interface.SocketAddress
.DefaultHttpClientIODispatch
SSLContext
.
SSLContext
.
SSLClientIOEventDispatch
SSLContext
.
SSLContext
.
SSLIOSession
SSLIOSession
is a decorator class intended to transparently extend
an IOSession
with transport layer security capabilities based on
the SSL/TLS protocol.SSLIOSession
class.
SSLIOSession
class.
SSLIOSession
class.
SSLSetupHandler
NHttpClientConnection
s.SSLNHttpClientConnectionFactory.SSLNHttpClientConnectionFactory(SSLContext,
SSLSetupHandler, NHttpMessageParserFactory, NHttpMessageWriterFactory,
ByteBufferAllocator, ConnectionConfig)
SSLNHttpClientConnectionFactory.SSLNHttpClientConnectionFactory(SSLContext,
SSLSetupHandler, ConnectionConfig)
SSLNHttpClientConnectionFactory.SSLNHttpClientConnectionFactory(ConnectionConfig)
NHttpServerConnection
s.SSLNHttpServerConnectionFactory.SSLNHttpServerConnectionFactory(SSLContext,
SSLSetupHandler, NHttpMessageParserFactory, NHttpMessageWriterFactory,
ByteBufferAllocator, ConnectionConfig)
SSLNHttpServerConnectionFactory.SSLNHttpServerConnectionFactory(SSLContext,
SSLSetupHandler, ConnectionConfig)
SSLNHttpServerConnectionFactory.SSLNHttpServerConnectionFactory(ConnectionConfig)
DefaultHttpServerIODispatch
SSLContext
.
SSLContext
.
SSLServerIOEventDispatch
SSLContext
.
SSLContext
.
SSLSetupHandler
HttpRequest
to be sent to the target server.
HttpAsyncResponseProducer
.
HttpAsyncRequestExecutor
and HttpAsyncRequester
HttpAsyncService
SessionRequest
times out.
AbstractIOReactor.timeoutCheck(SelectionKey, long)
method.
SelectionKey.OP_WRITE
readiness.
SelectionKey.OP_WRITE
event on the given selection key.
len
bytes from the specified byte array
starting at offset off
to this buffer.
HttpMessage
.
UnsupportedOperationException
.
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |