All Classes and Interfaces
Class
Description
A skeletal
Channel
implementation.A skeletal implementation of a buffer.
A skeletal implementation of
ChannelBufferFactory
.A skeletal
ChannelSink
implementation.A skeletal
CodecEmbedder
implementation.Abstract Disk HttpData implementation
Abstract HttpData implementation
A skeletal implementation of
InternalLogger
.Abstract Memory HttpData implementation
Abstract base class for
WorkerPool
implementations that create the Worker
's
up-front and return them in a "fair" fashion when calling AbstractNioWorkerPool.nextWorker()
Abstract base class for Oio-Worker implementations
A skeletal server-side
Channel
implementation.AbstractTrafficShapingHandler allows to limit the global bandwidth
(see
GlobalTrafficShapingHandler
) or per session
bandwidth (see ChannelTrafficShapingHandler
), as traffic shaping.Attachment of ChannelHandlerContext
For simple ChannelBuffer, returns the readableBytes, else
use standard DefaultObjectSizeEstimator.
The
ReceiveBufferSizePredictor
that automatically increases and
decreases the predicted buffer size on feed back.The
ReceiveBufferSizePredictorFactory
that creates a new
AdaptiveReceiveBufferSizePredictor
.Attribute interface
A Web Socket echo server for running the autobahn test
suite
Handles handshakes and messages
Utility class for
ChannelBuffer
that encodes and decodes to and from
Base64 notation.Enumeration of supported Base64 dialects.
Encodes a
ChannelBuffer
into a Base64-encoded ChannelBuffer
.A big-endian Java heap buffer.
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.Web Socket frame containing binary data
Emulates blocking read operation.
A
IOException
raised by BlockingReadHandler
when no data
was read within a certain period of time.A helper class which initializes a
Channel
.Serves the boss tasks like connecting/accepting
A Pool that holds
Boss
instancesGenerates a self-signed certificate using Bouncy Castle.
Emulates buffered write operation.
A NIO
ByteBuffer
based buffer.This is fork of ElasticSearch's ByteBufferAllocator.Cleaner class
A nexus to a network socket or a component which is capable of I/O
operations such as read, write, connect, and bind.
A random and sequential accessible sequence of zero or more bytes (octets).
ByteInput
implementation which reads its data from a ChannelBuffer
ByteOutput
implementation which writes the data to a ChannelBuffer
A factory that creates or pools
ChannelBuffer
s.Locates an index of data in a
ChannelBuffer
.An
InputStream
which reads data from a ChannelBuffer
.An
OutputStream
which writes data to a ChannelBuffer
.Creates a new
ChannelBuffer
by allocating new space or by wrapping
or copying existing byte arrays, byte buffers and a string.A set of configuration properties of a
Channel
.A
ChannelEventRunnable
which sends the specified ChannelEvent
downstream.ChannelEventRunnableFilter
implementation which matches ChannelDownstreamEventRunnable
Handles or intercepts a downstream
ChannelEvent
, and sends a
ChannelEvent
to the next handler in a ChannelPipeline
.An I/O event or I/O request associated with a
Channel
.A
RuntimeException
which is thrown when an I/O operation fails.The main interface to a transport that creates a
Channel
associated
with a certain communication entity such as a network socket.The result of an asynchronous
Channel
I/O operation.Listens to the result of a
ChannelFuture
.ChannelFutureListener implementation which takes another ChannelFuture and notifies it
once the operationComplete method was called.
Listens to the progress of a time-consuming I/O operation such as a large
file transfer.
The result of an asynchronous
ChannelGroup
operation.Listens to the result of a
ChannelGroupFuture
.Handles or intercepts a
ChannelEvent
, and sends a
ChannelEvent
to the next handler in a ChannelPipeline
.Indicates that the same instance of the annotated
ChannelHandler
can be added to one or more ChannelPipeline
s multiple times
without a race condition.Enables a
ChannelHandler
to interact with its ChannelPipeline
and other handlers.A
RuntimeException
which is thrown when a
LifeCycleAwareChannelHandler
throws an Exception
in its handler methods.A global variable that is local to a
Channel
.A
ChannelException
which is thrown when a ChannelPipeline
failed to process a ChannelEvent
or when a ChannelPipelineFactory
failed to initialize a ChannelPipeline
.Creates a new
ChannelPipeline
for a new Channel
.A helper class which provides various convenience methods related with
Channel
, ChannelHandler
, and ChannelPipeline
.Receives and processes the terminal downstream
ChannelEvent
s.The current or future state of a
Channel
.A
ChannelEvent
which represents the change of the Channel
state.This implementation of the
AbstractTrafficShapingHandler
is for channel
traffic shaping, that is to say a per channel limitation of the bandwidth.A
ChannelEventRunnable
which sends the specified ChannelEvent
upstream.ChannelEventRunnableFilter
which matches ChannelDownstreamEventRunnable
Handles or intercepts an upstream
ChannelEvent
, and sends a
ChannelEvent
to the next handler in a ChannelPipeline
.A utility class that provides various common operations and constants
related with
Charset
and its relevant classes.A
ChannelEvent
which represents the notification of the state of
a child Channel
.A
ChunkedInput
that fetches data from a file chunk by chunk.A data stream of indefinite length which is consumed by
ChunkedWriteHandler
.A
ChunkedInput
that fetches data from a file chunk by chunk using
NIO FileChannel
.A
ChunkedInput
that fetches data from a ReadableByteChannel
chunk by chunk.A
ChunkedInput
that fetches data from an InputStream
chunk by
chunk.A
ChannelHandler
that adds support for writing a large data stream
asynchronously neither spending a lot of memory nor getting
OutOfMemoryError
.please use
ClassResolvers
as instance factoryA helper class which creates a new client-side
Channel
and makes a
connection attempt.A RFC6265 compliant cookie decoder to be used client side.
A RFC6265 compliant cookie encoder to be used client side,
so only name=value pairs are sent.
A
ChannelFactory
which creates a client-side SocketChannel
.Web Socket Frame for closing the connection
A helper that wraps an encoder or a decoder (codec) so that they can be used
without doing actual I/O in unit tests or higher level codecs.
A
RuntimeException
which is thrown when a CodecEmbedder
failed to encode or decode the specified input.Apache Commons Logging
logger.
Logger factory which creates an
Apache Commons Logging
logger.
OneToOneEncoder
implementation which uses JBoss Marshalling to marshal
an Object.An encoder which serializes a Java object into a
ChannelBuffer
(interoperability version).A skeletal
ChannelFuture
implementation which represents a
ChannelFuture
which has been completed already.A virtual buffer which shows multiple buffers as a single merged buffer.
An
IOException
that is raised when compression or decompression
failed.An alternative identity-comparing
ConcurrentMap
which is similar to
ConcurrentHashMap
.ConcurrentReferenceHashMap list entry.
Segments are specialized versions of hash tables.
An alternative weak-key identity-comparing
ConcurrentMap
which is
similar to ConcurrentHashMap
.ConcurrentReferenceHashMap list entry.
Segments are specialized versions of hash tables.
A weak-key reference which stores the key hash needed for reclamation.
A helper class which creates a new server-side
Channel
for a
connectionless transport.ConnectException
which will be thrown if a connection could
not be established because of a connection timeout.UnmarshallerProvider
which store a reference to the Unmarshaller
in the
ChannelHandlerContext
via the ChannelHandlerContext.setAttachment(Object)
method.Web Socket continuation frame containing continuation text or binary data.
Conversion utility class to parse a property represented as a string or
an object.
Deprecated.
An interface defining an
HTTP cookie.
Parent of Client and Server side cookie decoders
Deprecated.
Use
io.netty.handler.codec.http.cookie.ClientCookieDecoder
or io.netty.handler.codec.http.cookie.ServerCookieDecoder
instead.Parent of Client and Server side cookie encoders
Encodes
Cookie
s into an HTTP header value.Deprecated.
Duplicate of package private $
io.netty.handler.codec.http.cookie.CookieUtil
An
Exception
which is thrown when the received frame data can not
be decoded by a FrameDecoder
implementation.A UDP/IP
Channel
which is created by DatagramChannelFactory
.A
ChannelConfig
for a DatagramChannel
.A
ChannelFactory
which creates a DatagramChannel
.Determines if Netty is running in a debug mode or not.
A helper that wraps a decoder so that it can be used without doing actual
I/O in unit tests or higher level codecs.
The default
SocketChannelConfig
implementation.The default
ChannelFuture
implementation.The default
ChannelGroup
implementation.The default
ChannelGroupFuture
implementation.The default
ChannelPipeline
implementation.The default
ChildChannelStateEvent
implementation.The default
Cookie
implementation.Deprecated.
Use
io.netty.handler.codec.http.cookie.DefaultCookie
instead.The default
DatagramChannelConfig
implementation.The default
ExceptionEvent
implementation.The default
HttpChunk
implementation.The default
HttpChunkTrailer
implementation.Default factory giving Attribute and FileUpload according to constructor
Attribute and FileUpload could be :
- MemoryAttribute, DiskAttribute or MixedAttribute
- MemoryFileUpload, DiskFileUpload or MixedFileUpload
according to the constructor.
- MemoryAttribute, DiskAttribute or MixedAttribute
- MemoryFileUpload, DiskFileUpload or MixedFileUpload
according to the constructor.
The default
HttpMessage
implementation.The default
HttpRequest
implementation.The default
HttpResponse
implementation.The default
IdleStateEvent
implementation.The default
LocalClientChannelFactory
implementation.The default
LocalServerChannelFactory
implementation.Default implementation of
MarshallerProvider
which just create a new Marshaller
on ever DefaultMarshallerProvider.getMarshaller(ChannelHandlerContext)
call.The default
NioSocketChannelConfig
implementation.The default
NioSocketChannelConfig
implementation.The default
ObjectSizeEstimator
implementation for general purpose.The default
ServerSocketChannelConfig
implementation.The default
ServerSocketChannelConfig
implementation.The default
SocketChannelConfig
implementation.The default
SpdyDataFrame
implementation.The default
SpdyGoAwayFrame
implementation.The default
SpdyHeadersFrame
implementation.The default
SpdyPingFrame
implementation.The default
SpdyRstStreamFrame
implementation.The default
SpdySettingsFrame
implementation.The default
SpdyStreamFrame
implementation.The default
SpdySynReplyFrame
implementation.The default
SpdySynStreamFrame
implementation.The default
SpdyWindowUpdateFrame
implementation.Default implementation of
UnmarshallerProvider
which will just create a new Unmarshaller
on every call to DefaultUnmarshallerProvider.getUnmarshaller(ChannelHandlerContext)
The default
WriteCompletionEvent
implementation.A decoder that splits the received
ChannelBuffer
s by one or more
delimiters.A set of commonly used delimiters for
DelimiterBasedFrameDecoder
.Utility that detects various properties specific to the current runtime
environment, such as Java version and the availability of the
sun.misc.Unsafe
object.A
ChannelBufferFactory
which pre-allocates a large chunk of direct
buffer and returns its slice on demand.Keeps sending random data to the specified address.
Handles a client-side channel.
Discards any incoming data.
Handles a server-side channel.
Disk implementation of Attributes
Disk FileUpload implementation that stores file into real files
The default downstream
ChannelStateEvent
implementation.The default downstream
MessageEvent
implementation.A derived buffer which simply forwards all data access requests to its
parent.
A dynamic capacity buffer which increases its capacity as needed.
Sends one message when a connection is open and echoes back any received
data to the server.
Handler implementation for the echo client.
Echoes back any received data from a client.
Handler implementation for the echo server.
TODO Make EmbeddedChannel implement ChannelConfig and ChannelSink to reduce overhead.
An immutable empty buffer implementation.
A helper that wraps an encoder so that it can be used without doing actual
I/O in unit tests or higher level codecs.
Represents an object which contains another object that needs to be taken
into account by
ObjectSizeEstimator
for more accurate object size
estimation.A
ChannelEvent
which represents the notification of an exception
raised by a ChannelHandler
or an I/O thread.Forwards an upstream
ChannelEvent
to an Executor
.Shuts down a list of
Executor
s.A common interface for a class which depends on external resources that
need explicit release or shutdown.
A utility class that provides the convenient shutdown of
ExternalResourceReleasable
s.Sends a sequence of integers to a
FactorialServer
to calculate
the factorial of the specified integer.Handler for a client-side channel.
Creates a newly configured
ChannelPipeline
for a client-side channel.Receives a sequence of integers from a
FactorialClient
to calculate
the factorial of the specified integer.Handler for a server-side channel.
Creates a newly configured
ChannelPipeline
for a server-side channel.The
CompleteChannelFuture
which is failed already.This is a fair alternative of
OrderedDownstreamThreadPoolExecutor
.This is a fair alternative of
OrderedMemoryAwareThreadPoolExecutor
.A region of a file that is sent via a
Channel
which supports
zero-copy file transfer.FileUpload interface that could be in memory, on temporary file or any other implementations.
An
TrustManagerFactory
that trusts an X.509 certificate whose SHA1 checksum matches.A decoder that splits the received
ChannelBuffer
s by the fixed number
of bytes.The
ReceiveBufferSizePredictor
that always yields the same buffer
size prediction.The
ReceiveBufferSizePredictorFactory
that returns a
FixedReceiveBufferSizePredictor
with the pre-defined configuration.Decodes the received
ChannelBuffer
s into a meaningful frame object.Version for
GlobalChannelTrafficShapingHandler
.Class to implement monitoring at fix delay.
This implementation of the
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.
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.
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.A
Timer
optimized for approximated I/O timeout scheduling.Bucket that stores HashedWheelTimeouts.
A skeletal implementation for Java heap buffers.
A
ChannelBufferFactory
which merely allocates a heap buffer with
the specified capacity.An HTTP chunk which is used for HTTP chunked transfer-encoding.
A
ChannelHandler
that aggregates an HttpMessage
and its following HttpChunk
s into a single HttpMessage
with
no following HttpChunk
s.The last
HttpChunk
which has trailing headers.A combination of
HttpRequestEncoder
and HttpResponseDecoder
which enables easier client side HTTP implementation.Compresses an
HttpMessage
and an HttpChunk
in gzip
or
deflate
encoding while respecting the "Accept-Encoding"
header.Decodes the content of the received
HttpRequest
and HttpChunk
.Encodes the content of the outbound
HttpResponse
and HttpChunk
.Extended interface for InterfaceHttpData
Interface to enable creation of InterfaceHttpData objects
This DateFormat decodes 3 formats of
Date
, but only encodes the one,
the first:
Sun, 06 Nov 1994 08:49:37 GMT: standard specification, the only one with
valid generation
Sun, 06 Nov 1994 08:49:37 GMT: obsolete specification
Sun Nov 6 08:49:37 1994: obsolete specification
First obsolete format
Second obsolete format
Provides the constants for the standard HTTP header names and values and
commonly used utility methods that accesses an
HttpMessage
.Standard HTTP header names.
Standard HTTP header values.
An HTTP server that sends back the content of the received HTTP request
in a pretty plaintext form.
An HTTP message which provides common properties for
HttpRequest
and
HttpResponse
.The internal state of
HttpMessageDecoder
.Shared Static object between HttpMessageDecoder, HttpPostRequestDecoder and HttpPostRequestEncoder
Exception when NO Backend Array is found
This class intends to decrease the CPU in seeking ahead some bytes in
HttpPostRequestDecoder
Allowed mechanism for multipart
mechanism := "7bit"
/ "8bit"
/ "binary"
Not allowed: "quoted-printable"
/ "base64"
This decoder will decode Body and can handle POST BODY in multipart form.
This decoder will decode Body and can handle POST BODY (both multipart and standard).
Exception when the body is fully decoded, even if there is still data
Exception when an error occurs while decoding
states follow
NOTSTARTED PREAMBLE (
(HEADERDELIMITER DISPOSITION (FIELD | FILEUPLOAD))*
(HEADERDELIMITER DISPOSITION MIXEDPREAMBLE
(MIXEDDELIMITER MIXEDDISPOSITION MIXEDFILEUPLOAD)+
MIXEDCLOSEDELIMITER)*
CLOSEDELIMITER)+ EPILOGUE
First status is: NOSTARTED
Content-type: multipart/form-data, boundary=AaB03x => PREAMBLE in Header
--AaB03x => HEADERDELIMITER
content-disposition: form-data; name="field1" => DISPOSITION
Joe Blow => FIELD
--AaB03x => HEADERDELIMITER
content-disposition: form-data; name="pics" => DISPOSITION
Content-type: multipart/mixed, boundary=BbC04y
--BbC04y => MIXEDDELIMITER
Content-disposition: attachment; filename="file1.txt" => MIXEDDISPOSITION
Content-Type: text/plain
...
Exception when try reading data from request in chunked format, and not enough
data are available (need more chunks)
This encoder will help to encode Request for a FORM as POST.
Different modes to use to encode form data.
Exception when an error occurs while encoding
This decoder will decode Body and can handle standard (non multipart) POST BODY.
An HTTP request.
An HTTP response.
A combination of
HttpRequestDecoder
and HttpResponseEncoder
which enables easier server side HTTP implementation.A simple HTTP client that prints out the content of the HTTP response to
System.out
to test HttpSnoopServer
.An HTTP server that sends back the content of the received HTTP request
in a pretty plaintext form.
A simple handler that serves incoming HTTP requests to send their respective
HTTP responses.
An HTTP tunneled version of the telnet client example.
Creates a client-side
SocketChannel
which connects to an
HttpTunnelingServlet
to communicate with the server application
behind the HttpTunnelingServlet
.An
HttpServlet
that proxies an incoming data to the actual server
and vice versa.The
ChannelConfig
of a client-side HTTP tunneling
SocketChannel
.An extended
SimpleChannelHandler
that adds the handler method for
an IdleStateEvent
.An extended
SimpleChannelUpstreamHandler
that adds the handler method
for an IdleStateEvent
.A
ChannelEvent
that is triggered when a Channel
has been idle
for a while.Triggers an
IdleStateEvent
when a Channel
has not performed
read, write, or both operation for a while.Executor
which executes the command in the caller thread.An insecure
TrustManagerFactory
that trusts all X.509 certificates without any verification.Interface for all Objects that could be encoded/decoded using HttpPostRequestEncoder/Decoder
This Attribute is only for Encoder use to insert special command between object if needed
(like Multipart Mixed mode)
Internal-use-only logger used by Netty.
Creates an
InternalLogger
or changes the default factory
implementation.The log level that
InternalLogger
can log at.Internet Protocol (IP) families
The Interface IpFilteringHandler.
General class that handle Ip Filtering.
The listener interface for receiving ipFilter events.
This Interface defines an Ip Filter Rule.
Implementation of Filter of IP based on ALLOW and DENY rules.
This implementation could be changed by implementing a new
The check is done by going from step to step in the underlying array of IpFilterRule.
Each
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.The Class IpFilterRuleList is a helper class to generate a List of Rules from a string.
This Interface defines an IpSet object.
This class allows to check if an IP V4 or V6 Address is contained in a subnet.
Ip V4 and Ip V6 filter rule.
Note that mix of IPV4 and IPV6 is allowed but it is not recommended.
Note that mix of IPV4 and IPV6 is allowed but it is not recommended.
This class allows to check if an IP-V4-Address is contained in a subnet.
Supported Formats for the Subnets are: 1.1.1.1/255.255.255.255 or 1.1.1.1/32 (CIDR-Notation) and (InetAddress,Mask) where Mask is a integer for CIDR-notation or a String for Standard Mask notation.
Example1:
IpV4Subnet ips = new IpV4Subnet("192.168.1.0/24");
System.out.println("Result: "+ ips.contains("192.168.1.123"));
System.out.println("Result: "+ ips.contains(inetAddress2));
Example1 bis:
IpV4Subnet ips = new IpV4Subnet(inetAddress, 24);
where inetAddress is 192.168.1.0 and inetAddress2 is 192.168.1.123
Example2:
IpV4Subnet ips = new IpV4Subnet("192.168.1.0/255.255.255.0");
System.out.println("Result: "+ ips.contains("192.168.1.123"));
System.out.println("Result: "+ ips.contains(inetAddress2));
Example2 bis:
IpV4Subnet ips = new IpV4Subnet(inetAddress, "255.255.255.0");
where inetAddress is 192.168.1.0 and inetAddress2 is 192.168.1.123
Supported Formats for the Subnets are: 1.1.1.1/255.255.255.255 or 1.1.1.1/32 (CIDR-Notation) and (InetAddress,Mask) where Mask is a integer for CIDR-notation or a String for Standard Mask notation.
Example1:
IpV4Subnet ips = new IpV4Subnet("192.168.1.0/24");
System.out.println("Result: "+ ips.contains("192.168.1.123"));
System.out.println("Result: "+ ips.contains(inetAddress2));
Example1 bis:
IpV4Subnet ips = new IpV4Subnet(inetAddress, 24);
where inetAddress is 192.168.1.0 and inetAddress2 is 192.168.1.123
Example2:
IpV4Subnet ips = new IpV4Subnet("192.168.1.0/255.255.255.0");
System.out.println("Result: "+ ips.contains("192.168.1.123"));
System.out.println("Result: "+ ips.contains(inetAddress2));
Example2 bis:
IpV4Subnet ips = new IpV4Subnet(inetAddress, "255.255.255.0");
where inetAddress is 192.168.1.0 and inetAddress2 is 192.168.1.123
IpV4 only Filter Rule
JBoss Logging
logger.
Logger factory which creates a
JBoss Logging
logger.
java.util.logging
logger.
Logger factory which creates a
java.util.logging
logger.
A client-side
SslContext
which uses JDK's SSL/TLS implementation.An
SslContext
which uses JDK's SSL/TLS implementation.A server-side
SslContext
which uses JDK's SSL/TLS implementation.Compresses a
ChannelBuffer
using the deflate algorithm.A decoder that splits the received
ChannelBuffer
s dynamically by the
value of the length field in the message.An encoder that prepends the length of the message.
A
ChannelHandler
that is notified when it is added to or removed
from a ChannelPipeline
.ByteInput
implementation which wraps another ByteInput
and throws a LimitingByteInput.TooBigObjectException
if the read limit was reached.Exception that will get thrown if the
Object
is to big to unmarshallA decoder that splits the received
ChannelBuffer
s on line endings.A little-endian Java heap buffer.
An endpoint in the local transport.
A
Channel
for the local transport.A
ChannelFactory
that creates a client-side LocalChannel
.Deploy this in JBossAS 5 or other IoC container by adding the following bean.
A
ServerChannel
for the local transport.A
ServerChannelFactory
that creates a LocalServerChannel
.Sends a list of continent/city pairs to a
LocalTimeServer
to
get the local times of the specified cities.Protobuf enum
org.jboss.netty.example.localtime.Continent
Protobuf enum
org.jboss.netty.example.localtime.DayOfWeek
Protobuf type
org.jboss.netty.example.localtime.LocalTime
Protobuf type
org.jboss.netty.example.localtime.LocalTime
Protobuf type
org.jboss.netty.example.localtime.LocalTimes
Protobuf type
org.jboss.netty.example.localtime.LocalTimes
Protobuf type
org.jboss.netty.example.localtime.Location
Protobuf type
org.jboss.netty.example.localtime.Location
Protobuf type
org.jboss.netty.example.localtime.Locations
Protobuf type
org.jboss.netty.example.localtime.Locations
Receives a list of continent/city pairs from a
LocalTimeClient
to
get the local times of the specified cities.Apache Log4J
logger.
Logger factory which creates an
Apache Log4J
logger.
A
ChannelHandler
that logs all events via InternalLogger
.This provider is responsible to get a
Marshaller
for the given ChannelHandlerContext
.Decoder which MUST be used with
MarshallingEncoder
.OneToOneEncoder
implementation which uses JBoss Marshalling to marshal
an Object.Memory implementation of Attributes
A
ThreadPoolExecutor
which blocks the task submission when there's
too many tasks in the queue.Default FileUpload implementation that stores file into memory.
Warning: be aware of the memory limitation.
Warning: be aware of the memory limitation.
A
ChannelEvent
which represents the transmission or reception of a
message.Mixed implementation using both in Memory and in File with a limit of size
Mixed implementation using both in Memory and in File with a limit of size
Helper class to load JNI resources.
An OSGi
BundleActivator
that configures logging.A bean that configures the default
InternalLoggerFactory
.A bean that configures the default
InternalLoggerFactory
.A class that holds a number of network-related constants.
Special
ChannelConfig
sub-type which offers extra methods which are useful for NIO.Boss
implementation that handles the connection attempts of clientsHolds
NioClientBoss
instances to useA
ClientSocketChannelFactory
which creates a client-side NIO-based
SocketChannel
.Provides an NIO based
DatagramChannel
.A
DatagramChannelConfig
for a NIO TCP/IP DatagramChannel
.A
DatagramChannelFactory
that creates a NIO-based connectionless
DatagramChannel
.Receives downstream events from a
ChannelPipeline
.A class responsible for registering channels with
Selector
.Default implementation which hands of
NioDatagramWorker
'sBoss implementation which handles accepting of new connections
Holds
NioServerBoss
instances to useA
ServerSocketChannelFactory
which creates a server-side NIO-based
ServerSocketChannel
.A
SocketChannelConfig
for a NIO TCP/IP SocketChannel
.Default implementation which hands of
NioWorker
'sSpecial
SSLException
which will get thrown if a packet is
received that not looks like a TLS/SSL record.Encodes a
Number
into the binary representation prepended with
a magic number ('F' or 0x46) and a 32-bit length prefix.A decoder which deserializes the received
ChannelBuffer
s into Java
objects.Modification of
EchoClient
which utilizes Java object serialization.Handler implementation for the object echo client.
Modification of
EchoServer
which utilizes Java object serialization.Handles both client-side and server-side handler depending on which
constructor was called.
An encoder which serializes a Java object into a
ChannelBuffer
.Estimates the size of an object in bytes.
A
ClientSocketChannelFactory
which creates a client-side blocking
I/O based SocketChannel
.A
DatagramChannelFactory
which creates a blocking I/O based
DatagramChannel
.A
ServerSocketChannelFactory
which creates a server-side blocking
I/O based ServerSocketChannel
.Handler that block any new connection if there are already a currently active
channel connected with the same InetAddress (IP).
Transforms a received message into another message.
Transforms a write request into another write request.
Special
OneToOneEncoder
which enforce strict ordering of encoding and writing.Generates a self-signed certificate using
sun.security.x509
package provided by OpenJDK.Tells if
netty-tcnative
and its OpenSSL support
are available.Implements a
SSLEngine
using
OpenSSL BIO abstractions.A server-side
SslContext
which uses OpenSSL's SSL/TLS implementation.Stats exposed by an OpenSSL session context.
Executor
which should be used for downstream ChannelEvent
's.A
MemoryAwareThreadPoolExecutor
which makes sure the events from the
same Channel
are executed sequentially.OSGi
LogService
logger.Logger factory which creates an OSGi
LogService
logger.The Class PatternRule represents an IP filter rule using string patterns.
Reads a PEM file and converts it into a list of DERs so that they are imported into a
KeyStore
easily.Web Socket frame containing binary data
Web Socket frame containing binary data
Serves two protocols (HTTP and Factorial) using only one port, enabling
either SSL or GZIP dynamically on demand.
Manipulates the current pipeline dynamically to switch protocols or enable
SSL or GZIP.
Exception which should get thrown if a Channel got closed before it is expected
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.An encoder that prepends the the Google Protocol Buffers
Base
128 Varints integer length field.
Helper class which convert the
InternetProtocolFamily
.Splits an HTTP query string into a path string and key-value parameter pairs.
Creates an URL-encoded URI from a path string and key-value parameter pairs.
A UDP broadcast client that asks for a quote of the moment (QOTM) to
QuoteOfTheMomentServer
.A UDP server that responds to the QOTM (quote of the moment) request to a
QuoteOfTheMomentClient
.A derived buffer which forbids any write requests to its parent.
A
TimeoutException
raised by ReadTimeoutHandler
when no data
was read within a certain period of time.Raises a
ReadTimeoutException
when no data was read within a certain
period of time.Predicts the number of readable bytes in the receive buffer of a
Channel
.Creates a new
ReceiveBufferSizePredictor
.A specialized variation of
FrameDecoder
which enables implementation
of a non-blocking decoder in the blocking I/O paradigm.Standard RTSP header names and values.
Standard RTSP header names.
Standard RTSP header values.
Decodes
ChannelBuffer
s into RTSP messages represented in
HttpMessage
s.Encodes an RTSP message represented in
HttpMessage
into
a ChannelBuffer
.The request method of RTSP.
Decodes
ChannelBuffer
s into RTSP requests represented in
HttpRequest
s.Encodes an RTSP request represented in
HttpRequest
into
a ChannelBuffer
.Decodes
ChannelBuffer
s into RTSP responses represented in
HttpResponse
s.Encodes an RTSP response represented in
HttpResponse
into
a ChannelBuffer
.The status code and its description of a RTSP response.
The version of RTSP.
Simple SSL chat client modified from
TelnetClient
.Handles a client-side channel.
Creates a newly configured
ChannelPipeline
for a new channel.Simple SSL chat server modified from
TelnetServer
.Handles a server-side channel.
Creates a newly configured
ChannelPipeline
for a new channel.Generates a temporary self-signed certificate for testing purposes.
A helper class which creates a new server-side
Channel
and accepts
incoming connections.A
ChannelFactory
that creates a ServerChannel
.A RFC6265 compliant cookie decoder to be used server side.
A RFC6265 compliant cookie encoder to be used server side,
so some fields are sent (Version is typically ignored).
A TCP/IP
ServerChannel
which accepts incoming TCP/IP connections.A
ChannelConfig
for a ServerSocketChannel
.A
ChannelFactory
which creates a ServerSocketChannel
.This implementation of a
WorkerPool
should be used if you plan to share a
WorkerPool
between different Factories.Warn when user creates too many instances to avoid
OutOfMemoryError
.A
ChannelDownstreamHandler
which provides an individual handler
method for each event type.A
ChannelHandler
which provides an individual handler method
for each event type.A
ChannelUpstreamHandler
which provides an individual handler method
for each event type.Helps to implement a custom
TrustManagerFactory
.SLF4J logger.
Logger factory which creates a SLF4J
logger.
A derived buffer which exposes its parent's sub-region only.
A TCP/IP socket
Channel
which was either accepted by
ServerSocketChannel
or created by ClientSocketChannelFactory
.A
ChannelConfig
for a SocketChannel
.An socks auth request.
Decodes
ChannelBuffer
s into SocksAuthRequest
.An socks auth response.
Decodes
ChannelBuffer
s into SocksAuthResponse
.An socks cmd request.
Decodes
ChannelBuffer
s into SocksCmdRequest
.An socks cmd response.
Decodes
ChannelBuffer
s into SocksCmdResponse
.An socks init request.
Decodes
ChannelBuffer
s into SocksInitRequest
.An socks init response.
Decodes
ChannelBuffer
s into SocksInitResponse
.An abstract class that defines a SocksMessage, providing common properties for
SocksRequest
and SocksResponse
.Encodes an
SocksMessage
into a ChannelBuffer
.An abstract class that defines a SocksRequest, providing common properties for
SocksInitRequest
, SocksAuthRequest
, SocksCmdRequest
and UnknownSocksRequest
.Type of socks request
An abstract class that defines a SocksResponse, providing common properties for
SocksInitResponse
, SocksAuthResponse
, SocksCmdResponse
and UnknownSocksResponse
.Type of socks response
A SPDY Protocol DATA Frame
A SPDY Protocol Frame
A
ChannelHandler
that encodes and decodes SPDY Frames.Decodes
ChannelBuffer
s into SPDY Frames.Callback interface for
SpdyFrameDecoder
.Encodes a SPDY Frame into a
ChannelBuffer
.A SPDY Protocol GOAWAY Frame
Provides the constants for the standard SPDY HTTP header names and commonly
used utility methods that access a
SpdyHeadersFrame
.SPDY HTTP header names
A SPDY Protocol HEADERS Frame
A combination of
SpdyHttpDecoder
and SpdyHttpEncoder
Decodes
SpdySynStreamFrame
s, SpdySynReplyFrame
s,
and SpdyDataFrame
s into HttpRequest
s and HttpResponse
s.Encodes
HttpRequest
s, HttpResponse
s, and HttpChunk
s
into SpdySynStreamFrame
s and SpdySynReplyFrame
s.Provides the constants for the header names and the utility methods
used by the
SpdyHttpDecoder
and SpdyHttpEncoder
.SPDY HTTP header names
SimpleChannelHandler
that takes care of adding the right streamId to the
HttpResponse
if one is not present.ChannelUpstreamHandler
which is responsible to setup the ChannelPipeline
either for
HTTP or SPDY.A SPDY Protocol PING Frame
A SPDY Protocol RST_STREAM Frame
Manages streams within a SPDY session.
The SPDY session status code and its description.
A SPDY Protocol SETTINGS Frame
A SPDY Protocol Frame that is associated with an individual SPDY Stream
The SPDY stream status code and its description.
A SPDY Protocol SYN_REPLY Frame
A SPDY Protocol SYN_STREAM Frame
A SPDY Protocol WINDOW_UPDATE Frame
A
ByteBuffer
pool dedicated for SslHandler
performance improvement.A secure socket protocol implementation which acts as a factory for
SSLEngine
and SslHandler
.An enumeration of SSL/TLS protocol providers.
Decodes a received
ChannelBuffer
into a String
.Encodes the requested
String
into a ChannelBuffer
.String utility class.
The
CompleteChannelFuture
which is succeeded already.FilterInputStream
which allows a user to change the underlying
stream at any time.A collection of utility methods to retrieve and parse the values of the Java system properties.
Simplistic telnet client.
Handles a client-side channel.
Creates a newly configured
ChannelPipeline
for a new channel.Simplistic telnet server.
Handles a server-side channel.
Creates a newly configured
ChannelPipeline
for a new channel.Web Socket text frame with assumed UTF-8 encoding
Insecure
SecureRandom
which relies on ThreadLocalRandom
for random number generation.UnmarshallerProvider
implementation which use a ThreadLocal
to store references
to Marshaller
instances.A random number generator isolated to the current thread.
UnmarshallerProvider
implementation which use a ThreadLocal
to store references
to Unmarshaller
instances.Overrides the thread name proposed by
ThreadRenamingRunnable
.A
Runnable
that changes the current thread name and reverts it back
when its execution ends.A
TimeoutException
when no data was either read or written within a
certain period of time.Schedules
TimerTask
s for one-time future execution in a background
thread.A task which is executed after the delay specified with
Timer.newTimeout(TimerTask, long, TimeUnit)
.An
Exception
which is thrown when the length of the frame
decoded is greater than the maximum.TrafficCounter is associated with
AbstractTrafficShapingHandler
.Class to implement monitoring at fix delay
A derived buffer which hides its parent's tail data beyond a certain index.
An unknown socks message.
An unknown socks request.
An unknown socks response.
This provider is responsible to get an
Unmarshaller
for a ChannelHandlerContext
An
Exception
which is thrown when a user calls an unsupported
operation on a ChannelBuffer
in a ReplayingDecoder
implementation.The default upstream
ChannelStateEvent
implementation.The default upstream
MessageEvent
implementation.Connects to a server periodically to measure and print the uptime of the
server.
Keep reconnecting to the server while printing out the current uptime and
connection attempt status.
Checks UTF8 bytes for validity before converting it into a string
Provides the version information of Netty.
A delegating
ExecutorService
with its own termination management.A placeholder
Enum
which could be specified as a type parameter of
ReplayingDecoder
when a user wants to manage the decoder state or
there's no state to manage.Decodes
ChannelBuffer
s into WebSocketFrame
s.Encodes a
WebSocketFrame
into a ChannelBuffer
.Decodes a web socket frame from wire protocol version 7 format.
Encodes a web socket frame into wire protocol version 7 format.
Decodes a web socket frame from wire protocol version 8 format.
Encodes a web socket frame into wire protocol version 8 format.
Decodes a web socket frame from wire protocol version 13 format.
Encodes a web socket frame into wire protocol version 13 format.
Base class for web socket client handshake implementations
Performs client side opening and closing handshakes for web socket specification version draft-ietf-hybi-thewebsocketprotocol-
00
Performs client side opening and closing handshakes for web socket specification version draft-ietf-hybi-thewebsocketprotocol-
07
Performs client side opening and closing handshakes for web socket specification version draft-ietf-hybi-thewebsocketprotocol-
10
Performs client side opening and closing handshakes for web socket specification version draft-ietf-hybi-thewebsocketprotocol-
17
Instances the appropriate handshake class to use for clients
Base class for web socket frames
Handler that aggregate fragmented WebSocketFrame's.
Type of web socket frames
Exception during handshaking process
A HTTP server which serves Web Socket requests at:
http://localhost:8080/websocket
Open your browser at http://localhost:8080/, then the demo page will be loaded and a Web Socket connection will be
made automatically.
Handles handshakes and messages
Base class for server side web socket opening and closing handshakes
Performs server side opening and closing handshakes for web socket specification version draft-ietf-hybi-thewebsocketprotocol-
00
Performs server side opening and closing handshakes for web socket specification version draft-ietf-hybi-thewebsocketprotocol-
07
Performs server side opening and closing handshakes for web socket specification version draft-ietf-hybi-thewebsocketprotocol-
10
Performs server side opening and closing handshakes for RFC 6455 (originally web
socket specification version draft-ietf-hybi-thewebsocketprotocol- 17).
Instances the appropriate handshake class to use for servers
Generates the demo HTML page which is served at http://localhost:8080/
Handles WebSocket control frames (Close, Ping, Pong) and data frames (Text and Binary) are passed
to the next handler in the pipeline.
Handles the HTTP handshake (the HTTP Upgrade request)
TODO Document me.
Versions of the web socket specification.
A
Worker
is responsible to dispatch IO operationsThe
WorkerPool
is responsible to hand of Worker
's on demandThe common interface for buffer wrappers and derived buffers.
A
ChannelEvent
which represents the notification of the completion
of a write request on a Channel
.A
TimeoutException
raised by WriteTimeoutHandler
when no data
was written within a certain period of time.Raises a
WriteTimeoutException
when no data was written within a
certain period of time.Decompresses a
ChannelBuffer
using the deflate algorithm.Compresses a
ChannelBuffer
using the deflate algorithm.Utility methods used by
ZlibEncoder
and ZlibDecoder
.The container file formats that wrap the stream compressed by the DEFLATE
algorithm.
Cookie
instead.