程序包 | 说明 |
---|---|
io.netty.channel |
The core channel API which is asynchronous and event-driven abstraction of
various transports such as a
NIO Channel.
|
io.netty.example.discard | |
io.netty.example.echo | |
io.netty.example.factorial | |
io.netty.example.file | |
io.netty.example.http.cors | |
io.netty.example.http.file | |
io.netty.example.http.helloworld | |
io.netty.example.http.snoop | |
io.netty.example.http.upload | |
io.netty.example.http.websocketx.benchmarkserver |
This package contains a benchmark application for websockets.
|
io.netty.example.http.websocketx.client | |
io.netty.example.http.websocketx.server |
This package contains an example web socket web server.
|
io.netty.example.localecho | |
io.netty.example.objectecho | |
io.netty.example.portunification | |
io.netty.example.proxy | |
io.netty.example.qotm | |
io.netty.example.rxtx | |
io.netty.example.sctp | |
io.netty.example.securechat | |
io.netty.example.socksproxy | |
io.netty.example.spdy.client |
This package contains an example SPDY HTTP client.
|
io.netty.example.spdy.server |
This package contains an example SPDY HTTP web server.
|
io.netty.example.telnet | |
io.netty.example.udt.echo.bytes |
Examples show how to use UDT Byte Streams.
|
io.netty.example.udt.echo.message |
Examples show how to use UDT Message Flows.
|
io.netty.example.udt.echo.rendezvous |
Examples show how to use UDT Message Rendezvous.
|
io.netty.example.udt.echo.rendezvousBytes |
Examples show how to use UDT Byte Streams Rendezvous.
|
io.netty.example.uptime | |
io.netty.example.worldclock | |
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.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.multipart |
HTTP multipart support.
|
io.netty.handler.codec.http.websocketx |
Encoder, decoder, handshakers and their related message types for
Web Socket data frames.
|
io.netty.handler.codec.marshalling |
Decoder and Encoder which uses JBoss Marshalling.
|
io.netty.handler.codec.protobuf |
Encoder and decoder which transform a
Google Protocol Buffers
com.google.protobuf.Message into a ByteBuf
and vice versa. |
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.socks |
Encoder, decoder and their related message types for Socks.
|
io.netty.handler.codec.spdy |
Encoder, decoder, session handler and their related message types for the SPDY protocol.
|
io.netty.handler.codec.string |
Encoder and decoder which transform a
String into a
ByteBuf and vice versa. |
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 a
io.netty.channel.ChannelEvent for debugging purpose. |
io.netty.handler.ssl |
SSL ·
TLS implementation based on
SSLEngine |
io.netty.handler.ssl.ocsp |
OCSP stapling,
formally known as the TLS Certificate Status Request extension, is an
alternative approach to the Online Certificate Status Protocol (OCSP)
for checking the revocation status of X.509 digital certificates.
|
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.
|
限定符和类型 | 方法和说明 |
---|---|
ChannelHandlerContext |
DefaultChannelPipeline.context(ChannelHandler handler) |
ChannelHandlerContext |
ChannelPipeline.context(ChannelHandler handler)
Returns the context object of the specified
ChannelHandler in
this pipeline. |
ChannelHandlerContext |
DefaultChannelPipeline.context(java.lang.Class<? extends ChannelHandler> handlerType) |
ChannelHandlerContext |
ChannelPipeline.context(java.lang.Class<? extends ChannelHandler> handlerType)
Returns the context object of the
ChannelHandler of the
specified type in this pipeline. |
ChannelHandlerContext |
DefaultChannelPipeline.context(java.lang.String name) |
ChannelHandlerContext |
ChannelPipeline.context(java.lang.String name)
Returns the context object of the
ChannelHandler with the
specified name in this pipeline. |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelActive()
A
Channel is active now, which means it is connected. |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelInactive()
A
Channel is inactive now, which means it is closed. |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelRead(java.lang.Object msg)
A
Channel received a message. |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelReadComplete()
Triggers an
ChannelInboundHandler.channelReadComplete(ChannelHandlerContext)
event to the next ChannelInboundHandler in the ChannelPipeline . |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelRegistered()
|
ChannelHandlerContext |
ChannelHandlerContext.fireChannelUnregistered()
|
ChannelHandlerContext |
ChannelHandlerContext.fireChannelWritabilityChanged()
Triggers an
ChannelInboundHandler.channelWritabilityChanged(ChannelHandlerContext)
event to the next ChannelInboundHandler in the ChannelPipeline . |
ChannelHandlerContext |
ChannelHandlerContext.fireExceptionCaught(java.lang.Throwable cause)
A
Channel received an Throwable in one of its inbound operations. |
ChannelHandlerContext |
ChannelHandlerContext.fireUserEventTriggered(java.lang.Object evt)
A
Channel received an user defined event. |
ChannelHandlerContext |
DefaultChannelPipeline.firstContext() |
ChannelHandlerContext |
ChannelPipeline.firstContext()
Returns the context of the first
ChannelHandler in this pipeline. |
ChannelHandlerContext |
ChannelHandlerContext.flush()
Request to flush all pending messages via this ChannelOutboundInvoker.
|
ChannelHandlerContext |
DefaultChannelPipeline.lastContext() |
ChannelHandlerContext |
ChannelPipeline.lastContext()
Returns the context of the last
ChannelHandler in this pipeline. |
ChannelHandlerContext |
ChannelHandlerContext.read()
Request to Read data from the
Channel into the first inbound buffer, triggers an
ChannelInboundHandler.channelRead(ChannelHandlerContext, Object) event if data was
read, and triggers a
channelReadComplete event so the
handler can decide to continue reading. |
限定符和类型 | 方法和说明 |
---|---|
void |
CombinedChannelDuplexHandler.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise)
Calls
bind(SocketAddress, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelOutboundHandler.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise)
Called once a bind operation is made.
|
void |
ChannelDuplexHandler.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise)
Calls
bind(SocketAddress, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
CombinedChannelDuplexHandler.channelActive(ChannelHandlerContext ctx) |
void |
ChannelInboundHandlerAdapter.channelActive(ChannelHandlerContext ctx)
|
void |
ChannelInboundHandler.channelActive(ChannelHandlerContext ctx)
The
Channel of the ChannelHandlerContext is now active |
void |
CombinedChannelDuplexHandler.channelInactive(ChannelHandlerContext ctx) |
void |
ChannelInboundHandlerAdapter.channelInactive(ChannelHandlerContext ctx)
|
void |
ChannelInboundHandler.channelInactive(ChannelHandlerContext ctx)
The
Channel of the ChannelHandlerContext was registered is now inactive and reached its
end of lifetime. |
void |
SimpleChannelInboundHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
CombinedChannelDuplexHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
ChannelInboundHandlerAdapter.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg)
|
void |
ChannelInboundHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg)
Invoked when the current
Channel has read a message from the peer. |
protected abstract void |
SimpleChannelInboundHandler.channelRead0(ChannelHandlerContext ctx,
I msg)
Please keep in mind that this method will be renamed to
messageReceived(ChannelHandlerContext, I) in 5.0. |
void |
CombinedChannelDuplexHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
ChannelInboundHandlerAdapter.channelReadComplete(ChannelHandlerContext ctx)
Calls
fireChannelReadComplete() to forward
to the next ChannelInboundHandler in the ChannelPipeline . |
void |
ChannelInboundHandler.channelReadComplete(ChannelHandlerContext ctx)
Invoked when the last message read by the current read operation has been consumed by
ChannelInboundHandler.channelRead(ChannelHandlerContext, Object) . |
void |
CombinedChannelDuplexHandler.channelRegistered(ChannelHandlerContext ctx) |
void |
ChannelInitializer.channelRegistered(ChannelHandlerContext ctx) |
void |
ChannelInboundHandlerAdapter.channelRegistered(ChannelHandlerContext ctx)
|
void |
ChannelInboundHandler.channelRegistered(ChannelHandlerContext ctx)
|
void |
CombinedChannelDuplexHandler.channelUnregistered(ChannelHandlerContext ctx) |
void |
ChannelInboundHandlerAdapter.channelUnregistered(ChannelHandlerContext ctx)
Calls
fireChannelUnregistered() to forward
to the next ChannelInboundHandler in the ChannelPipeline . |
void |
ChannelInboundHandler.channelUnregistered(ChannelHandlerContext ctx)
|
void |
CombinedChannelDuplexHandler.channelWritabilityChanged(ChannelHandlerContext ctx) |
void |
ChannelInboundHandlerAdapter.channelWritabilityChanged(ChannelHandlerContext ctx)
Calls
fireChannelWritabilityChanged() to forward
to the next ChannelInboundHandler in the ChannelPipeline . |
void |
ChannelInboundHandler.channelWritabilityChanged(ChannelHandlerContext ctx)
Gets called once the writable state of a
Channel changed. |
void |
CombinedChannelDuplexHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.close(ChannelHandlerContext ctx,
ChannelPromise promise)
|
void |
ChannelOutboundHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise)
Called once a close operation is made.
|
void |
ChannelDuplexHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise)
|
void |
CombinedChannelDuplexHandler.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise)
Calls
connect(SocketAddress, SocketAddress, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelOutboundHandler.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise)
Called once a connect operation is made.
|
void |
ChannelDuplexHandler.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise)
Calls
connect(SocketAddress, SocketAddress, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
CombinedChannelDuplexHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.deregister(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
deregister(ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelOutboundHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise)
Called once a deregister operation is made from the current registered
EventLoop . |
void |
ChannelDuplexHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise)
|
void |
CombinedChannelDuplexHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
disconnect(ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelOutboundHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise)
Called once a disconnect operation is made.
|
void |
ChannelDuplexHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
disconnect(ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
CombinedChannelDuplexHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
ChannelInitializer.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause)
Handle the
Throwable by logging and closing the Channel . |
void |
ChannelInboundHandlerAdapter.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause)
|
void |
ChannelInboundHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause)
Gets called if a
Throwable was thrown. |
void |
ChannelHandlerAdapter.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause)
|
void |
ChannelHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause)
已过时。
is part of
ChannelInboundHandler |
void |
CombinedChannelDuplexHandler.flush(ChannelHandlerContext ctx) |
void |
ChannelOutboundHandlerAdapter.flush(ChannelHandlerContext ctx)
|
void |
ChannelOutboundHandler.flush(ChannelHandlerContext ctx)
Called once a flush operation is made.
|
void |
ChannelDuplexHandler.flush(ChannelHandlerContext ctx)
|
void |
CombinedChannelDuplexHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
ChannelInitializer.handlerAdded(ChannelHandlerContext ctx)
Do nothing by default, sub-classes may override this method.
|
void |
ChannelHandlerAdapter.handlerAdded(ChannelHandlerContext ctx)
Do nothing by default, sub-classes may override this method.
|
void |
ChannelHandler.handlerAdded(ChannelHandlerContext ctx)
Gets called after the
ChannelHandler was added to the actual context and it's ready to handle events. |
void |
CombinedChannelDuplexHandler.handlerRemoved(ChannelHandlerContext ctx) |
void |
ChannelHandlerAdapter.handlerRemoved(ChannelHandlerContext ctx)
Do nothing by default, sub-classes may override this method.
|
void |
ChannelHandler.handlerRemoved(ChannelHandlerContext ctx)
Gets called after the
ChannelHandler was removed from the actual context and it doesn't handle events
anymore. |
void |
CombinedChannelDuplexHandler.read(ChannelHandlerContext ctx) |
void |
ChannelOutboundHandlerAdapter.read(ChannelHandlerContext ctx)
|
void |
ChannelOutboundHandler.read(ChannelHandlerContext ctx)
Intercepts
read() . |
void |
ChannelDuplexHandler.read(ChannelHandlerContext ctx)
|
void |
CombinedChannelDuplexHandler.userEventTriggered(ChannelHandlerContext ctx,
java.lang.Object evt) |
void |
ChannelInboundHandlerAdapter.userEventTriggered(ChannelHandlerContext ctx,
java.lang.Object evt)
Calls
fireUserEventTriggered(Object) to forward
to the next ChannelInboundHandler in the ChannelPipeline . |
void |
ChannelInboundHandler.userEventTriggered(ChannelHandlerContext ctx,
java.lang.Object evt)
Gets called if an user event was triggered.
|
void |
CombinedChannelDuplexHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise)
Calls
write(Object, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelOutboundHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise)
Called once a write operation is made.
|
void |
ChannelDuplexHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise)
Calls
write(Object, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
构造器和说明 |
---|
PendingWriteQueue(ChannelHandlerContext ctx) |
限定符和类型 | 方法和说明 |
---|---|
void |
DiscardClientHandler.channelActive(ChannelHandlerContext ctx) |
void |
DiscardClientHandler.channelInactive(ChannelHandlerContext ctx) |
void |
DiscardServerHandler.channelRead0(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
DiscardClientHandler.channelRead0(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
DiscardServerHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
DiscardClientHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
限定符和类型 | 方法和说明 |
---|---|
void |
EchoClientHandler.channelActive(ChannelHandlerContext ctx) |
void |
EchoServerHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
EchoClientHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
EchoServerHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
EchoClientHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
EchoServerHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
EchoClientHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
限定符和类型 | 方法和说明 |
---|---|
void |
FactorialClientHandler.channelActive(ChannelHandlerContext ctx) |
void |
FactorialServerHandler.channelInactive(ChannelHandlerContext ctx) |
void |
FactorialServerHandler.channelRead0(ChannelHandlerContext ctx,
java.math.BigInteger msg) |
void |
FactorialClientHandler.channelRead0(ChannelHandlerContext ctx,
java.math.BigInteger msg) |
protected void |
BigIntegerDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
NumberEncoder.encode(ChannelHandlerContext ctx,
java.lang.Number msg,
ByteBuf out) |
void |
FactorialServerHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
FactorialClientHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
限定符和类型 | 方法和说明 |
---|---|
void |
FileServerHandler.channelActive(ChannelHandlerContext ctx) |
void |
FileServerHandler.channelRead0(ChannelHandlerContext ctx,
java.lang.String msg) |
void |
FileServerHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
限定符和类型 | 方法和说明 |
---|---|
void |
OkResponseHandler.channelRead0(ChannelHandlerContext ctx,
java.lang.Object msg) |
限定符和类型 | 方法和说明 |
---|---|
void |
HttpStaticFileServerHandler.channelRead0(ChannelHandlerContext ctx,
FullHttpRequest request) |
void |
HttpStaticFileServerHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
限定符和类型 | 方法和说明 |
---|---|
void |
HttpHelloWorldServerHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
HttpHelloWorldServerHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
HttpHelloWorldServerHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
限定符和类型 | 方法和说明 |
---|---|
void |
HttpSnoopClientHandler.channelRead0(ChannelHandlerContext ctx,
HttpObject msg) |
protected void |
HttpSnoopServerHandler.channelRead0(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
HttpSnoopServerHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
HttpSnoopServerHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
HttpSnoopClientHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
限定符和类型 | 方法和说明 |
---|---|
void |
HttpUploadServerHandler.channelRead0(ChannelHandlerContext ctx,
HttpObject msg) |
void |
HttpUploadClientHandler.channelRead0(ChannelHandlerContext ctx,
HttpObject msg) |
void |
HttpUploadServerHandler.channelUnregistered(ChannelHandlerContext ctx) |
void |
HttpUploadServerHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
HttpUploadClientHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
限定符和类型 | 方法和说明 |
---|---|
void |
WebSocketServerHandler.channelRead0(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
WebSocketServerHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
WebSocketServerHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
限定符和类型 | 方法和说明 |
---|---|
void |
WebSocketClientHandler.channelActive(ChannelHandlerContext ctx) |
void |
WebSocketClientHandler.channelInactive(ChannelHandlerContext ctx) |
void |
WebSocketClientHandler.channelRead0(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
WebSocketClientHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
WebSocketClientHandler.handlerAdded(ChannelHandlerContext ctx) |
限定符和类型 | 方法和说明 |
---|---|
protected void |
WebSocketIndexPageHandler.channelRead0(ChannelHandlerContext ctx,
FullHttpRequest req) |
protected void |
WebSocketFrameHandler.channelRead0(ChannelHandlerContext ctx,
WebSocketFrame frame) |
void |
WebSocketIndexPageHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
限定符和类型 | 方法和说明 |
---|---|
void |
LocalEchoServerHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
LocalEchoClientHandler.channelRead0(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
LocalEchoServerHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
LocalEchoServerHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
LocalEchoClientHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
限定符和类型 | 方法和说明 |
---|---|
void |
ObjectEchoClientHandler.channelActive(ChannelHandlerContext ctx) |
void |
ObjectEchoServerHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
ObjectEchoClientHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
ObjectEchoServerHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
ObjectEchoClientHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
ObjectEchoServerHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
ObjectEchoClientHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
限定符和类型 | 方法和说明 |
---|---|
protected void |
PortUnificationServerHandler.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
限定符和类型 | 方法和说明 |
---|---|
void |
HexDumpProxyFrontendHandler.channelActive(ChannelHandlerContext ctx) |
void |
HexDumpProxyBackendHandler.channelActive(ChannelHandlerContext ctx) |
void |
HexDumpProxyFrontendHandler.channelInactive(ChannelHandlerContext ctx) |
void |
HexDumpProxyBackendHandler.channelInactive(ChannelHandlerContext ctx) |
void |
HexDumpProxyFrontendHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
HexDumpProxyBackendHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
HexDumpProxyFrontendHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
HexDumpProxyBackendHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
限定符和类型 | 方法和说明 |
---|---|
void |
QuoteOfTheMomentServerHandler.channelRead0(ChannelHandlerContext ctx,
DatagramPacket packet) |
void |
QuoteOfTheMomentClientHandler.channelRead0(ChannelHandlerContext ctx,
DatagramPacket msg) |
void |
QuoteOfTheMomentServerHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
QuoteOfTheMomentServerHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
QuoteOfTheMomentClientHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
限定符和类型 | 方法和说明 |
---|---|
void |
RxtxClientHandler.channelActive(ChannelHandlerContext ctx) |
void |
RxtxClientHandler.channelRead0(ChannelHandlerContext ctx,
java.lang.String msg) |
限定符和类型 | 方法和说明 |
---|---|
void |
SctpEchoClientHandler.channelActive(ChannelHandlerContext ctx) |
void |
SctpEchoServerHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
SctpEchoClientHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
SctpEchoServerHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
SctpEchoClientHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
SctpEchoServerHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
SctpEchoClientHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
限定符和类型 | 方法和说明 |
---|---|
void |
SecureChatServerHandler.channelActive(ChannelHandlerContext ctx) |
void |
SecureChatServerHandler.channelRead0(ChannelHandlerContext ctx,
java.lang.String msg) |
void |
SecureChatClientHandler.channelRead0(ChannelHandlerContext ctx,
java.lang.String msg) |
void |
SecureChatServerHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
SecureChatClientHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
限定符和类型 | 方法和说明 |
---|---|
void |
RelayHandler.channelActive(ChannelHandlerContext ctx) |
void |
DirectClientHandler.channelActive(ChannelHandlerContext ctx) |
void |
RelayHandler.channelInactive(ChannelHandlerContext ctx) |
void |
RelayHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
SocksServerConnectHandler.channelRead0(ChannelHandlerContext ctx,
SocksCmdRequest request) |
void |
SocksServerHandler.channelRead0(ChannelHandlerContext ctx,
SocksRequest socksRequest) |
void |
SocksServerHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
SocksServerHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable throwable) |
void |
SocksServerConnectHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
RelayHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
DirectClientHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable throwable) |
限定符和类型 | 方法和说明 |
---|---|
void |
SpdyFrameLogger.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
HttpResponseClientHandler.channelRead0(ChannelHandlerContext ctx,
HttpObject msg) |
void |
HttpResponseClientHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
SpdyFrameLogger.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
SpdyClientStreamIdHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
限定符和类型 | 方法和说明 |
---|---|
void |
SpdyServerHandler.channelRead0(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
SpdyServerHandler.channelReadComplete(ChannelHandlerContext ctx) |
protected void |
SpdyOrHttpHandler.configurePipeline(ChannelHandlerContext ctx,
java.lang.String protocol) |
void |
SpdyServerHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
限定符和类型 | 方法和说明 |
---|---|
void |
TelnetServerHandler.channelActive(ChannelHandlerContext ctx) |
void |
TelnetServerHandler.channelRead0(ChannelHandlerContext ctx,
java.lang.String request) |
protected void |
TelnetClientHandler.channelRead0(ChannelHandlerContext ctx,
java.lang.String msg) |
void |
TelnetServerHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
TelnetServerHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
TelnetClientHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
限定符和类型 | 方法和说明 |
---|---|
void |
ByteEchoServerHandler.channelActive(ChannelHandlerContext ctx) |
void |
ByteEchoClientHandler.channelActive(ChannelHandlerContext ctx) |
void |
ByteEchoServerHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
ByteEchoClientHandler.channelRead0(ChannelHandlerContext ctx,
ByteBuf msg) |
void |
ByteEchoServerHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
ByteEchoClientHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
ByteEchoServerHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
ByteEchoClientHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
限定符和类型 | 方法和说明 |
---|---|
void |
MsgEchoServerHandler.channelActive(ChannelHandlerContext ctx) |
void |
MsgEchoClientHandler.channelActive(ChannelHandlerContext ctx) |
void |
MsgEchoServerHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
MsgEchoClientHandler.channelRead0(ChannelHandlerContext ctx,
UdtMessage msg) |
void |
MsgEchoServerHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
MsgEchoClientHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
MsgEchoServerHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
MsgEchoClientHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
限定符和类型 | 方法和说明 |
---|---|
void |
MsgEchoPeerHandler.channelActive(ChannelHandlerContext ctx) |
void |
MsgEchoPeerHandler.channelRead0(ChannelHandlerContext ctx,
UdtMessage message) |
void |
MsgEchoPeerHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
MsgEchoPeerHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
限定符和类型 | 方法和说明 |
---|---|
void |
ByteEchoPeerHandler.channelActive(ChannelHandlerContext ctx) |
void |
ByteEchoPeerHandler.channelRead0(ChannelHandlerContext ctx,
ByteBuf buf) |
void |
ByteEchoPeerHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
ByteEchoPeerHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
限定符和类型 | 方法和说明 |
---|---|
void |
UptimeClientHandler.channelActive(ChannelHandlerContext ctx) |
void |
UptimeClientHandler.channelInactive(ChannelHandlerContext ctx) |
void |
UptimeServerHandler.channelRead0(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
UptimeClientHandler.channelRead0(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
UptimeClientHandler.channelUnregistered(ChannelHandlerContext ctx) |
void |
UptimeServerHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
UptimeClientHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
UptimeClientHandler.userEventTriggered(ChannelHandlerContext ctx,
java.lang.Object evt) |
限定符和类型 | 方法和说明 |
---|---|
void |
WorldClockClientHandler.channelRead0(ChannelHandlerContext ctx,
WorldClockProtocol.LocalTimes times) |
void |
WorldClockServerHandler.channelRead0(ChannelHandlerContext ctx,
WorldClockProtocol.Locations locations) |
void |
WorldClockServerHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
WorldClockClientHandler.channelRegistered(ChannelHandlerContext ctx) |
void |
WorldClockServerHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
WorldClockClientHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
限定符和类型 | 方法和说明 |
---|---|
protected ByteBuf |
LengthFieldPrepender.allocateBuffer(ChannelHandlerContext ctx,
ByteBuf msg,
boolean preferDirect) |
protected ByteBuf |
MessageToByteEncoder.allocateBuffer(ChannelHandlerContext ctx,
I msg,
boolean preferDirect)
Allocate a
ByteBuf which will be used as argument of #encode(ChannelHandlerContext, I, ByteBuf) . |
protected void |
ReplayingDecoder.callDecode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
ByteToMessageDecoder.callDecode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out)
Called once data should be decoded from the given
ByteBuf . |
void |
ByteToMessageDecoder.channelInactive(ChannelHandlerContext ctx) |
void |
ByteToMessageCodec.channelInactive(ChannelHandlerContext ctx) |
void |
MessageToMessageDecoder.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
MessageToMessageCodec.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
ByteToMessageDecoder.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
ByteToMessageCodec.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
ByteToMessageDecoder.channelReadComplete(ChannelHandlerContext ctx) |
void |
ByteToMessageCodec.channelReadComplete(ChannelHandlerContext ctx) |
protected java.lang.Object |
LineBasedFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf buffer)
Create a frame out of the
ByteBuf and return it. |
protected java.lang.Object |
LengthFieldBasedFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in)
Create a frame out of the
ByteBuf and return it. |
protected java.lang.Object |
FixedLengthFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in)
Create a frame out of the
ByteBuf and return it. |
protected java.lang.Object |
DelimiterBasedFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf buffer)
Create a frame out of the
ByteBuf and return it. |
protected void |
LineBasedFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
LengthFieldBasedFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
FixedLengthFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
DelimiterBasedFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected abstract void |
ByteToMessageDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out)
Decode the from one
ByteBuf to an other. |
protected abstract void |
ByteToMessageCodec.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected abstract void |
MessageToMessageDecoder.decode(ChannelHandlerContext ctx,
I msg,
java.util.List<java.lang.Object> out)
Decode from one message to an other.
|
protected abstract void |
MessageToMessageCodec.decode(ChannelHandlerContext ctx,
INBOUND_IN msg,
java.util.List<java.lang.Object> out) |
protected void |
ByteToMessageDecoder.decodeLast(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out)
Is called one last time when the
ChannelHandlerContext goes in-active. |
protected void |
ByteToMessageCodec.decodeLast(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
LengthFieldPrepender.encode(ChannelHandlerContext ctx,
ByteBuf msg,
ByteBuf out) |
protected abstract void |
MessageToByteEncoder.encode(ChannelHandlerContext ctx,
I msg,
ByteBuf out)
Encode a message into a
ByteBuf . |
protected abstract void |
ByteToMessageCodec.encode(ChannelHandlerContext ctx,
I msg,
ByteBuf out) |
protected abstract void |
MessageToMessageEncoder.encode(ChannelHandlerContext ctx,
I msg,
java.util.List<java.lang.Object> out)
Encode from one message to an other.
|
protected abstract void |
MessageToMessageCodec.encode(ChannelHandlerContext ctx,
OUTBOUND_IN msg,
java.util.List<java.lang.Object> out) |
protected ByteBuf |
LengthFieldBasedFrameDecoder.extractFrame(ChannelHandlerContext ctx,
ByteBuf buffer,
int index,
int length)
Extract the sub-region of the specified buffer.
|
void |
ByteToMessageCodec.handlerAdded(ChannelHandlerContext ctx) |
void |
ByteToMessageDecoder.handlerRemoved(ChannelHandlerContext ctx) |
void |
ByteToMessageCodec.handlerRemoved(ChannelHandlerContext ctx) |
protected void |
ByteToMessageDecoder.handlerRemoved0(ChannelHandlerContext ctx)
Gets called after the
ByteToMessageDecoder was removed from the actual context and it doesn't handle
events anymore. |
void |
ByteToMessageDecoder.userEventTriggered(ChannelHandlerContext ctx,
java.lang.Object evt) |
void |
MessageToMessageEncoder.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
MessageToMessageCodec.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
MessageToByteEncoder.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
ByteToMessageCodec.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
限定符和类型 | 方法和说明 |
---|---|
protected void |
Base64Decoder.decode(ChannelHandlerContext ctx,
ByteBuf msg,
java.util.List<java.lang.Object> out) |
protected void |
Base64Encoder.encode(ChannelHandlerContext ctx,
ByteBuf msg,
java.util.List<java.lang.Object> out) |
限定符和类型 | 方法和说明 |
---|---|
protected void |
ByteArrayDecoder.decode(ChannelHandlerContext ctx,
ByteBuf msg,
java.util.List<java.lang.Object> out) |
protected void |
ByteArrayEncoder.encode(ChannelHandlerContext ctx,
byte[] msg,
java.util.List<java.lang.Object> out) |
限定符和类型 | 方法和说明 |
---|---|
protected ByteBuf |
JdkZlibEncoder.allocateBuffer(ChannelHandlerContext ctx,
ByteBuf msg,
boolean preferDirect) |
void |
JZlibEncoder.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
JdkZlibEncoder.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
protected void |
SnappyFramedDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
JZlibDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
JdkZlibDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
SnappyFramedEncoder.encode(ChannelHandlerContext ctx,
ByteBuf in,
ByteBuf out) |
protected void |
JZlibEncoder.encode(ChannelHandlerContext ctx,
ByteBuf in,
ByteBuf out) |
protected void |
JdkZlibEncoder.encode(ChannelHandlerContext ctx,
ByteBuf uncompressed,
ByteBuf out) |
void |
JZlibEncoder.handlerAdded(ChannelHandlerContext ctx) |
void |
JdkZlibEncoder.handlerAdded(ChannelHandlerContext ctx) |
protected void |
JdkZlibDecoder.handlerRemoved0(ChannelHandlerContext ctx) |
限定符和类型 | 方法和说明 |
---|---|
void |
HAProxyMessageDecoder.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
protected void |
HAProxyMessageDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
限定符和类型 | 字段和说明 |
---|---|
protected ChannelHandlerContext |
HttpContentDecoder.ctx |
限定符和类型 | 方法和说明 |
---|---|
void |
HttpObjectAggregator.channelInactive(ChannelHandlerContext ctx) |
void |
HttpContentEncoder.channelInactive(ChannelHandlerContext ctx) |
void |
HttpContentDecoder.channelInactive(ChannelHandlerContext ctx) |
void |
HttpServerKeepAliveHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
protected void |
HttpObjectDecoder.decode(ChannelHandlerContext ctx,
ByteBuf buffer,
java.util.List<java.lang.Object> out) |
protected void |
HttpObjectAggregator.decode(ChannelHandlerContext ctx,
HttpObject msg,
java.util.List<java.lang.Object> out) |
protected void |
HttpContentDecoder.decode(ChannelHandlerContext ctx,
HttpObject msg,
java.util.List<java.lang.Object> out) |
protected void |
HttpContentEncoder.decode(ChannelHandlerContext ctx,
HttpRequest msg,
java.util.List<java.lang.Object> out) |
protected void |
HttpObjectDecoder.decodeLast(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
HttpContentEncoder.encode(ChannelHandlerContext ctx,
HttpObject msg,
java.util.List<java.lang.Object> out) |
protected void |
HttpObjectEncoder.encode(ChannelHandlerContext ctx,
java.lang.Object msg,
java.util.List<java.lang.Object> out) |
void |
HttpObjectAggregator.handlerAdded(ChannelHandlerContext ctx) |
void |
HttpContentDecoder.handlerAdded(ChannelHandlerContext ctx) |
void |
HttpContentCompressor.handlerAdded(ChannelHandlerContext ctx) |
void |
HttpObjectAggregator.handlerRemoved(ChannelHandlerContext ctx) |
void |
HttpContentEncoder.handlerRemoved(ChannelHandlerContext ctx) |
void |
HttpContentDecoder.handlerRemoved(ChannelHandlerContext ctx) |
HttpContent |
HttpChunkedInput.readChunk(ChannelHandlerContext ctx) |
void |
HttpObjectDecoder.userEventTriggered(ChannelHandlerContext ctx,
java.lang.Object evt) |
void |
HttpServerKeepAliveHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
限定符和类型 | 方法和说明 |
---|---|
void |
CorsHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
CorsHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
CorsHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
限定符和类型 | 方法和说明 |
---|---|
HttpContent |
HttpPostRequestEncoder.readChunk(ChannelHandlerContext ctx)
Returns the next available HttpChunk.
|
限定符和类型 | 方法和说明 |
---|---|
void |
WebSocketFrameAggregator.channelInactive(ChannelHandlerContext ctx) |
void |
WebSocket08FrameDecoder.channelInactive(ChannelHandlerContext ctx) |
protected void |
WebSocket08FrameDecoder.checkCloseFrameBody(ChannelHandlerContext ctx,
ByteBuf buffer) |
protected void |
WebSocket08FrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
WebSocket00FrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
WebSocketServerProtocolHandler.decode(ChannelHandlerContext ctx,
WebSocketFrame frame,
java.util.List<java.lang.Object> out) |
protected void |
WebSocketFrameAggregator.decode(ChannelHandlerContext ctx,
WebSocketFrame msg,
java.util.List<java.lang.Object> out) |
protected void |
WebSocketClientProtocolHandler.decode(ChannelHandlerContext ctx,
WebSocketFrame frame,
java.util.List<java.lang.Object> out) |
protected void |
WebSocket08FrameEncoder.encode(ChannelHandlerContext ctx,
WebSocketFrame msg,
java.util.List<java.lang.Object> out) |
protected void |
WebSocket00FrameEncoder.encode(ChannelHandlerContext ctx,
WebSocketFrame msg,
java.util.List<java.lang.Object> out) |
void |
WebSocketServerProtocolHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
WebSocketServerProtocolHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
WebSocketClientProtocolHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
WebSocketFrameAggregator.handlerRemoved(ChannelHandlerContext ctx) |
WebSocketFrame |
WebSocketChunkedInput.readChunk(ChannelHandlerContext ctx)
Fetches a chunked data from the stream.
|
限定符和类型 | 方法和说明 |
---|---|
protected java.lang.Object |
MarshallingDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in) |
protected void |
CompatibleMarshallingDecoder.decode(ChannelHandlerContext ctx,
ByteBuf buffer,
java.util.List<java.lang.Object> out) |
protected void |
CompatibleMarshallingDecoder.decodeLast(ChannelHandlerContext ctx,
ByteBuf buffer,
java.util.List<java.lang.Object> out) |
protected void |
MarshallingEncoder.encode(ChannelHandlerContext ctx,
java.lang.Object msg,
ByteBuf out) |
protected void |
CompatibleMarshallingEncoder.encode(ChannelHandlerContext ctx,
java.lang.Object msg,
ByteBuf out) |
void |
CompatibleMarshallingDecoder.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
protected ByteBuf |
MarshallingDecoder.extractFrame(ChannelHandlerContext ctx,
ByteBuf buffer,
int index,
int length) |
Marshaller |
ThreadLocalMarshallerProvider.getMarshaller(ChannelHandlerContext ctx) |
Marshaller |
MarshallerProvider.getMarshaller(ChannelHandlerContext ctx)
Get a
Marshaller for the given ChannelHandlerContext |
Marshaller |
DefaultMarshallerProvider.getMarshaller(ChannelHandlerContext ctx) |
Unmarshaller |
UnmarshallerProvider.getUnmarshaller(ChannelHandlerContext ctx)
Get the
Unmarshaller for the given ChannelHandlerContext |
Unmarshaller |
ThreadLocalUnmarshallerProvider.getUnmarshaller(ChannelHandlerContext ctx) |
Unmarshaller |
DefaultUnmarshallerProvider.getUnmarshaller(ChannelHandlerContext ctx) |
Unmarshaller |
ContextBoundUnmarshallerProvider.getUnmarshaller(ChannelHandlerContext ctx) |
限定符和类型 | 方法和说明 |
---|---|
protected void |
ProtobufVarint32FrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
ProtobufDecoder.decode(ChannelHandlerContext ctx,
ByteBuf msg,
java.util.List<java.lang.Object> out) |
protected void |
ProtobufVarint32LengthFieldPrepender.encode(ChannelHandlerContext ctx,
ByteBuf msg,
ByteBuf out) |
protected void |
ProtobufEncoder.encode(ChannelHandlerContext ctx,
MessageLiteOrBuilder msg,
java.util.List<java.lang.Object> out) |
限定符和类型 | 方法和说明 |
---|---|
protected void |
SctpMessageCompletionHandler.decode(ChannelHandlerContext ctx,
SctpMessage msg,
java.util.List<java.lang.Object> out) |
protected void |
SctpInboundByteStreamHandler.decode(ChannelHandlerContext ctx,
SctpMessage msg,
java.util.List<java.lang.Object> out) |
protected void |
SctpOutboundByteStreamHandler.encode(ChannelHandlerContext ctx,
ByteBuf msg,
java.util.List<java.lang.Object> out) |
限定符和类型 | 方法和说明 |
---|---|
protected java.lang.Object |
ObjectDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in) |
protected void |
ObjectEncoder.encode(ChannelHandlerContext ctx,
java.io.Serializable msg,
ByteBuf out) |
protected void |
CompatibleObjectEncoder.encode(ChannelHandlerContext ctx,
java.io.Serializable msg,
ByteBuf out) |
限定符和类型 | 方法和说明 |
---|---|
protected void |
SocksInitResponseDecoder.decode(ChannelHandlerContext ctx,
ByteBuf byteBuf,
java.util.List<java.lang.Object> out) |
protected void |
SocksInitRequestDecoder.decode(ChannelHandlerContext ctx,
ByteBuf byteBuf,
java.util.List<java.lang.Object> out) |
protected void |
SocksCmdResponseDecoder.decode(ChannelHandlerContext ctx,
ByteBuf byteBuf,
java.util.List<java.lang.Object> out) |
protected void |
SocksCmdRequestDecoder.decode(ChannelHandlerContext ctx,
ByteBuf byteBuf,
java.util.List<java.lang.Object> out) |
protected void |
SocksAuthResponseDecoder.decode(ChannelHandlerContext channelHandlerContext,
ByteBuf byteBuf,
java.util.List<java.lang.Object> out) |
protected void |
SocksAuthRequestDecoder.decode(ChannelHandlerContext ctx,
ByteBuf byteBuf,
java.util.List<java.lang.Object> out) |
protected void |
SocksMessageEncoder.encode(ChannelHandlerContext ctx,
SocksMessage msg,
ByteBuf out) |
限定符和类型 | 方法和说明 |
---|---|
void |
SpdyFrameCodec.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
SpdySessionHandler.channelInactive(ChannelHandlerContext ctx) |
void |
SpdySessionHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
SpdyFrameCodec.channelReadComplete(ChannelHandlerContext ctx) |
void |
SpdySessionHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
SpdyFrameCodec.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
protected abstract void |
SpdyOrHttpChooser.configureHttp1(ChannelHandlerContext ctx)
已过时。
Configures the
Channel of the specified ctx for HTTP/1. |
protected abstract void |
SpdyOrHttpChooser.configureSpdy(ChannelHandlerContext ctx,
SpdyVersion version)
已过时。
Configures the
Channel of the specified ctx for HTTP/2. |
void |
SpdyFrameCodec.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
protected void |
SpdyOrHttpChooser.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out)
已过时。
|
protected void |
SpdyFrameCodec.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
SpdyHttpResponseStreamIdHandler.decode(ChannelHandlerContext ctx,
java.lang.Object msg,
java.util.List<java.lang.Object> out) |
protected void |
SpdyHttpDecoder.decode(ChannelHandlerContext ctx,
SpdyFrame msg,
java.util.List<java.lang.Object> out) |
void |
SpdyFrameCodec.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
SpdyFrameCodec.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
protected void |
SpdyHttpResponseStreamIdHandler.encode(ChannelHandlerContext ctx,
HttpMessage msg,
java.util.List<java.lang.Object> out) |
protected void |
SpdyHttpEncoder.encode(ChannelHandlerContext ctx,
HttpObject msg,
java.util.List<java.lang.Object> out) |
void |
SpdySessionHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
SpdyOrHttpChooser.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause)
已过时。
|
void |
SpdyFrameCodec.flush(ChannelHandlerContext ctx) |
void |
SpdyFrameCodec.handlerAdded(ChannelHandlerContext ctx) |
void |
SpdyFrameCodec.read(ChannelHandlerContext ctx) |
void |
SpdySessionHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
SpdyFrameCodec.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
限定符和类型 | 方法和说明 |
---|---|
protected void |
StringDecoder.decode(ChannelHandlerContext ctx,
ByteBuf msg,
java.util.List<java.lang.Object> out) |
protected void |
StringEncoder.encode(ChannelHandlerContext ctx,
java.lang.CharSequence msg,
java.util.List<java.lang.Object> out) |
限定符和类型 | 方法和说明 |
---|---|
void |
FlushConsolidationHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
FlushConsolidationHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
FlushConsolidationHandler.channelWritabilityChanged(ChannelHandlerContext ctx) |
void |
FlushConsolidationHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
FlushConsolidationHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
FlushConsolidationHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
FlushConsolidationHandler.flush(ChannelHandlerContext ctx) |
void |
FlushConsolidationHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
FlushConsolidationHandler.handlerRemoved(ChannelHandlerContext ctx) |
限定符和类型 | 方法和说明 |
---|---|
protected boolean |
UniqueIpFilter.accept(ChannelHandlerContext ctx,
java.net.InetSocketAddress remoteAddress) |
protected boolean |
RuleBasedIpFilter.accept(ChannelHandlerContext ctx,
java.net.InetSocketAddress remoteAddress) |
protected abstract boolean |
AbstractRemoteAddressFilter.accept(ChannelHandlerContext ctx,
T remoteAddress)
This method is called immediately after a
Channel gets registered. |
protected void |
AbstractRemoteAddressFilter.channelAccepted(ChannelHandlerContext ctx,
T remoteAddress)
This method is called if
remoteAddress gets accepted by
AbstractRemoteAddressFilter.accept(ChannelHandlerContext, SocketAddress) . |
void |
AbstractRemoteAddressFilter.channelActive(ChannelHandlerContext ctx) |
void |
AbstractRemoteAddressFilter.channelRegistered(ChannelHandlerContext ctx) |
protected ChannelFuture |
AbstractRemoteAddressFilter.channelRejected(ChannelHandlerContext ctx,
T remoteAddress)
This method is called if
remoteAddress gets rejected by
AbstractRemoteAddressFilter.accept(ChannelHandlerContext, SocketAddress) . |
限定符和类型 | 方法和说明 |
---|---|
void |
LoggingHandler.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
LoggingHandler.channelActive(ChannelHandlerContext ctx) |
void |
LoggingHandler.channelInactive(ChannelHandlerContext ctx) |
void |
LoggingHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
LoggingHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
LoggingHandler.channelRegistered(ChannelHandlerContext ctx) |
void |
LoggingHandler.channelUnregistered(ChannelHandlerContext ctx) |
void |
LoggingHandler.channelWritabilityChanged(ChannelHandlerContext ctx) |
void |
LoggingHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
LoggingHandler.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
LoggingHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
LoggingHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
LoggingHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
LoggingHandler.flush(ChannelHandlerContext ctx) |
protected java.lang.String |
LoggingHandler.format(ChannelHandlerContext ctx,
java.lang.String message) |
void |
LoggingHandler.userEventTriggered(ChannelHandlerContext ctx,
java.lang.Object evt) |
void |
LoggingHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
限定符和类型 | 方法和说明 |
---|---|
void |
SslHandler.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
SslHandler.channelActive(ChannelHandlerContext ctx)
Issues an initial TLS handshake once connected when used in client-mode
|
void |
SslHandler.channelInactive(ChannelHandlerContext ctx) |
void |
SslHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
SslHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
protected abstract void |
ApplicationProtocolNegotiationHandler.configurePipeline(ChannelHandlerContext ctx,
java.lang.String protocol)
Invoked on successful initial SSL/TLS handshake.
|
void |
SslHandler.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
protected void |
SslHandler.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
SniHandler.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
OptionalSslHandler.decode(ChannelHandlerContext context,
ByteBuf in,
java.util.List<java.lang.Object> out) |
void |
SslHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
SslHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
SslHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
ApplicationProtocolNegotiationHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
SslHandler.flush(ChannelHandlerContext ctx) |
void |
SslHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
SslHandler.handlerRemoved0(ChannelHandlerContext ctx) |
protected void |
ApplicationProtocolNegotiationHandler.handshakeFailure(ChannelHandlerContext ctx,
java.lang.Throwable cause)
Invoked on failed initial SSL/TLS handshake.
|
protected ChannelHandler |
OptionalSslHandler.newNonSslHandler(ChannelHandlerContext context)
Override to configure the ChannelHandler.
|
protected SslHandler |
OptionalSslHandler.newSslHandler(ChannelHandlerContext context,
SslContext sslContext)
Override to configure the SslHandler eg.
|
void |
SslHandler.read(ChannelHandlerContext ctx) |
void |
ApplicationProtocolNegotiationHandler.userEventTriggered(ChannelHandlerContext ctx,
java.lang.Object evt) |
void |
SslHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
限定符和类型 | 方法和说明 |
---|---|
void |
OcspClientHandler.userEventTriggered(ChannelHandlerContext ctx,
java.lang.Object evt) |
protected abstract boolean |
OcspClientHandler.verify(ChannelHandlerContext ctx,
ReferenceCountedOpenSslEngine engine) |
限定符和类型 | 方法和说明 |
---|---|
void |
ChunkedWriteHandler.channelInactive(ChannelHandlerContext ctx) |
void |
ChunkedWriteHandler.channelWritabilityChanged(ChannelHandlerContext ctx) |
void |
ChunkedWriteHandler.flush(ChannelHandlerContext ctx) |
void |
ChunkedWriteHandler.handlerAdded(ChannelHandlerContext ctx) |
ByteBuf |
ChunkedStream.readChunk(ChannelHandlerContext ctx) |
ByteBuf |
ChunkedNioStream.readChunk(ChannelHandlerContext ctx) |
ByteBuf |
ChunkedNioFile.readChunk(ChannelHandlerContext ctx) |
B |
ChunkedInput.readChunk(ChannelHandlerContext ctx)
Fetches a chunked data from the stream.
|
ByteBuf |
ChunkedFile.readChunk(ChannelHandlerContext ctx) |
void |
ChunkedWriteHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
限定符和类型 | 方法和说明 |
---|---|
void |
IdleStateHandler.channelActive(ChannelHandlerContext ctx) |
protected void |
ReadTimeoutHandler.channelIdle(ChannelHandlerContext ctx,
IdleStateEvent evt) |
protected void |
IdleStateHandler.channelIdle(ChannelHandlerContext ctx,
IdleStateEvent evt)
Is called when an
IdleStateEvent should be fired. |
void |
IdleStateHandler.channelInactive(ChannelHandlerContext ctx) |
void |
IdleStateHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
IdleStateHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
IdleStateHandler.channelRegistered(ChannelHandlerContext ctx) |
void |
IdleStateHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
WriteTimeoutHandler.handlerRemoved(ChannelHandlerContext ctx) |
void |
IdleStateHandler.handlerRemoved(ChannelHandlerContext ctx) |
protected void |
ReadTimeoutHandler.readTimedOut(ChannelHandlerContext ctx)
Is called when a read timeout was detected.
|
void |
WriteTimeoutHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
IdleStateHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
protected void |
WriteTimeoutHandler.writeTimedOut(ChannelHandlerContext ctx)
Is called when a write timeout was detected
|
限定符和类型 | 方法和说明 |
---|---|
void |
GlobalChannelTrafficShapingHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
AbstractTrafficShapingHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
AbstractTrafficShapingHandler.channelRegistered(ChannelHandlerContext ctx) |
protected long |
GlobalChannelTrafficShapingHandler.checkWaitReadTime(ChannelHandlerContext ctx,
long wait,
long now) |
void |
GlobalTrafficShapingHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
GlobalChannelTrafficShapingHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
ChannelTrafficShapingHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
GlobalTrafficShapingHandler.handlerRemoved(ChannelHandlerContext ctx) |
void |
GlobalChannelTrafficShapingHandler.handlerRemoved(ChannelHandlerContext ctx) |
void |
ChannelTrafficShapingHandler.handlerRemoved(ChannelHandlerContext ctx) |
protected void |
GlobalChannelTrafficShapingHandler.informReadOperation(ChannelHandlerContext ctx,
long now) |
protected static boolean |
AbstractTrafficShapingHandler.isHandlerActive(ChannelHandlerContext ctx) |
void |
AbstractTrafficShapingHandler.read(ChannelHandlerContext ctx) |
protected void |
AbstractTrafficShapingHandler.submitWrite(ChannelHandlerContext ctx,
java.lang.Object msg,
long delay,
ChannelPromise promise)
已过时。
|
protected void |
GlobalChannelTrafficShapingHandler.submitWrite(ChannelHandlerContext ctx,
java.lang.Object msg,
long size,
long writedelay,
long now,
ChannelPromise promise) |
void |
GlobalChannelTrafficShapingHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
AbstractTrafficShapingHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |