Package | Description |
---|---|
io.netty.channel |
The core channel API which is asynchronous and event-driven abstraction of
various transports such as a
NIO Channel.
|
io.netty.handler.codec |
Extensible decoder and its common implementations which deal with the
packet fragmentation and reassembly issue found in a stream-based transport
such as TCP/IP.
|
io.netty.handler.codec.http |
Encoder, decoder and their related message types for HTTP.
|
io.netty.handler.codec.http.cors |
This package contains Cross Origin Resource Sharing (CORS) related classes.
|
io.netty.handler.codec.spdy |
Encoder, decoder, session handler and their related message types for the SPDY protocol.
|
io.netty.handler.flush |
Package to control flush behavior.
|
io.netty.handler.logging |
Logs a
io.netty.channel.ChannelEvent for debugging purpose. |
io.netty.handler.stream |
Writes very large data stream asynchronously neither spending a lot of
memory nor getting
OutOfMemoryError . |
io.netty.handler.timeout |
Adds support for read and write timeout and idle connection notification
using a
Timer . |
io.netty.handler.traffic |
Implementation of a Traffic Shaping Handler and Dynamic Statistics.
|
Modifier and Type | Class and Description |
---|---|
class |
CombinedChannelDuplexHandler<I extends ChannelInboundHandler,O extends ChannelOutboundHandler>
|
Modifier and Type | Class and Description |
---|---|
class |
ByteToMessageCodec<I>
A Codec for on-the-fly encoding/decoding of bytes to messages and vise-versa.
|
class |
MessageToMessageCodec<INBOUND_IN,OUTBOUND_IN>
A Codec for on-the-fly encoding/decoding of message.
|
Modifier and Type | Class and Description |
---|---|
class |
HttpClientCodec
A combination of
HttpRequestEncoder and HttpResponseDecoder
which enables easier client side HTTP implementation. |
class |
HttpContentCompressor
Compresses an
HttpMessage and an HttpContent in gzip or
deflate encoding while respecting the "Accept-Encoding" header. |
class |
HttpContentEncoder
Encodes the content of the outbound
HttpResponse and HttpContent . |
class |
HttpServerCodec
A combination of
HttpRequestDecoder and HttpResponseEncoder
which enables easier server side HTTP implementation. |
class |
HttpServerKeepAliveHandler
HttpServerKeepAliveHandler helps close persistent connections when appropriate.
|
Modifier and Type | Class and Description |
---|---|
class |
CorsHandler
Handles Cross Origin Resource Sharing (CORS) requests.
|
Modifier and Type | Class and Description |
---|---|
class |
SpdyHttpCodec
A combination of
SpdyHttpDecoder and SpdyHttpEncoder |
class |
SpdyHttpResponseStreamIdHandler
MessageToMessageCodec that takes care of adding the right SpdyHttpHeaders.Names.STREAM_ID to the
HttpMessage if one is not present. |
class |
SpdySessionHandler
Manages streams within a SPDY session.
|
Modifier and Type | Class and Description |
---|---|
class |
FlushConsolidationHandler
ChannelDuplexHandler which consolidates Channel.flush() / ChannelHandlerContext.flush()
operations (which also includes
Channel.writeAndFlush(Object) / Channel.writeAndFlush(Object, ChannelPromise) and
ChannelHandlerContext.writeAndFlush(Object) /
ChannelHandlerContext.writeAndFlush(Object, ChannelPromise) ). |
Modifier and Type | Class and Description |
---|---|
class |
LoggingHandler
A
ChannelHandler that logs all events using a logging framework. |
Modifier and Type | Class and Description |
---|---|
class |
ChunkedWriteHandler
A
ChannelHandler that adds support for writing a large data stream
asynchronously neither spending a lot of memory nor getting
OutOfMemoryError . |
Modifier and Type | Class and Description |
---|---|
class |
IdleStateHandler
Triggers an
IdleStateEvent when a Channel has not performed
read, write, or both operation for a while. |
class |
ReadTimeoutHandler
Raises a
ReadTimeoutException when no data was read within a certain
period of time. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractTrafficShapingHandler
AbstractTrafficShapingHandler allows to limit the global bandwidth
(see
GlobalTrafficShapingHandler ) or per session
bandwidth (see ChannelTrafficShapingHandler ), as traffic shaping. |
class |
ChannelTrafficShapingHandler
This implementation of the
AbstractTrafficShapingHandler is for channel
traffic shaping, that is to say a per channel limitation of the bandwidth. |
class |
GlobalChannelTrafficShapingHandler
This implementation of the
AbstractTrafficShapingHandler is for global
and per channel traffic shaping, that is to say a global limitation of the bandwidth, whatever
the number of opened channels and a per channel limitation of the bandwidth.This version shall not be in the same pipeline than other TrafficShapingHandler. The general use should be as follow: Create your unique GlobalChannelTrafficShapingHandler like: GlobalChannelTrafficShapingHandler myHandler = new GlobalChannelTrafficShapingHandler(executor); The executor could be the underlying IO worker pool pipeline.addLast(myHandler); Note that this handler has a Pipeline Coverage of "all" which means only one such handler must be created and shared among all channels as the counter must be shared among all channels. Other arguments can be passed like write or read limitation (in bytes/s where 0 means no limitation) or the check interval (in millisecond) that represents the delay between two computations of the bandwidth and so the call back of the doAccounting method (0 means no accounting at all). Note that as this is a fusion of both Global and Channel Traffic Shaping, limits are in 2 sets, respectively Global and Channel. A value of 0 means no accounting for checkInterval. |
class |
GlobalTrafficShapingHandler
This implementation of the
AbstractTrafficShapingHandler is for global
traffic shaping, that is to say a global limitation of the bandwidth, whatever
the number of opened channels. |