Package | Description |
---|---|
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.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.handler.codec.http.websocketx |
Encoder, decoder, handshakers and their related message types for
Web Socket data frames.
|
io.netty.handler.proxy |
Adds support for client connections via proxy protocols such as
SOCKS and
HTTP CONNECT tunneling
|
io.netty.handler.ssl |
Modifier and Type | Class and Description |
---|---|
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>
Deprecated.
Use
ChannelFactory instead. |
Modifier and Type | Interface and Description |
---|---|
interface |
ChannelFactory<T extends Channel>
Creates a new
Channel . |
class |
ChannelInitializer<C extends Channel>
A special
ChannelHandler which offers an easy way to initialize a Channel once it was
registered to its EventLoop . |
class |
ReflectiveChannelFactory<T extends Channel>
A
ChannelFactory that instantiates a new Channel by invoking its default constructor reflectively. |
Modifier and Type | Interface and Description |
---|---|
interface |
ServerChannel
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractChannel
A skeletal
Channel implementation. |
class |
AbstractServerChannel
A skeletal server-side
Channel implementation. |
Modifier and Type | Field and Description |
---|---|
protected Channel |
DefaultChannelConfig.channel |
Modifier and Type | Method and Description |
---|---|
Channel |
ChannelPipeline.channel()
Returns the
Channel that this pipeline is attached to. |
Channel |
DefaultChannelProgressivePromise.channel() |
Channel |
ChannelPromise.channel() |
Channel |
ChannelFuture.channel()
Returns a channel where the I/O operation associated with this
future takes place.
|
Channel |
ChannelHandlerContext.channel()
Return the
Channel which is bound to the ChannelHandlerContext . |
Channel |
DefaultChannelPromise.channel() |
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
ChannelHandler.channelRead(ChannelHandlerContext, Object) event if data was
read, and triggers a
channelReadComplete event so the
handler can decide to continue reading. |
Channel |
AbstractChannel.read() |
Modifier and Type | Method and Description |
---|---|
int |
AbstractChannel.compareTo(Channel o) |
ChannelFuture |
ThreadPerChannelEventLoopGroup.register(Channel channel) |
ChannelFuture |
MultithreadEventLoopGroup.register(Channel channel) |
ChannelFuture |
EventLoopGroup.register(Channel channel)
|
ChannelFuture |
SingleThreadEventLoop.register(Channel channel) |
ChannelFuture |
ThreadPerChannelEventLoopGroup.register(Channel channel,
ChannelPromise promise) |
ChannelFuture |
ThreadPerChannelEventLoop.register(Channel channel,
ChannelPromise promise) |
ChannelFuture |
MultithreadEventLoopGroup.register(Channel channel,
ChannelPromise promise) |
ChannelFuture |
EventLoopGroup.register(Channel channel,
ChannelPromise promise)
|
ChannelFuture |
SingleThreadEventLoop.register(Channel channel,
ChannelPromise promise) |
Constructor and Description |
---|
AbstractChannel(Channel parent)
Creates a new instance.
|
AbstractChannel(Channel parent,
ChannelId id)
Creates a new instance.
|
DefaultChannelConfig(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.
|
Modifier and Type | Class and Description |
---|---|
class |
EmbeddedChannel
Base class for
Channel implementations that are used in an embedded fashion. |
Modifier and Type | Class and Description |
---|---|
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. |
Modifier and Type | Method and Description |
---|---|
protected Channel |
EpollServerDomainSocketChannel.newChildChannel(int fd,
byte[] addr,
int offset,
int len) |
protected Channel |
EpollServerSocketChannel.newChildChannel(int fd,
byte[] address,
int offset,
int len) |
Constructor and Description |
---|
AbstractEpollStreamChannel(Channel parent,
int fd) |
EpollDomainSocketChannel(Channel parent,
FileDescriptor fd) |
Modifier and Type | Method and Description |
---|---|
Channel |
ChannelGroup.find(ChannelId id)
|
Channel |
DefaultChannelGroup.find(ChannelId id) |
Modifier and Type | Method and Description |
---|---|
Iterator<Map.Entry<Channel,Throwable>> |
ChannelGroupException.iterator()
|
Iterator<Channel> |
DefaultChannelGroup.iterator() |
Modifier and Type | Method and Description |
---|---|
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 . |
Modifier and Type | Method and Description |
---|---|
static ChannelMatcher |
ChannelMatchers.isInstanceOf(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(Class<? extends Channel> clazz)
Returns a
ChannelMatcher that matches all Channel s that are not an
instance of sub-type of the given class. |
Constructor and Description |
---|
ChannelGroupException(Collection<Map.Entry<Channel,Throwable>> causes) |
Modifier and Type | Class and Description |
---|---|
class |
LocalChannel
A
Channel for the local transport. |
class |
LocalServerChannel
A
ServerChannel for the local transport which allows in VM communication. |
Modifier and Type | Class and Description |
---|---|
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. |
Constructor and Description |
---|
AbstractNioByteChannel(Channel parent,
SelectableChannel ch)
Create a new instance
|
AbstractNioChannel(Channel parent,
SelectableChannel ch,
int readInterestOp)
Create a new instance
|
AbstractNioMessageChannel(Channel parent,
SelectableChannel ch,
int readInterestOp) |
Modifier and Type | Class and Description |
---|---|
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.
|
Constructor and Description |
---|
AbstractOioByteChannel(Channel parent) |
AbstractOioChannel(Channel parent) |
AbstractOioMessageChannel(Channel parent) |
OioByteStreamChannel(Channel parent)
Create a new instance
|
Modifier and Type | Class and Description |
---|---|
class |
RxtxChannel
A channel to a serial device using the RXTX library.
|
Modifier and Type | Interface and Description |
---|---|
interface |
SctpChannel
A SCTP/IP
Channel interface for single SCTP association. |
interface |
SctpServerChannel
A SCTP/IP
ServerChannel which accepts incoming SCTP/IP associations. |
Modifier and Type | Class and Description |
---|---|
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. |
Constructor and Description |
---|
NioSctpChannel(Channel parent,
com.sun.nio.sctp.SctpChannel sctpChannel)
Create a new instance
|
Modifier and Type | Class and Description |
---|---|
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. |
Constructor and Description |
---|
OioSctpChannel(Channel parent,
com.sun.nio.sctp.SctpChannel ch)
Create a new instance from the given
SctpChannel . |
Modifier and Type | Interface and Description |
---|---|
interface |
DatagramChannel
A UDP/IP
Channel }. |
interface |
ServerSocketChannel
A TCP/IP
ServerChannel which accepts incoming TCP/IP connections. |
interface |
SocketChannel
A TCP/IP socket
Channel . |
Modifier and Type | Class and Description |
---|---|
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. |
Constructor and Description |
---|
NioSocketChannel(Channel parent,
SocketChannel socket)
Create a new instance
|
Modifier and Type | Class and Description |
---|---|
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 |
Constructor and Description |
---|
OioSocketChannel(Channel parent,
Socket socket)
Create a new instance from the given
Socket |
Modifier and Type | Interface and Description |
---|---|
interface |
UdtChannel
UDT
Channel . |
interface |
UdtServerChannel
UDT
ServerChannel . |
Modifier and Type | Class and Description |
---|---|
class |
NioUdtAcceptorChannel
Common base for Netty Byte/Message UDT Stream/Datagram acceptors.
|
class |
NioUdtByteAcceptorChannel
Byte Channel Acceptor for UDT Streams.
|
class |
NioUdtByteConnectorChannel
Byte Channel Connector for UDT Streams.
|
class |
NioUdtByteRendezvousChannel
Byte Channel Rendezvous for UDT Streams.
|
class |
NioUdtMessageAcceptorChannel
Message Channel Acceptor for UDT Datagrams.
|
class |
NioUdtMessageConnectorChannel
Message Connector for UDT Datagrams.
|
class |
NioUdtMessageRendezvousChannel
Message Rendezvous for UDT Datagrams.
|
Modifier and Type | Method and Description |
---|---|
static com.barchart.udt.nio.ChannelUDT |
NioUdtProvider.channelUDT(Channel channel)
Expose underlying
ChannelUDT for debugging and monitoring. |
static com.barchart.udt.SocketUDT |
NioUdtProvider.socketUDT(Channel channel)
Expose underlying
SocketUDT for debugging and monitoring. |
Constructor and Description |
---|
NioUdtByteConnectorChannel(Channel parent,
com.barchart.udt.nio.SocketChannelUDT channelUDT) |
NioUdtMessageConnectorChannel(Channel parent,
com.barchart.udt.nio.SocketChannelUDT channelUDT) |
Modifier and Type | Interface and Description |
---|---|
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. |
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
WebSocketServerHandshaker.close(Channel channel,
CloseWebSocketFrame frame)
Performs the closing handshake
|
ChannelFuture |
WebSocketClientHandshaker.close(Channel channel,
CloseWebSocketFrame frame)
Performs the closing handshake
|
ChannelFuture |
WebSocketServerHandshaker.close(Channel channel,
CloseWebSocketFrame frame,
ChannelPromise promise)
Performs the closing handshake
|
ChannelFuture |
WebSocketServerHandshaker00.close(Channel channel,
CloseWebSocketFrame frame,
ChannelPromise promise)
Echo back the closing frame
|
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
|
Modifier and Type | Method and Description |
---|---|
Future<Channel> |
ProxyHandler.connectFuture()
Returns a
Future that is notified when the connection to the destination has been established
or the connection attempt has failed. |
Modifier and Type | Method and Description |
---|---|
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()
|
Modifier and Type | Method and Description |
---|---|
Future<Channel> |
SslHandler.renegotiate(Promise<Channel> promise)
Performs TLS renegotiation.
|
Copyright © 2008–2015 The Netty Project. All rights reserved.