程序包 | 说明 |
---|---|
io.netty.bootstrap |
The helper classes with fluent API which enable an easy implementation of
typical client side and server side channel initialization.
|
io.netty.channel |
The core channel API which is asynchronous and event-driven abstraction of
various transports such as a
NIO Channel.
|
io.netty.channel.embedded |
A virtual
Channel that helps wrapping a series of handlers to
unit test the handlers or use them in non-I/O context. |
io.netty.channel.epoll |
Optimized transport for linux which uses EPOLL Edge-Triggered Mode
for maximal performance.
|
io.netty.channel.group |
A channel registry which helps a user maintain the list of open
Channel s and perform bulk operations on them. |
io.netty.channel.local |
A virtual transport that enables the communication between the two
parties in the same virtual machine.
|
io.netty.channel.nio |
NIO-based channel
API implementation - recommended for a large number of connections (>= 1000).
|
io.netty.channel.oio |
Old blocking I/O based channel API implementation - recommended for
a small number of connections (< 1000).
|
io.netty.channel.pool |
Implementations and API for
Channel pools. |
io.netty.channel.rxtx |
A serial and parallel port communication transport based on RXTX.
|
io.netty.channel.sctp |
Abstract SCTP socket interfaces which extend the core channel API.
|
io.netty.channel.sctp.nio |
NIO-based SCTP Channel
API implementation - recommended for a large number of connections (>= 1000).
|
io.netty.channel.sctp.oio |
Old blocking I/O based SCTP channel API implementation - recommended for
a small number of connections (< 1000).
|
io.netty.channel.socket |
Abstract TCP and UDP socket interfaces which extend the core channel API.
|
io.netty.channel.socket.nio |
NIO-based socket channel
API implementation - recommended for a large number of connections (>= 1000).
|
io.netty.channel.socket.oio |
Old blocking I/O based socket channel API implementation - recommended for
a small number of connections (< 1000).
|
io.netty.channel.udt |
UDT Transport.
|
io.netty.channel.udt.nio |
UDT Transport for NIO Channels.
|
io.netty.channel.unix |
Unix specific transport.
|
io.netty.example.proxy | |
io.netty.example.socksproxy | |
io.netty.handler.codec.http.websocketx |
Encoder, decoder, handshakers and their related message types for
Web Socket data frames.
|
io.netty.handler.ssl |
SSL ·
TLS implementation based on
SSLEngine |
限定符和类型 | 类和说明 |
---|---|
class |
AbstractBootstrap<B extends AbstractBootstrap<B,C>,C extends Channel>
AbstractBootstrap is a helper class that makes it easy to bootstrap a Channel . |
interface |
ChannelFactory<T extends Channel>
Factory that creates a new
Channel on AbstractBootstrap.bind() , Bootstrap.connect() , and
AbstractBootstrap.bind() . |
限定符和类型 | 类和说明 |
---|---|
class |
ChannelInitializer<C extends Channel>
A special
ChannelInboundHandler which offers an easy way to initialize a Channel once it was
registered to its EventLoop . |
限定符和类型 | 接口和说明 |
---|---|
interface |
ServerChannel
|
限定符和类型 | 类和说明 |
---|---|
class |
AbstractChannel
A skeletal
Channel implementation. |
class |
AbstractServerChannel
A skeletal server-side
Channel implementation. |
限定符和类型 | 字段和说明 |
---|---|
protected Channel |
DefaultChannelConfig.channel |
限定符和类型 | 方法和说明 |
---|---|
Channel |
DefaultChannelPromise.channel() |
Channel |
DefaultChannelProgressivePromise.channel() |
Channel |
DefaultChannelPipeline.channel() |
Channel |
ChannelPromise.channel() |
Channel |
ChannelPipeline.channel()
Returns the
Channel that this pipeline is attached to. |
Channel |
ChannelHandlerContext.channel()
Return the
Channel which is bound to the ChannelHandlerContext . |
Channel |
ChannelFuture.channel()
Returns a channel where the I/O operation associated with this
future takes place.
|
Channel |
Channel.flush()
Request to flush all pending messages.
|
Channel |
AbstractChannel.flush() |
Channel |
Channel.parent()
Returns the parent of this channel.
|
Channel |
AbstractChannel.parent() |
Channel |
Channel.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. |
Channel |
AbstractChannel.read() |
限定符和类型 | 方法和说明 |
---|---|
int |
AbstractChannel.compareTo(Channel o) |
ChannelFuture |
ThreadPerChannelEventLoopGroup.register(Channel channel) |
ChannelFuture |
SingleThreadEventLoop.register(Channel channel) |
ChannelFuture |
MultithreadEventLoopGroup.register(Channel channel) |
ChannelFuture |
EventLoopGroup.register(Channel channel)
|
ChannelFuture |
ThreadPerChannelEventLoopGroup.register(Channel channel,
ChannelPromise promise) |
ChannelFuture |
ThreadPerChannelEventLoop.register(Channel channel,
ChannelPromise promise) |
ChannelFuture |
SingleThreadEventLoop.register(Channel channel,
ChannelPromise promise) |
ChannelFuture |
MultithreadEventLoopGroup.register(Channel channel,
ChannelPromise promise) |
ChannelFuture |
EventLoopGroup.register(Channel channel,
ChannelPromise promise)
|
构造器和说明 |
---|
AbstractChannel(Channel parent)
Creates a new instance.
|
DefaultChannelConfig(Channel channel) |
DefaultChannelPipeline(Channel channel) |
DefaultChannelProgressivePromise(Channel channel)
Creates a new instance.
|
DefaultChannelProgressivePromise(Channel channel,
EventExecutor executor)
Creates a new instance.
|
DefaultChannelPromise(Channel channel)
Creates a new instance.
|
DefaultChannelPromise(Channel channel,
EventExecutor executor)
Creates a new instance.
|
限定符和类型 | 类和说明 |
---|---|
class |
EmbeddedChannel
Base class for
Channel implementations that are used in an embedded fashion. |
限定符和类型 | 类和说明 |
---|---|
class |
AbstractEpollServerChannel |
class |
AbstractEpollStreamChannel |
class |
EpollDatagramChannel
DatagramChannel implementation that uses linux EPOLL Edge-Triggered Mode for
maximal performance. |
class |
EpollDomainSocketChannel |
class |
EpollServerDomainSocketChannel |
class |
EpollServerSocketChannel
ServerSocketChannel implementation that uses linux EPOLL Edge-Triggered Mode for
maximal performance. |
class |
EpollSocketChannel
SocketChannel implementation that uses linux EPOLL Edge-Triggered Mode for
maximal performance. |
限定符和类型 | 方法和说明 |
---|---|
protected Channel |
EpollServerSocketChannel.newChildChannel(int fd,
byte[] address,
int offset,
int len) |
protected Channel |
EpollServerDomainSocketChannel.newChildChannel(int fd,
byte[] addr,
int offset,
int len) |
构造器和说明 |
---|
AbstractEpollStreamChannel(Channel parent,
int fd)
|
AbstractEpollStreamChannel(Channel parent,
Socket fd) |
EpollDomainSocketChannel(Channel parent,
FileDescriptor fd)
|
EpollDomainSocketChannel(Channel parent,
Socket fd) |
限定符和类型 | 方法和说明 |
---|---|
java.util.Iterator<Channel> |
DefaultChannelGroup.iterator() |
java.util.Iterator<java.util.Map.Entry<Channel,java.lang.Throwable>> |
ChannelGroupException.iterator()
Returns a
Iterator which contains all the Throwable that was a cause of the failure and the
related id of the Channel . |
限定符和类型 | 方法和说明 |
---|---|
boolean |
DefaultChannelGroup.add(Channel channel) |
ChannelFuture |
ChannelGroupFuture.find(Channel channel)
Returns the
ChannelFuture of the individual I/O operation which
is associated with the specified Channel . |
static ChannelMatcher |
ChannelMatchers.is(Channel channel)
Returns a
ChannelMatcher that matches the given Channel . |
static ChannelMatcher |
ChannelMatchers.isNot(Channel channel)
Returns a
ChannelMatcher that matches all Channel s except the given. |
boolean |
ChannelMatcher.matches(Channel channel)
Returns
true if the operation should be also executed on the given Channel . |
限定符和类型 | 方法和说明 |
---|---|
static ChannelMatcher |
ChannelMatchers.isInstanceOf(java.lang.Class<? extends Channel> clazz)
Returns a
ChannelMatcher that matches all Channel s that are an instance of sub-type of
the given class. |
static ChannelMatcher |
ChannelMatchers.isNotInstanceOf(java.lang.Class<? extends Channel> clazz)
Returns a
ChannelMatcher that matches all Channel s that are not an
instance of sub-type of the given class. |
构造器和说明 |
---|
ChannelGroupException(java.util.Collection<java.util.Map.Entry<Channel,java.lang.Throwable>> causes) |
限定符和类型 | 类和说明 |
---|---|
class |
LocalChannel
A
Channel for the local transport. |
class |
LocalServerChannel
A
ServerChannel for the local transport which allows in VM communication. |
限定符和类型 | 类和说明 |
---|---|
class |
AbstractNioByteChannel
AbstractNioChannel base class for Channel s that operate on bytes. |
class |
AbstractNioChannel
Abstract base class for
Channel implementations which use a Selector based approach. |
class |
AbstractNioMessageChannel
AbstractNioChannel base class for Channel s that operate on messages. |
构造器和说明 |
---|
AbstractNioByteChannel(Channel parent,
java.nio.channels.SelectableChannel ch)
Create a new instance
|
AbstractNioChannel(Channel parent,
java.nio.channels.SelectableChannel ch,
int readInterestOp)
Create a new instance
|
AbstractNioMessageChannel(Channel parent,
java.nio.channels.SelectableChannel ch,
int readInterestOp) |
限定符和类型 | 类和说明 |
---|---|
class |
AbstractOioByteChannel
Abstract base class for OIO which reads and writes bytes from/to a Socket
|
class |
AbstractOioChannel
Abstract base class for
Channel implementations that use Old-Blocking-IO |
class |
AbstractOioMessageChannel
Abstract base class for OIO which reads and writes objects from/to a Socket
|
class |
OioByteStreamChannel
Abstract base class for OIO Channels that are based on streams.
|
构造器和说明 |
---|
AbstractOioByteChannel(Channel parent) |
AbstractOioChannel(Channel parent) |
AbstractOioMessageChannel(Channel parent) |
OioByteStreamChannel(Channel parent)
Create a new instance
|
限定符和类型 | 方法和说明 |
---|---|
protected Channel |
SimpleChannelPool.pollChannel()
Poll a
Channel out of the internal storage to reuse it. |
限定符和类型 | 方法和说明 |
---|---|
Future<Channel> |
SimpleChannelPool.acquire() |
Future<Channel> |
ChannelPool.acquire()
Acquire a
Channel from this ChannelPool . |
Future<Channel> |
SimpleChannelPool.acquire(Promise<Channel> promise) |
Future<Channel> |
FixedChannelPool.acquire(Promise<Channel> promise) |
Future<Channel> |
ChannelPool.acquire(Promise<Channel> promise)
Acquire a
Channel from this ChannelPool . |
限定符和类型 | 方法和说明 |
---|---|
void |
ChannelPoolHandler.channelAcquired(Channel ch)
Called once a
Channel was acquired by calling ChannelPool.acquire() or
ChannelPool.acquire(Promise) . |
void |
AbstractChannelPoolHandler.channelAcquired(Channel ch)
NOOP implementation, sub-classes may override this.
|
void |
ChannelPoolHandler.channelCreated(Channel ch)
Called once a new
Channel is created in the ChannelPool . |
void |
ChannelPoolHandler.channelReleased(Channel ch)
Called once a
Channel was released by calling ChannelPool.release(Channel) or
ChannelPool.release(Channel, Promise) . |
void |
AbstractChannelPoolHandler.channelReleased(Channel ch)
NOOP implementation, sub-classes may override this.
|
Future<java.lang.Boolean> |
ChannelHealthChecker.isHealthy(Channel channel)
Check if the given channel is healthy which means it can be used.
|
protected boolean |
SimpleChannelPool.offerChannel(Channel channel)
Offer a
Channel back to the internal storage. |
Future<java.lang.Void> |
SimpleChannelPool.release(Channel channel) |
Future<java.lang.Void> |
ChannelPool.release(Channel channel)
Release a
Channel back to this ChannelPool . |
Future<java.lang.Void> |
SimpleChannelPool.release(Channel channel,
Promise<java.lang.Void> promise) |
Future<java.lang.Void> |
FixedChannelPool.release(Channel channel,
Promise<java.lang.Void> promise) |
Future<java.lang.Void> |
ChannelPool.release(Channel channel,
Promise<java.lang.Void> promise)
Release a
Channel back to this ChannelPool . |
限定符和类型 | 方法和说明 |
---|---|
Future<Channel> |
SimpleChannelPool.acquire(Promise<Channel> promise) |
Future<Channel> |
FixedChannelPool.acquire(Promise<Channel> promise) |
Future<Channel> |
ChannelPool.acquire(Promise<Channel> promise)
Acquire a
Channel from this ChannelPool . |
限定符和类型 | 类和说明 |
---|---|
class |
RxtxChannel
已过时。
this transport will be removed in the next major version.
|
限定符和类型 | 接口和说明 |
---|---|
interface |
SctpChannel
A SCTP/IP
Channel interface for single SCTP association. |
interface |
SctpServerChannel
A SCTP/IP
ServerChannel which accepts incoming SCTP/IP associations. |
限定符和类型 | 类和说明 |
---|---|
class |
NioSctpChannel
SctpChannel implementation which use non-blocking mode and allows to read /
write SctpMessage s to the underlying SctpChannel . |
class |
NioSctpServerChannel
SctpServerChannel implementation which use non-blocking mode to accept new
connections and create the NioSctpChannel for them. |
构造器和说明 |
---|
NioSctpChannel(Channel parent,
com.sun.nio.sctp.SctpChannel sctpChannel)
Create a new instance
|
限定符和类型 | 类和说明 |
---|---|
class |
OioSctpChannel
SctpChannel implementation which use blocking mode and allows to read / write
SctpMessage s to the underlying SctpChannel . |
class |
OioSctpServerChannel
SctpServerChannel implementation which use blocking mode to accept new
connections and create the OioSctpChannel for them. |
构造器和说明 |
---|
OioSctpChannel(Channel parent,
com.sun.nio.sctp.SctpChannel ch)
Create a new instance from the given
SctpChannel . |
限定符和类型 | 接口和说明 |
---|---|
interface |
DatagramChannel
A UDP/IP
Channel . |
interface |
DuplexChannel
A duplex
Channel that has two sides that can be shutdown independently. |
interface |
ServerSocketChannel
A TCP/IP
ServerChannel which accepts incoming TCP/IP connections. |
interface |
SocketChannel
A TCP/IP socket
Channel . |
限定符和类型 | 类和说明 |
---|---|
class |
NioDatagramChannel
An NIO datagram
Channel that sends and receives an
AddressedEnvelope . |
class |
NioServerSocketChannel
A
ServerSocketChannel implementation which uses
NIO selector based implementation to accept new connections. |
class |
NioSocketChannel
SocketChannel which uses NIO selector based implementation. |
构造器和说明 |
---|
NioSocketChannel(Channel parent,
java.nio.channels.SocketChannel socket)
Create a new instance
|
限定符和类型 | 类和说明 |
---|---|
class |
OioDatagramChannel
An OIO datagram
Channel that sends and receives an
AddressedEnvelope . |
class |
OioServerSocketChannel
ServerSocketChannel which accepts new connections and create the OioSocketChannel 's for them. |
class |
OioSocketChannel
A
SocketChannel which is using Old-Blocking-IO |
构造器和说明 |
---|
OioSocketChannel(Channel parent,
java.net.Socket socket)
Create a new instance from the given
Socket |
限定符和类型 | 接口和说明 |
---|---|
interface |
UdtChannel
已过时。
The UDT transport is no longer maintained and will be removed.
|
interface |
UdtServerChannel
已过时。
The UDT transport is no longer maintained and will be removed.
|
限定符和类型 | 类和说明 |
---|---|
class |
NioUdtAcceptorChannel
已过时。
The UDT transport is no longer maintained and will be removed.
|
class |
NioUdtByteAcceptorChannel
已过时。
The UDT transport is no longer maintained and will be removed.
|
class |
NioUdtByteConnectorChannel
已过时。
The UDT transport is no longer maintained and will be removed.
|
class |
NioUdtByteRendezvousChannel
已过时。
The UDT transport is no longer maintained and will be removed.
|
class |
NioUdtMessageAcceptorChannel
已过时。
The UDT transport is no longer maintained and will be removed.
|
class |
NioUdtMessageConnectorChannel
已过时。
The UDT transport is no longer maintained and will be removed.
|
class |
NioUdtMessageRendezvousChannel
已过时。
The UDT transport is no longer maintained and will be removed.
|
限定符和类型 | 方法和说明 |
---|---|
static ChannelUDT |
NioUdtProvider.channelUDT(Channel channel)
已过时。
Expose underlying
ChannelUDT for debugging and monitoring. |
static SocketUDT |
NioUdtProvider.socketUDT(Channel channel)
已过时。
Expose underlying
SocketUDT for debugging and monitoring. |
构造器和说明 |
---|
NioUdtByteConnectorChannel(Channel parent,
SocketChannelUDT channelUDT)
已过时。
|
NioUdtMessageConnectorChannel(Channel parent,
SocketChannelUDT channelUDT)
已过时。
|
限定符和类型 | 接口和说明 |
---|---|
interface |
DomainSocketChannel
A
UnixChannel that supports communication via
Unix Domain Socket. |
interface |
ServerDomainSocketChannel
|
interface |
UnixChannel
Channel that expose operations that are only present on UNIX like systems. |
构造器和说明 |
---|
HexDumpProxyBackendHandler(Channel inboundChannel) |
限定符和类型 | 方法和说明 |
---|---|
static void |
SocksServerUtils.closeOnFlush(Channel ch)
Closes the specified channel after all queued write requests are flushed.
|
构造器和说明 |
---|
RelayHandler(Channel relayChannel) |
构造器和说明 |
---|
DirectClientHandler(Promise<Channel> promise) |
限定符和类型 | 方法和说明 |
---|---|
ChannelFuture |
WebSocketServerHandshaker.close(Channel channel,
CloseWebSocketFrame frame)
Performs the closing handshake
|
ChannelFuture |
WebSocketClientHandshaker.close(Channel channel,
CloseWebSocketFrame frame)
Performs the closing handshake
|
ChannelFuture |
WebSocketServerHandshaker00.close(Channel channel,
CloseWebSocketFrame frame,
ChannelPromise promise)
Echo back the closing frame
|
ChannelFuture |
WebSocketServerHandshaker.close(Channel channel,
CloseWebSocketFrame frame,
ChannelPromise promise)
Performs the closing handshake
|
ChannelFuture |
WebSocketClientHandshaker.close(Channel channel,
CloseWebSocketFrame frame,
ChannelPromise promise)
Performs the closing handshake
|
void |
WebSocketClientHandshaker.finishHandshake(Channel channel,
FullHttpResponse response)
Validates and finishes the opening handshake initiated by
WebSocketClientHandshaker.handshake(io.netty.channel.Channel) }. |
ChannelFuture |
WebSocketClientHandshaker.handshake(Channel channel)
Begins the opening handshake
|
ChannelFuture |
WebSocketClientHandshaker.handshake(Channel channel,
ChannelPromise promise)
Begins the opening handshake
|
ChannelFuture |
WebSocketServerHandshaker.handshake(Channel channel,
FullHttpRequest req)
Performs the opening handshake.
|
ChannelFuture |
WebSocketServerHandshaker.handshake(Channel channel,
FullHttpRequest req,
HttpHeaders responseHeaders,
ChannelPromise promise)
Performs the opening handshake
When call this method you MUST NOT retain the
FullHttpRequest which is passed in. |
ChannelFuture |
WebSocketServerHandshaker.handshake(Channel channel,
HttpRequest req)
Performs the opening handshake.
|
ChannelFuture |
WebSocketServerHandshaker.handshake(Channel channel,
HttpRequest req,
HttpHeaders responseHeaders,
ChannelPromise promise)
Performs the opening handshake
When call this method you MUST NOT retain the
HttpRequest which is passed in. |
ChannelFuture |
WebSocketClientHandshaker.processHandshake(Channel channel,
HttpResponse response)
Process the opening handshake initiated by
WebSocketClientHandshaker.handshake(io.netty.channel.Channel) }. |
ChannelFuture |
WebSocketClientHandshaker.processHandshake(Channel channel,
HttpResponse response,
ChannelPromise promise)
Process the opening handshake initiated by
WebSocketClientHandshaker.handshake(io.netty.channel.Channel) }. |
static ChannelFuture |
WebSocketServerHandshakerFactory.sendUnsupportedVersionResponse(Channel channel)
Return that we need cannot not support the web socket version
|
static ChannelFuture |
WebSocketServerHandshakerFactory.sendUnsupportedVersionResponse(Channel channel,
ChannelPromise promise)
Return that we need cannot not support the web socket version
|
static void |
WebSocketServerHandshakerFactory.sendUnsupportedWebSocketVersionResponse(Channel channel)
|
限定符和类型 | 方法和说明 |
---|---|
Future<Channel> |
SslHandler.handshakeFuture()
Returns a
Future that will get notified once the current TLS handshake completes. |
Future<Channel> |
SslHandler.renegotiate()
Performs TLS renegotiation.
|
Future<Channel> |
SslHandler.renegotiate(Promise<Channel> promise)
Performs TLS renegotiation.
|
Future<Channel> |
SslHandler.sslCloseFuture()
Return the
Future that will get notified if the inbound of the SSLEngine is closed. |
限定符和类型 | 方法和说明 |
---|---|
Future<Channel> |
SslHandler.renegotiate(Promise<Channel> promise)
Performs TLS renegotiation.
|