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.base64 | |
io.netty.handler.codec.bytes |
Encoder and decoder which transform an array of bytes into a
ByteBuf and vice versa. |
io.netty.handler.codec.compression | |
io.netty.handler.codec.dns |
DNS codec.
|
io.netty.handler.codec.memcache |
Common superset of ascii and binary classes.
|
io.netty.handler.codec.memcache.binary |
Implementations and Interfaces for the Memcache Binary protocol.
|
io.netty.handler.codec.mqtt |
Encoder, decoder and different Message Types for MQTT.
|
io.netty.handler.codec.redis |
Encoder, decoder for Redis.
|
io.netty.handler.codec.serialization |
Encoder, decoder and their compatibility stream implementations which
transform a
Serializable object into a byte buffer and
vice versa. |
io.netty.handler.codec.smtp |
SMTP codec.
|
io.netty.handler.codec.stomp |
STOMP codec
|
io.netty.handler.codec.string | |
io.netty.handler.flow |
Package to control the flow of messages.
|
io.netty.handler.flush |
Package to control flush behavior.
|
io.netty.handler.logging |
Logs the I/O events for debugging purpose.
|
io.netty.handler.ssl | |
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 |
ChannelDuplexHandler
ChannelHandler implementation which represents a combination out of a ChannelInboundHandler and
the ChannelOutboundHandler . |
class |
ChannelOutboundHandlerAdapter
Skeleton implementation of a
ChannelOutboundHandler . |
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 |
DatagramPacketEncoder<M>
An encoder that encodes the content in
AddressedEnvelope to DatagramPacket using
the specified message encoder. |
class |
LengthFieldPrepender
An encoder that prepends the length of the message.
|
class |
MessageToByteEncoder<I>
ChannelOutboundHandlerAdapter which encodes message in a stream-like fashion from one message to an
ByteBuf . |
class |
MessageToMessageCodec<INBOUND_IN,OUTBOUND_IN>
A Codec for on-the-fly encoding/decoding of message.
|
class |
MessageToMessageEncoder<I>
ChannelOutboundHandlerAdapter which encodes from one message to an other message
For example here is an implementation which decodes an Integer to an String . |
Modifier and Type | Class and Description |
---|---|
class |
Base64Encoder
|
Modifier and Type | Class and Description |
---|---|
class |
ByteArrayEncoder
Encodes the requested array of bytes into a
ByteBuf . |
Modifier and Type | Class and Description |
---|---|
class |
Bzip2Encoder
Compresses a
ByteBuf using the Bzip2 algorithm. |
class |
FastLzFrameEncoder
Compresses a
ByteBuf using the FastLZ algorithm. |
class |
JdkZlibEncoder
Compresses a
ByteBuf using the deflate algorithm. |
class |
JZlibEncoder
Compresses a
ByteBuf using the deflate algorithm. |
class |
SnappyFramedEncoder
Deprecated.
Use
SnappyFrameEncoder instead. |
class |
SnappyFrameEncoder
Compresses a
ByteBuf using the Snappy framing format. |
class |
ZlibEncoder
Compresses a
ByteBuf using the deflate algorithm. |
Modifier and Type | Class and Description |
---|---|
class |
DatagramDnsQueryEncoder
|
class |
DatagramDnsResponseEncoder
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractMemcacheObjectEncoder<M extends MemcacheMessage>
A general purpose
AbstractMemcacheObjectEncoder that encodes MemcacheMessage s. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractBinaryMemcacheEncoder<M extends BinaryMemcacheMessage>
A
MessageToByteEncoder that encodes binary memcache messages into bytes. |
class |
BinaryMemcacheClientCodec
The client codec that combines the proper encoder and decoder.
|
class |
BinaryMemcacheRequestEncoder
The encoder part which takes care of encoding the request headers.
|
class |
BinaryMemcacheResponseEncoder
The encoder which takes care of encoding the response headers.
|
class |
BinaryMemcacheServerCodec
The full server codec that combines the correct encoder and decoder.
|
Modifier and Type | Class and Description |
---|---|
class |
MqttEncoder
Encodes Mqtt messages into bytes following the protocol specification v3.1
as described here MQTTV3.1
|
Modifier and Type | Class and Description |
---|---|
class |
RedisEncoder
Encodes
RedisMessage into bytes following
RESP (REdis Serialization Protocol). |
Modifier and Type | Class and Description |
---|---|
class |
CompatibleObjectEncoder
An encoder which serializes a Java object into a
ByteBuf
(interoperability version). |
class |
ObjectEncoder
An encoder which serializes a Java object into a
ByteBuf . |
Modifier and Type | Class and Description |
---|---|
class |
SmtpRequestEncoder
Encoder for SMTP requests.
|
Modifier and Type | Class and Description |
---|---|
class |
StompSubframeEncoder
|
Modifier and Type | Class and Description |
---|---|
class |
LineEncoder
|
class |
StringEncoder
|
Modifier and Type | Class and Description |
---|---|
class |
FlowControlHandler
The
FlowControlHandler ensures that only one message per read() is sent downstream. |
Modifier and Type | Class and Description |
---|---|
class |
FlushConsolidationHandler
ChannelDuplexHandler which consolidates Channel.flush() / ChannelHandlerContext.flush()
operations (which also includes
ChannelOutboundInvoker.writeAndFlush(Object) / ChannelOutboundInvoker.writeAndFlush(Object, ChannelPromise) and
ChannelOutboundInvoker.writeAndFlush(Object) /
ChannelOutboundInvoker.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 |
AbstractSniHandler<T>
Enables SNI
(Server Name Indication) extension for server side SSL.
|
class |
SniHandler
Enables SNI
(Server Name Indication) extension for server side SSL.
|
class |
SslHandler
|
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. |
class |
WriteTimeoutHandler
Raises a
WriteTimeoutException when a write operation cannot finish in 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. |
Copyright © 2008-2017 The Netty Project. All Rights Reserved.