Package | Description |
---|---|
io.netty.bootstrap |
The helper classes with fluent API which enable an easy implementation of
typical client side and server side channel initialization.
|
io.netty.channel |
The core channel API which is asynchronous and event-driven abstraction of
various transports such as a
NIO Channel.
|
io.netty.channel.embedded |
A virtual
Channel that helps wrapping a series of handlers to
unit test the handlers or use them in non-I/O context. |
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.haproxy |
Decodes an HAProxy proxy protocol header
|
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.http.websocketx |
Encoder, decoder, handshakers and their related message types for
Web Socket data frames.
|
io.netty.handler.codec.http.websocketx.extensions |
Encoder, decoder, handshakers to handle
WebSocket Extensions.
|
io.netty.handler.codec.http.websocketx.extensions.compression |
Encoder, decoder, handshakers to handle most common WebSocket Compression Extensions.
|
io.netty.handler.codec.http2 |
Handlers for sending and receiving HTTP/2 frames.
|
io.netty.handler.codec.json |
JSON specific codecs.
|
io.netty.handler.codec.marshalling |
Decoder and Encoder which uses JBoss Marshalling.
|
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.protobuf |
Encoder and decoder which transform a
Google Protocol Buffers
Message and MessageNano into a
ByteBuf and vice versa. |
io.netty.handler.codec.redis |
Encoder, decoder for Redis.
|
io.netty.handler.codec.rtsp |
An RTSP
extension based on the HTTP codec.
|
io.netty.handler.codec.sctp |
Decoder and encoders to manage message completion and multi-streaming codec in SCTP/IP.
|
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.socks |
Encoder, decoder and their related message types for Socks.
|
io.netty.handler.codec.socksx |
Encoder, decoder and their related message types for SOCKS protocol.
|
io.netty.handler.codec.socksx.v4 |
Encoder, decoder and their related message types for SOCKSv4 protocol.
|
io.netty.handler.codec.socksx.v5 |
Encoder, decoder and their related message types for SOCKSv5 protocol.
|
io.netty.handler.codec.spdy |
Encoder, decoder, session handler and their related message types for the SPDY protocol.
|
io.netty.handler.codec.stomp |
STOMP codec
|
io.netty.handler.codec.string | |
io.netty.handler.codec.xml |
XML codec provides asynchronous and non-blocking XML parser based on the
Aalto XML parser.
|
io.netty.handler.flow |
Package to control the flow of messages.
|
io.netty.handler.flush |
Package to control flush behavior.
|
io.netty.handler.ipfilter |
Package to filter IP addresses (allow/deny).
|
io.netty.handler.logging |
Logs the I/O events for debugging purpose.
|
io.netty.handler.proxy |
Adds support for client connections via proxy protocols such as
SOCKS and
HTTP CONNECT tunneling
|
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 | Method and Description |
---|---|
ChannelHandler |
ServerBootstrapConfig.childHandler()
Returns the configured
ChannelHandler be used for the child channels or null
if non is configured yet. |
ChannelHandler |
AbstractBootstrapConfig.handler()
Returns the configured
ChannelHandler or null if non is configured yet. |
Modifier and Type | Method and Description |
---|---|
ServerBootstrap |
ServerBootstrap.childHandler(ChannelHandler childHandler)
Set the
ChannelHandler which is used to serve the request for the Channel 's. |
B |
AbstractBootstrap.handler(ChannelHandler handler)
the
ChannelHandler to use for serving the requests. |
Modifier and Type | Interface and Description |
---|---|
interface |
ChannelInboundHandler
ChannelHandler which adds callbacks for state changes. |
interface |
ChannelOutboundHandler
ChannelHandler which will get notified for IO-outbound-operations. |
Modifier and Type | Class and Description |
---|---|
class |
ChannelDuplexHandler
ChannelHandler implementation which represents a combination out of a ChannelInboundHandler and
the ChannelOutboundHandler . |
class |
ChannelHandlerAdapter
Skeleton implementation of a
ChannelHandler . |
class |
ChannelInboundHandlerAdapter
Abstract base class for
ChannelInboundHandler implementations which provide
implementations of all of their methods. |
class |
ChannelInitializer<C extends Channel>
A special
ChannelInboundHandler which offers an easy way to initialize a Channel once it was
registered to its EventLoop . |
class |
ChannelOutboundHandlerAdapter
Skeleton implementation of a
ChannelOutboundHandler . |
class |
CombinedChannelDuplexHandler<I extends ChannelInboundHandler,O extends ChannelOutboundHandler>
|
class |
SimpleChannelInboundHandler<I>
ChannelInboundHandlerAdapter which allows to explicit only handle a specific type of messages. |
Modifier and Type | Method and Description |
---|---|
<T extends ChannelHandler> |
DefaultChannelPipeline.get(Class<T> handlerType) |
<T extends ChannelHandler> |
ChannelPipeline.get(Class<T> handlerType)
Returns the
ChannelHandler of the specified type in this
pipeline. |
<T extends ChannelHandler> |
DefaultChannelPipeline.remove(Class<T> handlerType) |
<T extends ChannelHandler> |
ChannelPipeline.remove(Class<T> handlerType)
Removes the
ChannelHandler of the specified type from this pipeline. |
<T extends ChannelHandler> |
DefaultChannelPipeline.replace(Class<T> oldHandlerType,
String newName,
ChannelHandler newHandler) |
<T extends ChannelHandler> |
ChannelPipeline.replace(Class<T> oldHandlerType,
String newName,
ChannelHandler newHandler)
Replaces the
ChannelHandler of the specified type with a new handler in this pipeline. |
Modifier and Type | Method and Description |
---|---|
ChannelHandler |
DefaultChannelPipeline.first() |
ChannelHandler |
ChannelPipeline.first()
Returns the first
ChannelHandler in this pipeline. |
ChannelHandler |
DefaultChannelPipeline.get(String name) |
ChannelHandler |
ChannelPipeline.get(String name)
Returns the
ChannelHandler with the specified name in this
pipeline. |
ChannelHandler |
ChannelHandlerContext.handler()
The
ChannelHandler that is bound this ChannelHandlerContext . |
ChannelHandler |
DefaultChannelPipeline.last() |
ChannelHandler |
ChannelPipeline.last()
Returns the last
ChannelHandler in this pipeline. |
ChannelHandler |
DefaultChannelPipeline.remove(String name) |
ChannelHandler |
ChannelPipeline.remove(String name)
Removes the
ChannelHandler with the specified name from this pipeline. |
ChannelHandler |
DefaultChannelPipeline.removeFirst() |
ChannelHandler |
ChannelPipeline.removeFirst()
Removes the first
ChannelHandler in this pipeline. |
ChannelHandler |
DefaultChannelPipeline.removeLast() |
ChannelHandler |
ChannelPipeline.removeLast()
Removes the last
ChannelHandler in this pipeline. |
ChannelHandler |
DefaultChannelPipeline.replace(String oldName,
String newName,
ChannelHandler newHandler) |
ChannelHandler |
ChannelPipeline.replace(String oldName,
String newName,
ChannelHandler newHandler)
Replaces the
ChannelHandler of the specified name with a new handler in this pipeline. |
Modifier and Type | Method and Description |
---|---|
Iterator<Map.Entry<String,ChannelHandler>> |
DefaultChannelPipeline.iterator() |
Map<String,ChannelHandler> |
DefaultChannelPipeline.toMap() |
Map<String,ChannelHandler> |
ChannelPipeline.toMap()
Converts this pipeline into an ordered
Map whose keys are
handler names and whose values are handlers. |
Modifier and Type | Method and Description |
---|---|
ChannelPipeline |
DefaultChannelPipeline.addAfter(EventExecutorGroup group,
String baseName,
String name,
ChannelHandler handler) |
ChannelPipeline |
ChannelPipeline.addAfter(EventExecutorGroup group,
String baseName,
String name,
ChannelHandler handler)
Inserts a
ChannelHandler after an existing handler of this
pipeline. |
ChannelPipeline |
DefaultChannelPipeline.addAfter(String baseName,
String name,
ChannelHandler handler) |
ChannelPipeline |
ChannelPipeline.addAfter(String baseName,
String name,
ChannelHandler handler)
Inserts a
ChannelHandler after an existing handler of this
pipeline. |
ChannelPipeline |
DefaultChannelPipeline.addBefore(EventExecutorGroup group,
String baseName,
String name,
ChannelHandler handler) |
ChannelPipeline |
ChannelPipeline.addBefore(EventExecutorGroup group,
String baseName,
String name,
ChannelHandler handler)
Inserts a
ChannelHandler before an existing handler of this
pipeline. |
ChannelPipeline |
DefaultChannelPipeline.addBefore(String baseName,
String name,
ChannelHandler handler) |
ChannelPipeline |
ChannelPipeline.addBefore(String baseName,
String name,
ChannelHandler handler)
Inserts a
ChannelHandler before an existing handler of this
pipeline. |
ChannelPipeline |
DefaultChannelPipeline.addFirst(ChannelHandler... handlers) |
ChannelPipeline |
ChannelPipeline.addFirst(ChannelHandler... handlers)
Inserts
ChannelHandler s at the first position of this pipeline. |
ChannelPipeline |
DefaultChannelPipeline.addFirst(EventExecutorGroup executor,
ChannelHandler... handlers) |
ChannelPipeline |
ChannelPipeline.addFirst(EventExecutorGroup group,
ChannelHandler... handlers)
Inserts
ChannelHandler s at the first position of this pipeline. |
ChannelPipeline |
DefaultChannelPipeline.addFirst(EventExecutorGroup group,
String name,
ChannelHandler handler) |
ChannelPipeline |
ChannelPipeline.addFirst(EventExecutorGroup group,
String name,
ChannelHandler handler)
Inserts a
ChannelHandler at the first position of this pipeline. |
ChannelPipeline |
DefaultChannelPipeline.addFirst(String name,
ChannelHandler handler) |
ChannelPipeline |
ChannelPipeline.addFirst(String name,
ChannelHandler handler)
Inserts a
ChannelHandler at the first position of this pipeline. |
ChannelPipeline |
DefaultChannelPipeline.addLast(ChannelHandler... handlers) |
ChannelPipeline |
ChannelPipeline.addLast(ChannelHandler... handlers)
Inserts
ChannelHandler s at the last position of this pipeline. |
ChannelPipeline |
DefaultChannelPipeline.addLast(EventExecutorGroup executor,
ChannelHandler... handlers) |
ChannelPipeline |
ChannelPipeline.addLast(EventExecutorGroup group,
ChannelHandler... handlers)
Inserts
ChannelHandler s at the last position of this pipeline. |
ChannelPipeline |
DefaultChannelPipeline.addLast(EventExecutorGroup group,
String name,
ChannelHandler handler) |
ChannelPipeline |
ChannelPipeline.addLast(EventExecutorGroup group,
String name,
ChannelHandler handler)
Appends a
ChannelHandler at the last position of this pipeline. |
ChannelPipeline |
DefaultChannelPipeline.addLast(String name,
ChannelHandler handler) |
ChannelPipeline |
ChannelPipeline.addLast(String name,
ChannelHandler handler)
Appends a
ChannelHandler at the last position of this pipeline. |
ChannelHandlerContext |
DefaultChannelPipeline.context(ChannelHandler handler) |
ChannelHandlerContext |
ChannelPipeline.context(ChannelHandler handler)
Returns the context object of the specified
ChannelHandler in
this pipeline. |
ChannelPipeline |
DefaultChannelPipeline.remove(ChannelHandler handler) |
ChannelPipeline |
ChannelPipeline.remove(ChannelHandler handler)
Removes the specified
ChannelHandler from this pipeline. |
ChannelPipeline |
DefaultChannelPipeline.replace(ChannelHandler oldHandler,
String newName,
ChannelHandler newHandler) |
ChannelPipeline |
ChannelPipeline.replace(ChannelHandler oldHandler,
String newName,
ChannelHandler newHandler)
Replaces the specified
ChannelHandler with a new handler in this pipeline. |
<T extends ChannelHandler> |
DefaultChannelPipeline.replace(Class<T> oldHandlerType,
String newName,
ChannelHandler newHandler) |
<T extends ChannelHandler> |
ChannelPipeline.replace(Class<T> oldHandlerType,
String newName,
ChannelHandler newHandler)
Replaces the
ChannelHandler of the specified type with a new handler in this pipeline. |
ChannelHandler |
DefaultChannelPipeline.replace(String oldName,
String newName,
ChannelHandler newHandler) |
ChannelHandler |
ChannelPipeline.replace(String oldName,
String newName,
ChannelHandler newHandler)
Replaces the
ChannelHandler of the specified name with a new handler in this pipeline. |
Modifier and Type | Method and Description |
---|---|
ChannelHandlerContext |
DefaultChannelPipeline.context(Class<? extends ChannelHandler> handlerType) |
ChannelHandlerContext |
ChannelPipeline.context(Class<? extends ChannelHandler> handlerType)
Returns the context object of the
ChannelHandler of the
specified type in this pipeline. |
Constructor and Description |
---|
EmbeddedChannel(boolean hasDisconnect,
ChannelHandler... handlers)
Create a new instance with the pipeline initialized with the specified handlers.
|
EmbeddedChannel(ChannelHandler... handlers)
Create a new instance with the pipeline initialized with the specified handlers.
|
EmbeddedChannel(ChannelId channelId,
boolean hasDisconnect,
ChannelConfig config,
ChannelHandler... handlers)
Create a new instance with the channel ID set to the given ID and the pipeline
initialized with the specified handlers.
|
EmbeddedChannel(ChannelId channelId,
boolean hasDisconnect,
ChannelHandler... handlers)
Create a new instance with the channel ID set to the given ID and the pipeline
initialized with the specified handlers.
|
EmbeddedChannel(ChannelId channelId,
ChannelHandler... handlers)
Create a new instance with the channel ID set to the given ID and the pipeline
initialized with the specified handlers.
|
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 |
ByteToMessageDecoder
ChannelInboundHandlerAdapter which decodes bytes in a stream-like fashion from one ByteBuf to an
other Message type. |
class |
DatagramPacketDecoder
A decoder that decodes the content of the received
DatagramPacket using
the specified ByteBuf decoder. |
class |
DatagramPacketEncoder<M>
An encoder that encodes the content in
AddressedEnvelope to DatagramPacket using
the specified message encoder. |
class |
DelimiterBasedFrameDecoder
A decoder that splits the received
ByteBuf s by one or more
delimiters. |
class |
FixedLengthFrameDecoder
A decoder that splits the received
ByteBuf s by the fixed number
of bytes. |
class |
LengthFieldBasedFrameDecoder
A decoder that splits the received
ByteBuf s dynamically by the
value of the length field in the message. |
class |
LengthFieldPrepender
An encoder that prepends the length of the message.
|
class |
LineBasedFrameDecoder
A decoder that splits the received
ByteBuf s on line endings. |
class |
MessageAggregator<I,S,C extends ByteBufHolder,O extends ByteBufHolder>
An abstract
ChannelHandler that aggregates a series of message objects into a single aggregated 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 |
MessageToMessageDecoder<I>
ChannelInboundHandlerAdapter which decodes from one message to an other 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 . |
class |
ReplayingDecoder<S>
A specialized variation of
ByteToMessageDecoder which enables implementation
of a non-blocking decoder in the blocking I/O paradigm. |
Modifier and Type | Class and Description |
---|---|
class |
Base64Decoder
|
class |
Base64Encoder
|
Modifier and Type | Class and Description |
---|---|
class |
ByteArrayDecoder
Decodes a received
ByteBuf into an array of bytes. |
class |
ByteArrayEncoder
Encodes the requested array of bytes into a
ByteBuf . |
Modifier and Type | Class and Description |
---|---|
class |
Bzip2Decoder
Uncompresses a
ByteBuf encoded with the Bzip2 format. |
class |
Bzip2Encoder
Compresses a
ByteBuf using the Bzip2 algorithm. |
class |
FastLzFrameDecoder
Uncompresses a
ByteBuf encoded by FastLzFrameEncoder using the FastLZ algorithm. |
class |
FastLzFrameEncoder
Compresses a
ByteBuf using the FastLZ algorithm. |
class |
JdkZlibDecoder
Decompress a
ByteBuf using the inflate algorithm. |
class |
JdkZlibEncoder
Compresses a
ByteBuf using the deflate algorithm. |
class |
JZlibDecoder |
class |
JZlibEncoder
Compresses a
ByteBuf using the deflate algorithm. |
class |
Lz4FrameDecoder
Uncompresses a
ByteBuf encoded with the LZ4 format. |
class |
Lz4FrameEncoder
Compresses a
ByteBuf using the LZ4 format. |
class |
LzfDecoder
Uncompresses a
ByteBuf encoded with the LZF format. |
class |
LzfEncoder
Compresses a
ByteBuf using the LZF format. |
class |
LzmaFrameEncoder
Compresses a
ByteBuf using the LZMA algorithm. |
class |
SnappyFramedDecoder
Deprecated.
Use
SnappyFrameDecoder instead. |
class |
SnappyFrameDecoder
Uncompresses a
ByteBuf encoded with the Snappy framing format. |
class |
SnappyFramedEncoder
Deprecated.
Use
SnappyFrameEncoder instead. |
class |
SnappyFrameEncoder
Compresses a
ByteBuf using the Snappy framing format. |
class |
ZlibDecoder
Decompresses a
ByteBuf using the deflate algorithm. |
class |
ZlibEncoder
Compresses a
ByteBuf using the deflate algorithm. |
Modifier and Type | Class and Description |
---|---|
class |
DatagramDnsQueryDecoder
Decodes a
DatagramPacket into a DatagramDnsQuery . |
class |
DatagramDnsQueryEncoder
|
class |
DatagramDnsResponseDecoder
Decodes a
DatagramPacket into a DatagramDnsResponse . |
class |
DatagramDnsResponseEncoder
|
Modifier and Type | Class and Description |
---|---|
class |
HAProxyMessageDecoder
Decodes an HAProxy proxy protocol header
|
Modifier and Type | Class and Description |
---|---|
class |
HttpClientCodec
A combination of
HttpRequestEncoder and HttpResponseDecoder
which enables easier client side HTTP implementation. |
class |
HttpClientUpgradeHandler
Client-side handler for handling an HTTP upgrade handshake to another protocol.
|
class |
HttpContentCompressor
Compresses an
HttpMessage and an HttpContent in gzip or
deflate encoding while respecting the "Accept-Encoding" header. |
class |
HttpContentDecoder
Decodes the content of the received
HttpRequest and HttpContent . |
class |
HttpContentDecompressor
|
class |
HttpContentEncoder
Encodes the content of the outbound
HttpResponse and HttpContent . |
class |
HttpObjectAggregator
A
ChannelHandler that aggregates an HttpMessage
and its following HttpContent s into a single FullHttpRequest
or FullHttpResponse (depending on if it used to handle requests or responses)
with no following HttpContent s. |
class |
HttpObjectDecoder
|
class |
HttpObjectEncoder<H extends HttpMessage>
|
class |
HttpRequestDecoder
|
class |
HttpRequestEncoder
|
class |
HttpResponseDecoder
|
class |
HttpResponseEncoder
|
class |
HttpServerCodec
A combination of
HttpRequestDecoder and HttpResponseEncoder
which enables easier server side HTTP implementation. |
class |
HttpServerExpectContinueHandler
|
class |
HttpServerKeepAliveHandler
HttpServerKeepAliveHandler helps close persistent connections when appropriate.
|
class |
HttpServerUpgradeHandler
A server-side handler that receives HTTP requests and optionally performs a protocol switch if
the requested protocol is supported.
|
Modifier and Type | Class and Description |
---|---|
class |
CorsHandler
Handles Cross Origin Resource Sharing (CORS) requests.
|
Modifier and Type | Interface and Description |
---|---|
interface |
WebSocketFrameDecoder
Marker interface which all WebSocketFrame decoders need to implement.
|
interface |
WebSocketFrameEncoder
Marker interface which all WebSocketFrame encoders need to implement.
|
Modifier and Type | Class and Description |
---|---|
class |
Utf8FrameValidator |
class |
WebSocket00FrameDecoder
Decodes
ByteBuf s into WebSocketFrame s. |
class |
WebSocket00FrameEncoder
Encodes a
WebSocketFrame into a ByteBuf . |
class |
WebSocket07FrameDecoder
Decodes a web socket frame from wire protocol version 7 format.
|
class |
WebSocket07FrameEncoder
Encodes a web socket frame into wire protocol version 7 format.
|
class |
WebSocket08FrameDecoder
Decodes a web socket frame from wire protocol version 8 format.
|
class |
WebSocket08FrameEncoder
Encodes a web socket frame into wire protocol version 8 format.
|
class |
WebSocket13FrameDecoder
Decodes a web socket frame from wire protocol version 13 format.
|
class |
WebSocket13FrameEncoder
Encodes a web socket frame into wire protocol version 13 format.
|
class |
WebSocketClientProtocolHandler
This handler does all the heavy lifting for you to run a websocket client.
|
class |
WebSocketFrameAggregator
Handler that aggregate fragmented WebSocketFrame's.
|
class |
WebSocketServerProtocolHandler
This handler does all the heavy lifting for you to run a websocket server.
|
Modifier and Type | Class and Description |
---|---|
class |
WebSocketClientExtensionHandler
This handler negotiates and initializes the WebSocket Extensions.
|
class |
WebSocketExtensionDecoder
Convenient class for io.netty.handler.codec.http.websocketx.extensions.WebSocketExtension decoder.
|
class |
WebSocketExtensionEncoder
Convenient class for io.netty.handler.codec.http.websocketx.extensions.WebSocketExtension encoder.
|
class |
WebSocketServerExtensionHandler
This handler negotiates and initializes the WebSocket Extensions.
|
Modifier and Type | Class and Description |
---|---|
class |
WebSocketClientCompressionHandler
Extends io.netty.handler.codec.http.websocketx.extensions.compression.WebSocketClientExtensionHandler
to handle the most common WebSocket Compression Extensions.
|
class |
WebSocketServerCompressionHandler
Extends io.netty.handler.codec.http.websocketx.extensions.compression.WebSocketServerExtensionHandler
to handle the most common WebSocket Compression Extensions.
|
Modifier and Type | Class and Description |
---|---|
class |
CleartextHttp2ServerUpgradeHandler
Performing cleartext upgrade, by h2c HTTP upgrade or Prior Knowledge.
|
class |
Http2Codec
An HTTP/2 channel handler that adds a
Http2FrameCodec and Http2MultiplexCodec to the pipeline before
removing itself. |
class |
Http2ConnectionHandler
Provides the default implementation for processing inbound frame events and delegates to a
Http2FrameListener |
class |
Http2FrameCodec
An HTTP/2 handler that maps HTTP/2 frames to
Http2Frame objects and vice versa. |
class |
Http2FrameLogger
Logs HTTP2 frames for debugging purposes.
|
class |
Http2MultiplexCodec
An HTTP/2 handler that creates child channels for each stream.
|
class |
Http2ServerDowngrader
This is a server-side adapter so that an http2 codec can be downgraded to
appear as if it's speaking http/1.1.
|
class |
HttpToHttp2ConnectionHandler
Translates HTTP/1.x object writes into HTTP/2 frames.
|
class |
InboundHttpToHttp2Adapter
Translates HTTP/1.x object reads into HTTP/2 frames.
|
Modifier and Type | Method and Description |
---|---|
ChannelHandler |
Http2StreamChannelBootstrap.handler() |
Modifier and Type | Method and Description |
---|---|
Http2StreamChannelBootstrap |
Http2StreamChannelBootstrap.handler(ChannelHandler handler)
Sets the channel handler that should be added to the channels's pipeline.
|
Constructor and Description |
---|
CleartextHttp2ServerUpgradeHandler(HttpServerCodec httpServerCodec,
HttpServerUpgradeHandler httpServerUpgradeHandler,
ChannelHandler http2ServerHandler)
Creates the channel handler provide cleartext HTTP/2 upgrade from HTTP
upgrade or prior knowledge
|
Http2CodecBuilder(boolean server,
ChannelHandler streamHandler)
Creates a new
Http2Codec builder. |
Modifier and Type | Class and Description |
---|---|
class |
JsonObjectDecoder
Splits a byte stream of JSON objects and arrays into individual objects/arrays and passes them up the
ChannelPipeline . |
Modifier and Type | Class and Description |
---|---|
class |
CompatibleMarshallingDecoder
|
class |
CompatibleMarshallingEncoder
MessageToByteEncoder implementation which uses JBoss Marshalling to marshal
an Object. |
class |
MarshallingDecoder
Decoder which MUST be used with
MarshallingEncoder . |
class |
MarshallingEncoder
MessageToByteEncoder implementation which uses JBoss Marshalling to marshal
an Object. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractMemcacheObjectAggregator<H extends MemcacheMessage>
A
ChannelHandler that aggregates an MemcacheMessage
and its following MemcacheContent s into a single MemcacheMessage with
no following MemcacheContent s. |
class |
AbstractMemcacheObjectDecoder
Abstract super class for both ascii and binary decoders.
|
class |
AbstractMemcacheObjectEncoder<M extends MemcacheMessage>
A general purpose
AbstractMemcacheObjectEncoder that encodes MemcacheMessage s. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractBinaryMemcacheDecoder<M extends BinaryMemcacheMessage>
Decoder for both
BinaryMemcacheRequest and BinaryMemcacheResponse . |
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 |
BinaryMemcacheObjectAggregator
An object aggregator for the memcache binary protocol.
|
class |
BinaryMemcacheRequestDecoder
The decoder part which takes care of decoding the request-specific headers.
|
class |
BinaryMemcacheRequestEncoder
The encoder part which takes care of encoding the request headers.
|
class |
BinaryMemcacheResponseDecoder
The decoder which takes care of decoding the response 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 |
MqttDecoder
Decodes Mqtt messages from bytes, following
the MQTT protocol specification v3.1
|
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 |
ProtobufDecoder
|
class |
ProtobufDecoderNano
|
class |
ProtobufEncoder
|
class |
ProtobufEncoderNano
|
class |
ProtobufVarint32FrameDecoder
A decoder that splits the received
ByteBuf s dynamically by the
value of the Google Protocol Buffers
Base
128 Varints integer length field in the message. |
class |
ProtobufVarint32LengthFieldPrepender
An encoder that prepends the the Google Protocol Buffers
Base
128 Varints integer length field.
|
Modifier and Type | Class and Description |
---|---|
class |
RedisArrayAggregator
Aggregates
RedisMessage parts into ArrayRedisMessage . |
class |
RedisBulkStringAggregator
A
ChannelHandler that aggregates an BulkStringHeaderRedisMessage
and its following BulkStringRedisContent s into a single FullBulkStringRedisMessage
with no following BulkStringRedisContent s. |
class |
RedisDecoder
Decodes the Redis protocol into
RedisMessage objects following
RESP (REdis Serialization Protocol). |
class |
RedisEncoder
Encodes
RedisMessage into bytes following
RESP (REdis Serialization Protocol). |
Modifier and Type | Class and Description |
---|---|
class |
RtspDecoder
Decodes
ByteBuf s into RTSP messages represented in
HttpMessage s. |
class |
RtspEncoder
|
class |
RtspObjectDecoder
Deprecated.
Use
RtspDecoder instead. |
class |
RtspObjectEncoder<H extends HttpMessage>
Deprecated.
Use
RtspEncoder instead. |
class |
RtspRequestDecoder
Deprecated.
Use
RtspDecoder directly instead |
class |
RtspRequestEncoder
Deprecated.
Use
RtspEncoder directly instead |
class |
RtspResponseDecoder
Deprecated.
Use
RtspDecoder directly instead |
class |
RtspResponseEncoder
Deprecated.
Use
RtspEncoder directly instead |
Modifier and Type | Class and Description |
---|---|
class |
SctpInboundByteStreamHandler
A ChannelHandler which receives
SctpMessage s which belong to a application protocol form a specific
SCTP Stream and decode it as ByteBuf . |
class |
SctpMessageCompletionHandler
MessageToMessageDecoder which will take care of handle fragmented SctpMessage s, so
only complete SctpMessage s will be forwarded to the next
ChannelInboundHandler . |
class |
SctpMessageToMessageDecoder |
class |
SctpOutboundByteStreamHandler
A ChannelHandler which transform
ByteBuf to SctpMessage and send it through a specific stream
with given protocol identifier. |
Modifier and Type | Class and Description |
---|---|
class |
CompatibleObjectEncoder
An encoder which serializes a Java object into a
ByteBuf
(interoperability version). |
class |
ObjectDecoder
A decoder which deserializes the received
ByteBuf s into Java
objects. |
class |
ObjectEncoder
An encoder which serializes a Java object into a
ByteBuf . |
Modifier and Type | Class and Description |
---|---|
class |
SmtpRequestEncoder
Encoder for SMTP requests.
|
class |
SmtpResponseDecoder
Decoder for SMTP responses.
|
Modifier and Type | Class and Description |
---|---|
class |
SocksAuthRequestDecoder
Decodes
ByteBuf s into SocksAuthRequest . |
class |
SocksAuthResponseDecoder
Decodes
ByteBuf s into SocksAuthResponse . |
class |
SocksCmdRequestDecoder
Decodes
ByteBuf s into SocksCmdRequest . |
class |
SocksCmdResponseDecoder
Decodes
ByteBuf s into SocksCmdResponse . |
class |
SocksInitRequestDecoder
Decodes
ByteBuf s into SocksInitRequest . |
class |
SocksInitResponseDecoder
Decodes
ByteBuf s into SocksInitResponse . |
class |
SocksMessageEncoder
Encodes an
SocksMessage into a ByteBuf . |
Modifier and Type | Class and Description |
---|---|
class |
SocksPortUnificationServerHandler
Detects the version of the current SOCKS connection and initializes the pipeline with
Socks4ServerDecoder or Socks5InitialRequestDecoder . |
Modifier and Type | Class and Description |
---|---|
class |
Socks4ClientDecoder
Decodes a single
Socks4CommandResponse from the inbound ByteBuf s. |
class |
Socks4ClientEncoder
Encodes a
Socks4CommandRequest into a ByteBuf . |
class |
Socks4ServerDecoder
Decodes a single
Socks4CommandRequest from the inbound ByteBuf s. |
class |
Socks4ServerEncoder
Encodes a
Socks4CommandResponse into a ByteBuf . |
Modifier and Type | Class and Description |
---|---|
class |
Socks5ClientEncoder
Encodes a client-side
Socks5Message into a ByteBuf . |
class |
Socks5CommandRequestDecoder
Decodes a single
Socks5CommandRequest from the inbound ByteBuf s. |
class |
Socks5CommandResponseDecoder
Decodes a single
Socks5CommandResponse from the inbound ByteBuf s. |
class |
Socks5InitialRequestDecoder
Decodes a single
Socks5InitialRequest from the inbound ByteBuf s. |
class |
Socks5InitialResponseDecoder
Decodes a single
Socks5InitialResponse from the inbound ByteBuf s. |
class |
Socks5PasswordAuthRequestDecoder
Decodes a single
Socks5PasswordAuthRequest from the inbound ByteBuf s. |
class |
Socks5PasswordAuthResponseDecoder
Decodes a single
Socks5PasswordAuthResponse from the inbound ByteBuf s. |
class |
Socks5ServerEncoder
Encodes a server-side
Socks5Message into a ByteBuf . |
Modifier and Type | Class and Description |
---|---|
class |
SpdyFrameCodec
A
ChannelHandler that encodes and decodes SPDY Frames. |
class |
SpdyHttpCodec
A combination of
SpdyHttpDecoder and SpdyHttpEncoder |
class |
SpdyHttpDecoder
Decodes
SpdySynStreamFrame s, SpdySynReplyFrame s,
and SpdyDataFrame s into FullHttpRequest s and FullHttpResponse s. |
class |
SpdyHttpEncoder
Encodes
HttpRequest s, HttpResponse s, and HttpContent s
into SpdySynStreamFrame s and SpdySynReplyFrame s. |
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 |
StompSubframeAggregator
A
ChannelHandler that aggregates an StompHeadersSubframe
and its following StompContentSubframe s into a single StompFrame . |
class |
StompSubframeDecoder
|
class |
StompSubframeEncoder
|
Modifier and Type | Class and Description |
---|---|
class |
LineEncoder
|
class |
StringDecoder
|
class |
StringEncoder
|
Modifier and Type | Class and Description |
---|---|
class |
XmlDecoder
Async XML decoder based on Aalto XML parser.
|
class |
XmlFrameDecoder
A frame decoder for single separate XML based message streams.
|
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 |
AbstractRemoteAddressFilter<T extends SocketAddress>
This class provides the functionality to either accept or reject new
Channel s
based on their IP address. |
class |
RuleBasedIpFilter
This class allows one to filter new
Channel s based on the
IpFilterRule s passed to its constructor. |
class |
UniqueIpFilter
This class allows one to ensure that at all times for every IP address there is at most one
Channel connected to the server. |
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 |
HttpProxyHandler |
class |
ProxyHandler |
class |
Socks4ProxyHandler |
class |
Socks5ProxyHandler |
Modifier and Type | Class and Description |
---|---|
class |
AbstractSniHandler<T>
Enables SNI
(Server Name Indication) extension for server side SSL.
|
class |
ApplicationProtocolNegotiationHandler
Configures a
ChannelPipeline depending on the application-level protocol negotiation result of
SslHandler . |
class |
OptionalSslHandler
OptionalSslHandler is a utility decoder to support both SSL and non-SSL handlers
based on the first message received. |
class |
SniHandler
Enables SNI
(Server Name Indication) extension for server side SSL.
|
class |
SslHandler
|
Modifier and Type | Method and Description |
---|---|
protected ChannelHandler |
OptionalSslHandler.newNonSslHandler(ChannelHandlerContext context)
Override to configure the ChannelHandler.
|
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–2018 The Netty Project. All rights reserved.