Package | Description |
---|---|
org.jboss.netty.channel |
The core channel API which is asynchronous and event-driven abstraction of
various transports such as a
NIO Channel.
|
org.jboss.netty.example.discard | |
org.jboss.netty.example.echo | |
org.jboss.netty.example.factorial | |
org.jboss.netty.example.http.file | |
org.jboss.netty.example.http.snoop | |
org.jboss.netty.example.http.upload | |
org.jboss.netty.example.http.websocketx.autobahn |
This package is intended for use with testing against the Python
AutoBahn test suite.
|
org.jboss.netty.example.http.websocketx.client |
This is an example web service client.
|
org.jboss.netty.example.http.websocketx.html5 | |
org.jboss.netty.example.http.websocketx.server |
This package contains an example web socket web server.
|
org.jboss.netty.example.http.websocketx.sslserver |
This package contains an example web socket web server with server SSL.
|
org.jboss.netty.example.localtime | |
org.jboss.netty.example.objectecho | |
org.jboss.netty.example.portunification | |
org.jboss.netty.example.proxy | |
org.jboss.netty.example.qotm | |
org.jboss.netty.example.securechat | |
org.jboss.netty.example.telnet | |
org.jboss.netty.example.uptime | |
org.jboss.netty.handler.codec.base64 |
Encoder and decoder which transform a
Base64-encoded
String or ChannelBuffer
into a decoded ChannelBuffer and vice versa. |
org.jboss.netty.handler.codec.compression |
Encoder and decoder which compresses and decompresses
ChannelBuffer s
in a compression format such as zlib
and gzip. |
org.jboss.netty.handler.codec.embedder |
A helper that wraps an encoder or a decoder so that they can be used without
doing actual I/O in unit tests or higher level codecs.
|
org.jboss.netty.handler.codec.frame |
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.
|
org.jboss.netty.handler.codec.http |
Encoder, decoder and their related message types for HTTP.
|
org.jboss.netty.handler.codec.http.websocket | |
org.jboss.netty.handler.codec.http.websocketx |
Encoder, decoder, handshakers and their related message types for
Web Socket data frames.
|
org.jboss.netty.handler.codec.oneone |
Simplistic abstract classes which help implement encoder and decoder that
transform an object into another object and vice versa.
|
org.jboss.netty.handler.codec.protobuf |
Encoder and decoder which transform a
Google Protocol Buffers
Message into a ChannelBuffer
and vice versa. |
org.jboss.netty.handler.codec.replay |
Specialized variation of
FrameDecoder
which enables implementation of a non-blocking decoder in the blocking I/O
paradigm. |
org.jboss.netty.handler.codec.rtsp |
An RTSP
extension based on the HTTP codec.
|
org.jboss.netty.handler.codec.serialization |
Encoder, decoder and their compatibility stream implementations which
transform a
Serializable object into a byte buffer and
vice versa. |
org.jboss.netty.handler.codec.socks |
Encoder, decoder and their related message types for Socks.
|
org.jboss.netty.handler.codec.spdy |
Encoder, decoder, session handler and their related message types for the SPDY protocol.
|
org.jboss.netty.handler.codec.string |
Encoder and decoder which transform a
String into a
ChannelBuffer and vice versa. |
org.jboss.netty.handler.execution |
Executor -based implementation of various
thread models that separate business logic from I/O threads |
org.jboss.netty.handler.ipfilter |
Implementation of a Ip based Filter handlers.
|
org.jboss.netty.handler.logging |
Logs a
ChannelEvent for debugging purpose
using an InternalLogger . |
org.jboss.netty.handler.queue |
The special-purpose handlers that store an event into an internal queue
instead of propagating the event immediately.
|
org.jboss.netty.handler.ssl | |
org.jboss.netty.handler.stream |
Writes very large data stream asynchronously neither spending a lot of
memory nor getting
OutOfMemoryError . |
org.jboss.netty.handler.timeout |
Adds support for read and write timeout and idle connection notification
using a
Timer . |
org.jboss.netty.handler.traffic |
Implementation of a Traffic Shaping Handler and Dynamic Statistics.
|
Modifier and Type | Class and Description |
---|---|
class |
SimpleChannelHandler
A
ChannelHandler which provides an individual handler method
for each event type. |
class |
SimpleChannelUpstreamHandler
A
ChannelUpstreamHandler which provides an individual handler method
for each event type. |
Modifier and Type | Class and Description |
---|---|
class |
DiscardClientHandler
Handles a client-side channel.
|
class |
DiscardServerHandler
Handles a server-side channel.
|
Modifier and Type | Class and Description |
---|---|
class |
EchoClientHandler
Handler implementation for the echo client.
|
class |
EchoServerHandler
Handler implementation for the echo server.
|
Modifier and Type | Class and Description |
---|---|
class |
BigIntegerDecoder
Decodes the binary representation of a
BigInteger prepended
with a magic number ('F' or 0x46) and a 32-bit integer length prefix into a
BigInteger instance. |
class |
FactorialClientHandler
Handler for a client-side channel.
|
class |
FactorialServerHandler
Handler for a server-side channel.
|
Modifier and Type | Class and Description |
---|---|
class |
HttpStaticFileServerHandler
A simple handler that serves incoming HTTP requests to send their respective
HTTP responses.
|
Modifier and Type | Class and Description |
---|---|
class |
HttpSnoopClientHandler |
class |
HttpSnoopServerHandler |
Modifier and Type | Class and Description |
---|---|
class |
HttpUploadClientHandler |
class |
HttpUploadServerHandler |
Modifier and Type | Class and Description |
---|---|
class |
AutobahnServerHandler
Handles handshakes and messages
|
Modifier and Type | Class and Description |
---|---|
class |
WebSocketClientHandler |
Modifier and Type | Class and Description |
---|---|
class |
CustomTextFrameHandler |
Modifier and Type | Class and Description |
---|---|
class |
WebSocketServerHandler
Handles handshakes and messages
|
Modifier and Type | Class and Description |
---|---|
class |
WebSocketSslServerHandler
Handles handshakes and messages
|
Modifier and Type | Class and Description |
---|---|
class |
LocalTimeClientHandler |
class |
LocalTimeServerHandler |
Modifier and Type | Class and Description |
---|---|
class |
ObjectEchoClientHandler
Handler implementation for the object echo client.
|
class |
ObjectEchoServerHandler
Handles both client-side and server-side handler depending on which
constructor was called.
|
Modifier and Type | Class and Description |
---|---|
class |
PortUnificationServerHandler
Manipulates the current pipeline dynamically to switch protocols or enable
SSL or GZIP.
|
Modifier and Type | Class and Description |
---|---|
class |
HexDumpProxyInboundHandler |
Modifier and Type | Class and Description |
---|---|
class |
QuoteOfTheMomentClientHandler |
class |
QuoteOfTheMomentServerHandler |
Modifier and Type | Class and Description |
---|---|
class |
SecureChatClientHandler
Handles a client-side channel.
|
class |
SecureChatServerHandler
Handles a server-side channel.
|
Modifier and Type | Class and Description |
---|---|
class |
TelnetClientHandler
Handles a client-side channel.
|
class |
TelnetServerHandler
Handles a server-side channel.
|
Modifier and Type | Class and Description |
---|---|
class |
UptimeClientHandler
Keep reconnecting to the server while printing out the current uptime and
connection attempt status.
|
Modifier and Type | Class and Description |
---|---|
class |
Base64Decoder
|
Modifier and Type | Class and Description |
---|---|
class |
ZlibDecoder
Decompresses a
ChannelBuffer using the deflate algorithm. |
Constructor and Description |
---|
DecoderEmbedder(ChannelBufferFactory bufferFactory,
ChannelUpstreamHandler... handlers)
Creates a new embedder whose pipeline is composed of the specified
handlers.
|
DecoderEmbedder(ChannelUpstreamHandler... handlers)
Creates a new embedder whose pipeline is composed of the specified
handlers.
|
Modifier and Type | Class and Description |
---|---|
class |
DelimiterBasedFrameDecoder
A decoder that splits the received
ChannelBuffer s by one or more
delimiters. |
class |
FixedLengthFrameDecoder
A decoder that splits the received
ChannelBuffer s by the fixed number
of bytes. |
class |
FrameDecoder
Decodes the received
ChannelBuffer s into a meaningful frame object. |
class |
LengthFieldBasedFrameDecoder
A decoder that splits the received
ChannelBuffer s dynamically by the
value of the length field in the message. |
class |
LineBasedFrameDecoder
A decoder that splits the received
ChannelBuffer s on line endings. |
Modifier and Type | Class and Description |
---|---|
class |
HttpChunkAggregator
A
ChannelHandler that aggregates an HttpMessage
and its following HttpChunk s into a single HttpMessage with
no following HttpChunk s. |
class |
HttpClientCodec
A combination of
HttpRequestEncoder and HttpResponseDecoder
which enables easier client side HTTP implementation. |
class |
HttpContentCompressor
Compresses an
HttpMessage and an HttpChunk in gzip or
deflate encoding while respecting the "Accept-Encoding" header. |
class |
HttpContentDecoder
Decodes the content of the received
HttpRequest and HttpChunk . |
class |
HttpContentDecompressor
|
class |
HttpContentEncoder
Encodes the content of the outbound
HttpResponse and HttpChunk . |
class |
HttpMessageDecoder
|
class |
HttpRequestDecoder
|
class |
HttpResponseDecoder
|
class |
HttpServerCodec
A combination of
HttpRequestDecoder and HttpResponseEncoder
which enables easier server side HTTP implementation. |
Modifier and Type | Class and Description |
---|---|
class |
WebSocketFrameDecoder
Deprecated.
Use org.jboss.netty.handler.codec.http.websocketx instead.
Decodes
ChannelBuffer s into WebSocketFrame s.
For the detailed instruction on adding add Web Socket support to your HTTP
server, take a look into the WebSocketServer example located in the
|
Modifier and Type | Class and Description |
---|---|
class |
WebSocket00FrameDecoder
Decodes
ChannelBuffer s into WebSocketFrame s. |
class |
WebSocket07FrameDecoder
Decodes a web socket frame from wire protocol version 7 format.
|
class |
WebSocket08FrameDecoder
Decodes a web socket frame from wire protocol version 8 format.
|
class |
WebSocket13FrameDecoder
Decodes a web socket frame from wire protocol version 13 format.
|
class |
WebSocketServerProtocolHandler
Handles WebSocket control frames (Close, Ping, Pong) and data frames (Text and Binary) are passed
to the next handler in the pipeline.
|
class |
WebSocketServerProtocolHandshakeHandler
Handles the HTTP handshake (the HTTP Upgrade request)
|
Modifier and Type | Class and Description |
---|---|
class |
OneToOneDecoder
Transforms a received message into another message.
|
Modifier and Type | Class and Description |
---|---|
class |
ProtobufDecoder
|
class |
ProtobufVarint32FrameDecoder
A decoder that splits the received
ChannelBuffer s dynamically by the
value of the Google Protocol Buffers
Base
128 Varints integer length field in the message. |
Modifier and Type | Class and Description |
---|---|
class |
ReplayingDecoder<T extends Enum<T>>
A specialized variation of
FrameDecoder which enables implementation
of a non-blocking decoder in the blocking I/O paradigm. |
Modifier and Type | Class and Description |
---|---|
class |
RtspMessageDecoder
Decodes
ChannelBuffer s into RTSP messages represented in
HttpMessage s. |
class |
RtspRequestDecoder
Decodes
ChannelBuffer s into RTSP requests represented in
HttpRequest s. |
class |
RtspResponseDecoder
Decodes
ChannelBuffer s into RTSP responses represented in
HttpResponse s. |
Modifier and Type | Class and Description |
---|---|
class |
CompatibleObjectDecoder
Deprecated.
This decoder has a known critical bug which fails to decode and
raises a random exception in some circumstances. Avoid to use
it whenever you can. The only workaround is to replace
CompatibleObjectEncoder , CompatibleObjectDecoder ,
ObjectInputStream , and ObjectOutputStream with
ObjectEncoder , ObjectDecoder ,
ObjectEncoderOutputStream , and
ObjectDecoderInputStream respectively. This workaround
requires both a client and a server to be modified. |
class |
ObjectDecoder
A decoder which deserializes the received
ChannelBuffer s into Java
objects. |
Modifier and Type | Class and Description |
---|---|
class |
SocksAuthRequestDecoder
Decodes
ChannelBuffer s into SocksAuthRequest . |
class |
SocksAuthResponseDecoder
Decodes
ChannelBuffer s into SocksAuthResponse . |
class |
SocksCmdRequestDecoder
Decodes
ChannelBuffer s into SocksCmdRequest . |
class |
SocksCmdResponseDecoder
Decodes
ChannelBuffer s into SocksCmdResponse . |
class |
SocksInitRequestDecoder
Decodes
ChannelBuffer s into SocksInitRequest . |
class |
SocksInitResponseDecoder
Decodes
ChannelBuffer s into SocksInitResponse . |
Modifier and Type | Class and Description |
---|---|
class |
SpdyFrameCodec
A combination of
SpdyFrameDecoder and SpdyFrameEncoder . |
class |
SpdyFrameDecoder
Decodes
ChannelBuffer s into SPDY Data and Control Frames. |
class |
SpdyHttpCodec
A combination of
SpdyHttpDecoder and SpdyHttpEncoder |
class |
SpdyHttpDecoder
Decodes
SpdySynStreamFrame s, SpdySynReplyFrame s,
and SpdyDataFrame s into HttpRequest s and HttpResponse s. |
class |
SpdyHttpResponseStreamIdHandler
SimpleChannelHandler that takes care of adding the right streamId to the
HttpResponse if one is not present. |
class |
SpdyOrHttpChooser
ChannelUpstreamHandler which is responsible to setup the ChannelPipeline either for
HTTP or SPDY. |
class |
SpdySessionHandler
Manages streams within a SPDY session.
|
Modifier and Type | Method and Description |
---|---|
protected abstract ChannelUpstreamHandler |
SpdyOrHttpChooser.createHttpRequestHandlerForHttp()
Create the
ChannelUpstreamHandler that is responsible for handling the HttpRequest 's
when the SpdyOrHttpChooser.SelectedProtocol was SpdyOrHttpChooser.SelectedProtocol.HttpVersion1_0 or
SpdyOrHttpChooser.SelectedProtocol.HttpVersion1_1 |
protected ChannelUpstreamHandler |
SpdyOrHttpChooser.createHttpRequestHandlerForSpdy()
Create the
ChannelUpstreamHandler that is responsible for handling the HttpRequest 's
when the SpdyOrHttpChooser.SelectedProtocol was SpdyOrHttpChooser.SelectedProtocol.SpdyVersion2 or
SpdyOrHttpChooser.SelectedProtocol.SpdyVersion3 . |
Modifier and Type | Class and Description |
---|---|
class |
StringDecoder
Decodes a received
ChannelBuffer into a String . |
Modifier and Type | Class and Description |
---|---|
class |
ExecutionHandler
Forwards an upstream
ChannelEvent to an Executor . |
Modifier and Type | Class and Description |
---|---|
class |
IpFilteringHandlerImpl
General class that handle Ip Filtering.
|
class |
IpFilterRuleHandler
Implementation of Filter of IP based on ALLOW and DENY rules.
This implementation could be changed by implementing a new IpFilterRule than default
IpV4SubnetFilterRule (IPV4 support only), IpSubnetFilterRule (IPV4 and IPV6 support)
or IpFilterRule (IP and host name string pattern support) .The check is done by going from step to step in the underlying array of IpFilterRule. Each IpFilterRule answers to the method accept if the InetAddress is accepted or not,
according to its implementation. |
class |
OneIpFilterHandler
Handler that block any new connection if there are already a currently active
channel connected with the same InetAddress (IP).
Take care to not change isBlocked method except if you know what you are doing since it is used to test if the current closed connection is to be removed or not from the map of currently connected channel. |
Modifier and Type | Class and Description |
---|---|
class |
LoggingHandler
A
ChannelHandler that logs all events via InternalLogger . |
Modifier and Type | Class and Description |
---|---|
class |
BlockingReadHandler<E>
Emulates blocking read operation.
|
class |
BufferedWriteHandler
Emulates buffered write operation.
|
Modifier and Type | Class and Description |
---|---|
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 |
IdleStateAwareChannelHandler
An extended
SimpleChannelHandler that adds the handler method for
an IdleStateEvent . |
class |
IdleStateAwareChannelUpstreamHandler
An extended
SimpleChannelUpstreamHandler that adds the handler method
for an IdleStateEvent . |
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.The general use should be as follow: Add in your pipeline a new ChannelTrafficShapingHandler, before a recommended ExecutionHandler (like
OrderedMemoryAwareThreadPoolExecutor or MemoryAwareThreadPoolExecutor ).ChannelTrafficShapingHandler myHandler = new ChannelTrafficShapingHandler(timer); timer could be created using HashedWheelTimer pipeline.addLast("CHANNEL_TRAFFIC_SHAPING", myHandler); Note that this handler has a Pipeline Coverage of "one" which means a new handler must be created for each new channel as the counter cannot be shared among all channels. For instance, if you have a ChannelPipelineFactory , you should create a new ChannelTrafficShapingHandler in this
ChannelPipelineFactory each time getPipeline() method is called.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). 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.The general use should be as follow: Create your unique GlobalTrafficShapingHandler like: GlobalTrafficShapingHandler myHandler = new GlobalTrafficShapingHandler(timer); timer could be created using HashedWheelTimer pipeline.addLast("GLOBAL_TRAFFIC_SHAPING", 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). A value of 0 means no accounting for checkInterval. |
Copyright © 2008-2014 The Netty Project. All Rights Reserved.