程序包 | 说明 |
---|---|
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.channel.socket.nio |
NIO-based socket channel
API implementation - recommended for a large number of connections (>= 1000).
|
org.jboss.netty.channel.socket.oio |
Old blocking I/O based socket channel API implementation - recommended for
a small number of connections (< 1000).
|
org.jboss.netty.example.discard | |
org.jboss.netty.example.factorial | |
org.jboss.netty.example.localtime | |
org.jboss.netty.example.objectecho | |
org.jboss.netty.example.securechat | |
org.jboss.netty.example.telnet | |
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.http |
Encoder, decoder and their related message types for HTTP.
|
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.spdy |
Encoder, decoder, session handler and their related message types for the SPDY protocol.
|
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 |
SSL ·
TLS implementation based on
SSLEngine |
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 . |
限定符和类型 | 接口和说明 |
---|---|
interface |
ChannelStateEvent
A
ChannelEvent which represents the change of the Channel
state. |
interface |
ChildChannelStateEvent
A
ChannelEvent which represents the notification of the state of
a child Channel . |
interface |
ExceptionEvent
A
ChannelEvent which represents the notification of an exception
raised by a ChannelHandler or an I/O thread. |
interface |
MessageEvent
A
ChannelEvent which represents the transmission or reception of a
message. |
interface |
WriteCompletionEvent
A
ChannelEvent which represents the notification of the completion
of a write request on a Channel . |
限定符和类型 | 类和说明 |
---|---|
class |
DefaultChildChannelStateEvent
The default
ChildChannelStateEvent implementation. |
class |
DefaultExceptionEvent
The default
ExceptionEvent implementation. |
class |
DefaultWriteCompletionEvent
The default
WriteCompletionEvent implementation. |
class |
DownstreamChannelStateEvent
The default downstream
ChannelStateEvent implementation. |
class |
DownstreamMessageEvent
The default downstream
MessageEvent implementation. |
class |
UpstreamChannelStateEvent
The default upstream
ChannelStateEvent implementation. |
class |
UpstreamMessageEvent
The default upstream
MessageEvent implementation. |
限定符和类型 | 方法和说明 |
---|---|
void |
ChannelSink.eventSunk(ChannelPipeline pipeline,
ChannelEvent e)
Invoked by
ChannelPipeline when a downstream ChannelEvent
has reached its terminal (the head of the pipeline). |
void |
ChannelSink.exceptionCaught(ChannelPipeline pipeline,
ChannelEvent e,
ChannelPipelineException cause)
Invoked by
ChannelPipeline when an exception was raised while
one of its ChannelHandler s process a ChannelEvent . |
void |
AbstractChannelSink.exceptionCaught(ChannelPipeline pipeline,
ChannelEvent event,
ChannelPipelineException cause)
Sends an
ExceptionEvent upstream with the specified
cause . |
void |
SimpleChannelHandler.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent e)
Handles the specified downstream event.
|
void |
SimpleChannelDownstreamHandler.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent e)
Handles the specified downstream event.
|
void |
ChannelDownstreamHandler.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent e)
Handles the specified downstream event.
|
void |
SimpleChannelUpstreamHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e)
Handles the specified upstream event.
|
void |
SimpleChannelHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e)
Handles the specified upstream event.
|
void |
ChannelUpstreamHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e)
Handles the specified upstream event.
|
protected boolean |
AbstractChannelSink.isFireExceptionCaughtLater(ChannelEvent event,
java.lang.Throwable actualCause)
Returns
true if and only if the specified actualCause , which was raised while
handling the specified event , must trigger an exceptionCaught() event in
an I/O thread. |
protected void |
DefaultChannelPipeline.notifyHandlerException(ChannelEvent e,
java.lang.Throwable t) |
void |
DefaultChannelPipeline.sendDownstream(ChannelEvent e) |
void |
ChannelPipeline.sendDownstream(ChannelEvent e)
Sends the specified
ChannelEvent to the last
ChannelDownstreamHandler in this pipeline. |
void |
ChannelHandlerContext.sendDownstream(ChannelEvent e)
Sends the specified
ChannelEvent to the
ChannelDownstreamHandler which is placed in the closest
downstream from the handler associated with this context. |
void |
DefaultChannelPipeline.sendUpstream(ChannelEvent e) |
void |
ChannelPipeline.sendUpstream(ChannelEvent e)
Sends the specified
ChannelEvent to the first
ChannelUpstreamHandler in this pipeline. |
void |
ChannelHandlerContext.sendUpstream(ChannelEvent e)
Sends the specified
ChannelEvent to the
ChannelUpstreamHandler which is placed in the closest upstream
from the handler associated with this context. |
限定符和类型 | 方法和说明 |
---|---|
protected boolean |
AbstractNioChannelSink.isFireExceptionCaughtLater(ChannelEvent event,
java.lang.Throwable actualCause) |
限定符和类型 | 方法和说明 |
---|---|
protected boolean |
AbstractOioChannelSink.isFireExceptionCaughtLater(ChannelEvent event,
java.lang.Throwable actualCause) |
限定符和类型 | 方法和说明 |
---|---|
void |
DiscardServerHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
DiscardClientHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
限定符和类型 | 方法和说明 |
---|---|
void |
FactorialServerHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
FactorialClientHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
限定符和类型 | 方法和说明 |
---|---|
void |
LocalTimeServerHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
LocalTimeClientHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
限定符和类型 | 方法和说明 |
---|---|
void |
ObjectEchoServerHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
ObjectEchoClientHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
限定符和类型 | 方法和说明 |
---|---|
void |
SecureChatServerHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
SecureChatClientHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
限定符和类型 | 方法和说明 |
---|---|
void |
TelnetServerHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
TelnetClientHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
限定符和类型 | 方法和说明 |
---|---|
void |
ZlibEncoder.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent evt) |
void |
JdkZlibEncoder.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent evt) |
限定符和类型 | 方法和说明 |
---|---|
void |
HttpServerCodec.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
HttpClientCodec.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
HttpServerCodec.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
HttpClientCodec.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
限定符和类型 | 方法和说明 |
---|---|
void |
OneToOneEncoder.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent evt) |
void |
OneToOneDecoder.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent evt) |
限定符和类型 | 方法和说明 |
---|---|
void |
SpdySessionHandler.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent evt) |
void |
SpdyHttpEncoder.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent evt) |
void |
SpdyHttpCodec.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
SpdyFrameCodec.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent evt) |
void |
SpdyOrHttpChooser.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
SpdyHttpCodec.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
限定符和类型 | 字段和说明 |
---|---|
protected ChannelEvent |
ChannelEventRunnable.e |
限定符和类型 | 方法和说明 |
---|---|
ChannelEvent |
ChannelEventRunnable.getEvent()
Returns the
ChannelEvent which will be sent upstream. |
限定符和类型 | 方法和说明 |
---|---|
protected java.util.concurrent.Executor |
OrderedMemoryAwareThreadPoolExecutor.getChildExecutor(ChannelEvent e) |
protected java.util.concurrent.Executor |
OrderedDownstreamThreadPoolExecutor.getChildExecutor(ChannelEvent e) |
protected java.lang.Object |
OrderedMemoryAwareThreadPoolExecutor.getChildExecutorKey(ChannelEvent e) |
protected java.lang.Object |
FairOrderedMemoryAwareThreadPoolExecutor.getKey(ChannelEvent e) |
void |
ExecutionHandler.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent e) |
protected boolean |
ExecutionHandler.handleReadSuspend(ChannelHandlerContext ctx,
ChannelEvent e)
Handle suspended reads
|
void |
ExecutionHandler.handleUpstream(ChannelHandlerContext context,
ChannelEvent e) |
构造器和说明 |
---|
ChannelDownstreamEventRunnable(ChannelHandlerContext ctx,
ChannelEvent e,
java.util.concurrent.Executor executor) |
ChannelEventRunnable(ChannelHandlerContext ctx,
ChannelEvent e,
java.util.concurrent.Executor executor)
Creates a
Runnable which sends the specified ChannelEvent
upstream via the specified ChannelHandlerContext . |
ChannelUpstreamEventRunnable(ChannelHandlerContext ctx,
ChannelEvent e,
java.util.concurrent.Executor executor)
Creates a
Runnable which sends the specified ChannelEvent
upstream via the specified ChannelHandlerContext . |
限定符和类型 | 方法和说明 |
---|---|
protected boolean |
OneIpFilterHandler.accept(ChannelHandlerContext ctx,
ChannelEvent e,
java.net.InetSocketAddress inetSocketAddress) |
protected boolean |
IpFilterRuleHandler.accept(ChannelHandlerContext ctx,
ChannelEvent e,
java.net.InetSocketAddress inetSocketAddress) |
protected abstract boolean |
IpFilteringHandlerImpl.accept(ChannelHandlerContext ctx,
ChannelEvent e,
java.net.InetSocketAddress inetSocketAddress)
Called when the channel is connected.
|
ChannelFuture |
IpFilterListener.allowed(ChannelHandlerContext ctx,
ChannelEvent e,
java.net.InetSocketAddress inetSocketAddress)
Called when the channel has the CONNECTED status and the channel was allowed by a previous call to accept().
|
boolean |
IpFilterListener.continues(ChannelHandlerContext ctx,
ChannelEvent e)
Called in handleUpstream, if this channel was previously blocked,
to check if whatever the event, it should be passed to the next entry in the pipeline.
|
protected boolean |
IpFilteringHandlerImpl.continues(ChannelHandlerContext ctx,
ChannelEvent e)
Called in handleUpstream, if this channel was previously blocked,
to check if whatever the event, it should be passed to the next entry in the pipeline.
|
protected ChannelFuture |
IpFilteringHandlerImpl.handleAllowedChannel(ChannelHandlerContext ctx,
ChannelEvent e,
java.net.InetSocketAddress inetSocketAddress) |
protected ChannelFuture |
IpFilteringHandlerImpl.handleRefusedChannel(ChannelHandlerContext ctx,
ChannelEvent e,
java.net.InetSocketAddress inetSocketAddress)
Called when the channel has the CONNECTED status and the channel was refused by a previous call to accept().
|
void |
OneIpFilterHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
IpFilteringHandlerImpl.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
ChannelFuture |
IpFilterListener.refused(ChannelHandlerContext ctx,
ChannelEvent e,
java.net.InetSocketAddress inetSocketAddress)
Called when the channel has the CONNECTED status and the channel was refused by a previous call to accept().
|
限定符和类型 | 方法和说明 |
---|---|
void |
LoggingHandler.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
LoggingHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
LoggingHandler.log(ChannelEvent e)
Logs the specified event to the
InternalLogger returned by
LoggingHandler.getLogger() . |
限定符和类型 | 方法和说明 |
---|---|
ChannelEvent |
BlockingReadHandler.readEvent()
Waits until a new
ChannelEvent is received or the associated
Channel is closed. |
ChannelEvent |
BlockingReadHandler.readEvent(long timeout,
java.util.concurrent.TimeUnit unit)
Waits until a new
ChannelEvent is received or the associated
Channel is closed. |
限定符和类型 | 方法和说明 |
---|---|
protected java.util.concurrent.BlockingQueue<ChannelEvent> |
BlockingReadHandler.getQueue()
Returns the queue which stores the received messages.
|
构造器和说明 |
---|
BlockingReadHandler(java.util.concurrent.BlockingQueue<ChannelEvent> queue)
Creates a new instance with the specified
BlockingQueue . |
限定符和类型 | 方法和说明 |
---|---|
void |
SslHandler.handleDownstream(ChannelHandlerContext context,
ChannelEvent evt) |
限定符和类型 | 方法和说明 |
---|---|
void |
ChunkedWriteHandler.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
ChunkedWriteHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
限定符和类型 | 接口和说明 |
---|---|
interface |
IdleStateEvent
A
ChannelEvent that is triggered when a Channel has been idle
for a while. |
限定符和类型 | 类和说明 |
---|---|
class |
DefaultIdleStateEvent
The default
IdleStateEvent implementation. |
限定符和类型 | 方法和说明 |
---|---|
void |
IdleStateAwareChannelUpstreamHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
IdleStateAwareChannelHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |