软件包 | 描述 |
---|---|
io.netty.bootstrap |
带有流畅API的助手类可以轻松实现典型的客户端和服务器端通道初始化。
|
io.netty.channel |
核心通道API是异步和事件驱动的各种传输的抽象,如
NIO Channel 。
|
io.netty.channel.embedded |
一个虚拟的 Channel ,它帮助包装一系列处理程序来单元测试处理程序或在非I / O上下文中使用它们。
|
io.netty.channel.epoll |
为使用
EPOLL Edge-Triggered Mode获得最佳性能的Linux优化传输。
|
io.netty.channel.group |
通道注册表,帮助用户维护打开的 Channel 的列表并对其执行批量操作。
|
io.netty.channel.kqueue |
BSD专用运输。
|
io.netty.channel.nio |
基于
NIO的通道API实现 - 推荐用于大量连接(> = 1000)。
|
io.netty.channel.oio |
旧阻止基于I / O的通道API实现 - 建议用于少量连接(<1000)。
|
io.netty.channel.pool |
Channel 池的实现和API。
|
io.netty.channel.rxtx |
基于
RXTX的串行和并行端口通信传输。
|
io.netty.channel.sctp |
抽象扩展核心通道API的SCTP套接字接口。
|
io.netty.channel.sctp.nio |
基于
NIO的SCTP通道API实现 - 推荐用于大量连接(> = 1000)。
|
io.netty.channel.sctp.oio |
旧的阻止基于I / O的SCTP通道API实现 - 建议用于少量连接(<1000)。
|
io.netty.channel.socket |
抽象扩展核心通道API的TCP和UDP套接字接口。
|
io.netty.channel.socket.nio |
基于
NIO的套接字通道API实现 - 推荐用于大量连接(> = 1000)。
|
io.netty.channel.socket.oio |
旧阻塞基于I / O的套接字通道API实现 - 建议少量连接(<1000)。
|
io.netty.channel.udt.nio |
用于NIO通道的UDT传输。
|
io.netty.handler.codec.compression | |
io.netty.handler.codec.http.websocketx |
Web Socket数据帧的编码器,解码器,握手及其相关消息类型。
|
io.netty.handler.codec.http2 |
用于发送和接收HTTP / 2帧的处理程序。
|
io.netty.handler.ipfilter |
打包来过滤IP地址(允许/拒绝)。
|
io.netty.handler.ssl |
SSL · TLS的实现基于
SSLEngine
|
io.netty.resolver.dns |
Java的内置域名查找机制的一种替代方法,可以异步解析域名,同样支持任意DNS记录类型的查询。
|
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
AbstractBootstrap.bind()
创建一个新的 Channel 并绑定它。
|
ChannelFuture |
AbstractBootstrap.bind(java.net.InetAddress inetHost, int inetPort)
创建一个新的 Channel 并绑定它。
|
ChannelFuture |
AbstractBootstrap.bind(int inetPort)
创建一个新的 Channel 并绑定它。
|
ChannelFuture |
AbstractBootstrap.bind(java.net.SocketAddress localAddress)
创建一个新的 Channel 并绑定它。
|
ChannelFuture |
AbstractBootstrap.bind(java.lang.String inetHost, int inetPort)
创建一个新的 Channel 并绑定它。
|
ChannelFuture |
Bootstrap.connect()
将 Channel 连接到远程对等端。
|
ChannelFuture |
Bootstrap.connect(java.net.InetAddress inetHost, int inetPort)
将 Channel 连接到远程对等端。
|
ChannelFuture |
Bootstrap.connect(java.net.SocketAddress remoteAddress)
将 Channel 连接到远程对等端。
|
ChannelFuture |
Bootstrap.connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress)
将 Channel 连接到远程对等端。
|
ChannelFuture |
Bootstrap.connect(java.lang.String inetHost, int inetPort)
将 Channel 连接到远程对等端。
|
ChannelFuture |
AbstractBootstrap.register()
|
Modifier and Type | Interface and Description |
---|---|
interface |
ChannelProgressiveFuture
一个特殊的 ChannelFuture ,用于指示FileRegion 传输进度
|
interface |
ChannelProgressivePromise
特殊 ChannelPromise 一旦关联的字节正在传输,将会通知它。
|
interface |
ChannelPromise
特别 ChannelFuture 这是可写的。
|
Modifier and Type | Class and Description |
---|---|
class |
DefaultChannelProgressivePromise
|
class |
DefaultChannelPromise
默认的 ChannelPromise 实现。
|
class |
DelegatingChannelPromiseNotifier |
class |
VoidChannelPromise |
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
ChannelFuture.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelFuture |
ChannelFuture.addListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners) |
ChannelFuture |
ChannelFuture.await() |
ChannelFuture |
ChannelFuture.awaitUninterruptibly() |
ChannelFuture |
DefaultChannelPipeline.bind(java.net.SocketAddress localAddress) |
ChannelFuture |
ChannelOutboundInvoker.bind(java.net.SocketAddress localAddress)
请求绑定到给定的 SocketAddress 并在操作完成后通知ChannelFuture ,无论是因为操作成功还是由于错误。
|
ChannelFuture |
AbstractChannel.bind(java.net.SocketAddress localAddress) |
ChannelFuture |
DefaultChannelPipeline.bind(java.net.SocketAddress localAddress, ChannelPromise promise) |
ChannelFuture |
ChannelOutboundInvoker.bind(java.net.SocketAddress localAddress, ChannelPromise promise)
请求绑定到给定的 SocketAddress 并在操作完成后通知ChannelFuture ,这可能是因为操作成功或者由于错误。
|
ChannelFuture |
AbstractChannel.bind(java.net.SocketAddress localAddress, ChannelPromise promise) |
ChannelFuture |
DefaultChannelPipeline.close() |
ChannelFuture |
ChannelOutboundInvoker.close()
请求关闭 Channel ,并在操作完成后通知ChannelFuture ,无论是因为操作成功还是由于错误。
|
ChannelFuture |
AbstractChannel.close() |
ChannelFuture |
DefaultChannelPipeline.close(ChannelPromise promise) |
ChannelFuture |
ChannelOutboundInvoker.close(ChannelPromise promise)
请求关闭 Channel ,并在操作完成后通知ChannelFuture ,无论是因为操作成功还是由于错误。
|
ChannelFuture |
AbstractChannel.close(ChannelPromise promise) |
ChannelFuture |
Channel.closeFuture()
返回此通道关闭时将通知的 ChannelFuture 。
|
ChannelFuture |
AbstractChannel.closeFuture() |
ChannelFuture |
DefaultChannelPipeline.connect(java.net.SocketAddress remoteAddress) |
ChannelFuture |
ChannelOutboundInvoker.connect(java.net.SocketAddress remoteAddress)
请求连接到给定的 SocketAddress 并在操作完成后通知ChannelFuture ,无论是因为操作成功还是由于错误。
|
ChannelFuture |
AbstractChannel.connect(java.net.SocketAddress remoteAddress) |
ChannelFuture |
DefaultChannelPipeline.connect(java.net.SocketAddress remoteAddress, ChannelPromise promise) |
ChannelFuture |
ChannelOutboundInvoker.connect(java.net.SocketAddress remoteAddress, ChannelPromise promise)
请求连接到给定的 SocketAddress 并在操作完成后通知ChannelFuture ,无论是因为操作成功还是由于错误。
|
ChannelFuture |
AbstractChannel.connect(java.net.SocketAddress remoteAddress, ChannelPromise promise) |
ChannelFuture |
DefaultChannelPipeline.connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress) |
ChannelFuture |
ChannelOutboundInvoker.connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress)
请求连接到给定的 SocketAddress 同时绑定到localAddress,并在操作完成后通知ChannelFuture ,因为操作成功或出错。
|
ChannelFuture |
AbstractChannel.connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress) |
ChannelFuture |
DefaultChannelPipeline.connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise) |
ChannelFuture |
ChannelOutboundInvoker.connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
请求连接到给定的 SocketAddress 同时绑定到localAddress,并在操作完成后通知ChannelFuture ,无论是因为操作成功还是由于错误。
|
ChannelFuture |
AbstractChannel.connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise) |
ChannelFuture |
DefaultChannelPipeline.deregister() |
ChannelFuture |
ChannelOutboundInvoker.deregister()
请求从先前分配的 EventExecutor 取消注册,并在操作完成后通知ChannelFuture ,这可能是因为操作成功或错误。
|
ChannelFuture |
AbstractChannel.deregister() |
ChannelFuture |
DefaultChannelPipeline.deregister(ChannelPromise promise) |
ChannelFuture |
ChannelOutboundInvoker.deregister(ChannelPromise promise)
请求从先前分配的 EventExecutor 取消注册,并在操作完成后通知ChannelFuture ,无论是因为操作成功还是由于错误。
|
ChannelFuture |
AbstractChannel.deregister(ChannelPromise promise) |
ChannelFuture |
DefaultChannelPipeline.disconnect() |
ChannelFuture |
ChannelOutboundInvoker.disconnect()
请求从远程对等方断开连接,并在操作完成后通知 ChannelFuture ,因为操作成功或错误。
|
ChannelFuture |
AbstractChannel.disconnect() |
ChannelFuture |
DefaultChannelPipeline.disconnect(ChannelPromise promise) |
ChannelFuture |
ChannelOutboundInvoker.disconnect(ChannelPromise promise)
请求从远程对等方断开连接,并在操作完成后通知 ChannelFuture ,可能是因为操作成功或错误。
|
ChannelFuture |
AbstractChannel.disconnect(ChannelPromise promise) |
ChannelFuture |
DefaultChannelPipeline.newFailedFuture(java.lang.Throwable cause) |
ChannelFuture |
ChannelOutboundInvoker.newFailedFuture(java.lang.Throwable cause)
创建一个新的已被标记为失败的 ChannelFuture 。
|
ChannelFuture |
AbstractChannel.newFailedFuture(java.lang.Throwable cause) |
ChannelFuture |
DefaultChannelPipeline.newSucceededFuture() |
ChannelFuture |
ChannelOutboundInvoker.newSucceededFuture()
创建一个新的 ChannelFuture ,它已被标记为已成功。
|
ChannelFuture |
AbstractChannel.newSucceededFuture() |
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)
已过时。
|
ChannelFuture |
ThreadPerChannelEventLoopGroup.register(ChannelPromise promise) |
ChannelFuture |
ThreadPerChannelEventLoop.register(ChannelPromise promise) |
ChannelFuture |
SingleThreadEventLoop.register(ChannelPromise promise) |
ChannelFuture |
MultithreadEventLoopGroup.register(ChannelPromise promise) |
ChannelFuture |
EventLoopGroup.register(ChannelPromise promise)
注册一个 Channel 这个EventLoop 使用ChannelFuture 。
|
ChannelFuture |
PendingWriteQueue.removeAndWrite()
删除待处理的写入操作并通过
ChannelOutboundInvoker.write(Object, ChannelPromise) 执行。
|
ChannelFuture |
PendingWriteQueue.removeAndWriteAll()
删除所有待处理的写入操作并通过
ChannelOutboundInvoker.write(Object, ChannelPromise) 执行它们。
|
ChannelFuture |
ChannelFuture.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelFuture |
ChannelFuture.removeListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners) |
ChannelFuture |
ChannelFuture.sync() |
ChannelFuture |
ChannelFuture.syncUninterruptibly() |
ChannelFuture |
DefaultChannelPipeline.write(java.lang.Object msg) |
ChannelFuture |
ChannelOutboundInvoker.write(java.lang.Object msg)
要求通过 ChannelHandlerContext 通过ChannelPipeline 写信息。
|
ChannelFuture |
AbstractChannel.write(java.lang.Object msg) |
ChannelFuture |
DefaultChannelPipeline.write(java.lang.Object msg, ChannelPromise promise) |
ChannelFuture |
ChannelOutboundInvoker.write(java.lang.Object msg, ChannelPromise promise)
要求通过 ChannelHandlerContext 通过ChannelPipeline 写信息。
|
ChannelFuture |
AbstractChannel.write(java.lang.Object msg, ChannelPromise promise) |
ChannelFuture |
DefaultChannelPipeline.writeAndFlush(java.lang.Object msg) |
ChannelFuture |
ChannelOutboundInvoker.writeAndFlush(java.lang.Object msg)
|
ChannelFuture |
AbstractChannel.writeAndFlush(java.lang.Object msg) |
ChannelFuture |
DefaultChannelPipeline.writeAndFlush(java.lang.Object msg, ChannelPromise promise) |
ChannelFuture |
ChannelOutboundInvoker.writeAndFlush(java.lang.Object msg, ChannelPromise promise)
|
ChannelFuture |
AbstractChannel.writeAndFlush(java.lang.Object msg, ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
void |
DelegatingChannelPromiseNotifier.operationComplete(ChannelFuture future) |
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
EmbeddedChannel.close() |
ChannelFuture |
EmbeddedChannel.close(ChannelPromise promise) |
ChannelFuture |
EmbeddedChannel.disconnect() |
ChannelFuture |
EmbeddedChannel.disconnect(ChannelPromise promise) |
ChannelFuture |
EmbeddedChannel.writeOneInbound(java.lang.Object msg)
向此 Channel 的入站写入一条消息,但不刷新它。
|
ChannelFuture |
EmbeddedChannel.writeOneInbound(java.lang.Object msg, ChannelPromise promise)
向此 Channel 的入站写入一条消息,但不刷新它。
|
ChannelFuture |
EmbeddedChannel.writeOneOutbound(java.lang.Object msg)
向此 Channel 的出站端写入一条消息,但不刷新它。
|
ChannelFuture |
EmbeddedChannel.writeOneOutbound(java.lang.Object msg, ChannelPromise promise)
向此 Channel 的出站端写入一条消息,但不刷新它。
|
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
EpollDatagramChannel.block(java.net.InetAddress multicastAddress, java.net.InetAddress sourceToBlock) |
ChannelFuture |
EpollDatagramChannel.block(java.net.InetAddress multicastAddress, java.net.InetAddress sourceToBlock, ChannelPromise promise) |
ChannelFuture |
EpollDatagramChannel.block(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress sourceToBlock) |
ChannelFuture |
EpollDatagramChannel.block(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress sourceToBlock, ChannelPromise promise) |
ChannelFuture |
EpollDatagramChannel.joinGroup(java.net.InetAddress multicastAddress) |
ChannelFuture |
EpollDatagramChannel.joinGroup(java.net.InetAddress multicastAddress, ChannelPromise promise) |
ChannelFuture |
EpollDatagramChannel.joinGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source) |
ChannelFuture |
EpollDatagramChannel.joinGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source, ChannelPromise promise) |
ChannelFuture |
EpollDatagramChannel.joinGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface) |
ChannelFuture |
EpollDatagramChannel.joinGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface, ChannelPromise promise) |
ChannelFuture |
EpollDatagramChannel.leaveGroup(java.net.InetAddress multicastAddress) |
ChannelFuture |
EpollDatagramChannel.leaveGroup(java.net.InetAddress multicastAddress, ChannelPromise promise) |
ChannelFuture |
EpollDatagramChannel.leaveGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source) |
ChannelFuture |
EpollDatagramChannel.leaveGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source, ChannelPromise promise) |
ChannelFuture |
EpollDatagramChannel.leaveGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface) |
ChannelFuture |
EpollDatagramChannel.leaveGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface, ChannelPromise promise) |
ChannelFuture |
AbstractEpollStreamChannel.shutdown() |
ChannelFuture |
AbstractEpollStreamChannel.shutdown(ChannelPromise promise) |
ChannelFuture |
AbstractEpollStreamChannel.shutdownInput() |
ChannelFuture |
AbstractEpollStreamChannel.shutdownInput(ChannelPromise promise) |
ChannelFuture |
AbstractEpollStreamChannel.shutdownOutput() |
ChannelFuture |
AbstractEpollStreamChannel.shutdownOutput(ChannelPromise promise) |
ChannelFuture |
AbstractEpollStreamChannel.spliceTo(AbstractEpollStreamChannel ch, int len)
|
ChannelFuture |
AbstractEpollStreamChannel.spliceTo(AbstractEpollStreamChannel ch, int len, ChannelPromise promise)
|
ChannelFuture |
AbstractEpollStreamChannel.spliceTo(FileDescriptor ch, int offset, int len)
将此 AbstractEpollStreamChannel 接合到另一个FileDescriptor 。
|
ChannelFuture |
AbstractEpollStreamChannel.spliceTo(FileDescriptor ch, int offset, int len, ChannelPromise promise)
|
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
ChannelGroupFuture.find(Channel channel)
返回 ChannelFuture ,其与指定的相关联的单独的I / O操作的Channel 。
|
Modifier and Type | Method and Description |
---|---|
java.util.Iterator<ChannelFuture> |
ChannelGroupFuture.iterator()
返回 Iterator ,列举与此未来相关的所有ChannelFuture 。
|
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
KQueueDatagramChannel.block(java.net.InetAddress multicastAddress, java.net.InetAddress sourceToBlock) |
ChannelFuture |
KQueueDatagramChannel.block(java.net.InetAddress multicastAddress, java.net.InetAddress sourceToBlock, ChannelPromise promise) |
ChannelFuture |
KQueueDatagramChannel.block(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress sourceToBlock) |
ChannelFuture |
KQueueDatagramChannel.block(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress sourceToBlock, ChannelPromise promise) |
ChannelFuture |
KQueueDatagramChannel.joinGroup(java.net.InetAddress multicastAddress) |
ChannelFuture |
KQueueDatagramChannel.joinGroup(java.net.InetAddress multicastAddress, ChannelPromise promise) |
ChannelFuture |
KQueueDatagramChannel.joinGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source) |
ChannelFuture |
KQueueDatagramChannel.joinGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source, ChannelPromise promise) |
ChannelFuture |
KQueueDatagramChannel.joinGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface) |
ChannelFuture |
KQueueDatagramChannel.joinGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface, ChannelPromise promise) |
ChannelFuture |
KQueueDatagramChannel.leaveGroup(java.net.InetAddress multicastAddress) |
ChannelFuture |
KQueueDatagramChannel.leaveGroup(java.net.InetAddress multicastAddress, ChannelPromise promise) |
ChannelFuture |
KQueueDatagramChannel.leaveGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source) |
ChannelFuture |
KQueueDatagramChannel.leaveGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source, ChannelPromise promise) |
ChannelFuture |
KQueueDatagramChannel.leaveGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface) |
ChannelFuture |
KQueueDatagramChannel.leaveGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface, ChannelPromise promise) |
ChannelFuture |
AbstractKQueueStreamChannel.shutdown() |
ChannelFuture |
AbstractKQueueStreamChannel.shutdown(ChannelPromise promise) |
ChannelFuture |
AbstractKQueueStreamChannel.shutdownInput() |
ChannelFuture |
AbstractKQueueStreamChannel.shutdownInput(ChannelPromise promise) |
ChannelFuture |
AbstractKQueueStreamChannel.shutdownOutput() |
ChannelFuture |
AbstractKQueueStreamChannel.shutdownOutput(ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
protected abstract ChannelFuture |
AbstractNioByteChannel.shutdownInput()
关闭通道的输入端。
|
Modifier and Type | Method and Description |
---|---|
protected abstract ChannelFuture |
AbstractOioByteChannel.shutdownInput()
关闭此通道的输入端。
|
Modifier and Type | Method and Description |
---|---|
protected ChannelFuture |
SimpleChannelPool.connectChannel(Bootstrap bs)
引导一个新的 Channel 。
|
Modifier and Type | Method and Description |
---|---|
protected ChannelFuture |
RxtxChannel.shutdownInput()
已过时。
|
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
SctpServerChannel.bindAddress(java.net.InetAddress localAddress)
将地址绑定到已绑定的通道以启用多宿主。
|
ChannelFuture |
SctpChannel.bindAddress(java.net.InetAddress localAddress)
将地址绑定到已绑定的通道以启用多宿主。
|
ChannelFuture |
SctpServerChannel.bindAddress(java.net.InetAddress localAddress, ChannelPromise promise)
将地址绑定到已绑定的通道以启用多宿主。
|
ChannelFuture |
SctpChannel.bindAddress(java.net.InetAddress localAddress, ChannelPromise promise)
将地址绑定到已绑定的通道以启用多宿主。
|
ChannelFuture |
SctpServerChannel.unbindAddress(java.net.InetAddress localAddress)
从通道的多址地址列表中解除绑定地址。
|
ChannelFuture |
SctpChannel.unbindAddress(java.net.InetAddress localAddress)
从通道的多址地址列表中解除绑定地址。
|
ChannelFuture |
SctpServerChannel.unbindAddress(java.net.InetAddress localAddress, ChannelPromise promise)
从通道的多址地址列表中解除绑定地址。
|
ChannelFuture |
SctpChannel.unbindAddress(java.net.InetAddress localAddress, ChannelPromise promise)
从通道的多址地址列表中解除绑定地址。
|
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
NioSctpServerChannel.bindAddress(java.net.InetAddress localAddress) |
ChannelFuture |
NioSctpChannel.bindAddress(java.net.InetAddress localAddress) |
ChannelFuture |
NioSctpServerChannel.bindAddress(java.net.InetAddress localAddress, ChannelPromise promise) |
ChannelFuture |
NioSctpChannel.bindAddress(java.net.InetAddress localAddress, ChannelPromise promise) |
ChannelFuture |
NioSctpServerChannel.unbindAddress(java.net.InetAddress localAddress) |
ChannelFuture |
NioSctpChannel.unbindAddress(java.net.InetAddress localAddress) |
ChannelFuture |
NioSctpServerChannel.unbindAddress(java.net.InetAddress localAddress, ChannelPromise promise) |
ChannelFuture |
NioSctpChannel.unbindAddress(java.net.InetAddress localAddress, ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
OioSctpServerChannel.bindAddress(java.net.InetAddress localAddress) |
ChannelFuture |
OioSctpChannel.bindAddress(java.net.InetAddress localAddress) |
ChannelFuture |
OioSctpServerChannel.bindAddress(java.net.InetAddress localAddress, ChannelPromise promise) |
ChannelFuture |
OioSctpChannel.bindAddress(java.net.InetAddress localAddress, ChannelPromise promise) |
ChannelFuture |
OioSctpServerChannel.unbindAddress(java.net.InetAddress localAddress) |
ChannelFuture |
OioSctpChannel.unbindAddress(java.net.InetAddress localAddress) |
ChannelFuture |
OioSctpServerChannel.unbindAddress(java.net.InetAddress localAddress, ChannelPromise promise) |
ChannelFuture |
OioSctpChannel.unbindAddress(java.net.InetAddress localAddress, ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
DatagramChannel.block(java.net.InetAddress multicastAddress, java.net.InetAddress sourceToBlock)
阻止给定多播地址的给定sourceToBlock地址,并在操作完成后通知 ChannelFuture 。
|
ChannelFuture |
DatagramChannel.block(java.net.InetAddress multicastAddress, java.net.InetAddress sourceToBlock, ChannelPromise future)
阻止给定多播地址的给定sourceToBlock地址,并在操作完成后通知 ChannelFuture 。
|
ChannelFuture |
DatagramChannel.block(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress sourceToBlock)
在给定networkInterface上阻止给定的多播地址的给定sourceToBlock地址,并在操作完成后通知 ChannelFuture 。
|
ChannelFuture |
DatagramChannel.block(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress sourceToBlock, ChannelPromise future)
在给定networkInterface上阻止给定的多播地址的给定sourceToBlock地址,并在操作完成后通知 ChannelFuture 。
|
ChannelFuture |
DatagramChannel.joinGroup(java.net.InetAddress multicastAddress)
加入一个多播组,并在操作完成后通知 ChannelFuture 。
|
ChannelFuture |
DatagramChannel.joinGroup(java.net.InetAddress multicastAddress, ChannelPromise future)
加入一个多播组,并在操作完成后通知 ChannelFuture 。
|
ChannelFuture |
DatagramChannel.joinGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source)
在指定的接口加入指定的组播组,并在操作完成后通知 ChannelFuture 。
|
ChannelFuture |
DatagramChannel.joinGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source, ChannelPromise future)
加入指定接口上的指定组播组,并在操作完成后通知 ChannelFuture 。
|
ChannelFuture |
DatagramChannel.joinGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface)
在指定的接口加入指定的组播组,并在操作完成后通知 ChannelFuture 。
|
ChannelFuture |
DatagramChannel.joinGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface, ChannelPromise future)
在指定的接口加入指定的组播组,并在操作完成后通知 ChannelFuture 。
|
ChannelFuture |
DatagramChannel.leaveGroup(java.net.InetAddress multicastAddress)
一个操作完成后,离开多播组并通知 ChannelFuture 。
|
ChannelFuture |
DatagramChannel.leaveGroup(java.net.InetAddress multicastAddress, ChannelPromise future)
一旦操作完成,就离开多点传送组并通知 ChannelFuture 。
|
ChannelFuture |
DatagramChannel.leaveGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source)
在指定的接口上使用指定的源保留指定的多播组,并在操作完成后通知 ChannelFuture 。
|
ChannelFuture |
DatagramChannel.leaveGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source, ChannelPromise future)
在指定的接口上使用指定的源保留指定的多播组,并在操作完成后通知 ChannelFuture 。
|
ChannelFuture |
DatagramChannel.leaveGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface)
在指定的本地接口上留下多播组,并在操作完成后通知 ChannelFuture 。
|
ChannelFuture |
DatagramChannel.leaveGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface, ChannelPromise future)
在指定的本地接口上留下多播组,并在操作完成后通知 ChannelFuture 。
|
ChannelFuture |
DuplexChannel.shutdown()
将关闭此通道的输入和输出端。
|
ChannelFuture |
DuplexChannel.shutdown(ChannelPromise promise)
将关闭此通道的输入和输出端。
|
ChannelFuture |
DuplexChannel.shutdownInput() |
ChannelFuture |
DuplexChannel.shutdownInput(ChannelPromise promise)
将关闭输入并通知 ChannelPromise 。
|
ChannelFuture |
DuplexChannel.shutdownOutput() |
ChannelFuture |
DuplexChannel.shutdownOutput(ChannelPromise promise)
将关闭输出并通知 ChannelPromise 。
|
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
NioDatagramChannel.block(java.net.InetAddress multicastAddress, java.net.InetAddress sourceToBlock)
阻止给定多播地址的给定sourceToBlock地址
|
ChannelFuture |
NioDatagramChannel.block(java.net.InetAddress multicastAddress, java.net.InetAddress sourceToBlock, ChannelPromise promise)
阻止给定多播地址的给定sourceToBlock地址
|
ChannelFuture |
NioDatagramChannel.block(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress sourceToBlock)
阻止给定networkInterface上给定多播地址的给定sourceToBlock地址
|
ChannelFuture |
NioDatagramChannel.block(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress sourceToBlock, ChannelPromise promise)
阻止给定networkInterface上给定多播地址的给定sourceToBlock地址
|
ChannelFuture |
NioDatagramChannel.joinGroup(java.net.InetAddress multicastAddress) |
ChannelFuture |
NioDatagramChannel.joinGroup(java.net.InetAddress multicastAddress, ChannelPromise promise) |
ChannelFuture |
NioDatagramChannel.joinGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source) |
ChannelFuture |
NioDatagramChannel.joinGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source, ChannelPromise promise) |
ChannelFuture |
NioDatagramChannel.joinGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface) |
ChannelFuture |
NioDatagramChannel.joinGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface, ChannelPromise promise) |
ChannelFuture |
NioDatagramChannel.leaveGroup(java.net.InetAddress multicastAddress) |
ChannelFuture |
NioDatagramChannel.leaveGroup(java.net.InetAddress multicastAddress, ChannelPromise promise) |
ChannelFuture |
NioDatagramChannel.leaveGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source) |
ChannelFuture |
NioDatagramChannel.leaveGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source, ChannelPromise promise) |
ChannelFuture |
NioDatagramChannel.leaveGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface) |
ChannelFuture |
NioDatagramChannel.leaveGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface, ChannelPromise promise) |
ChannelFuture |
NioSocketChannel.shutdown() |
ChannelFuture |
NioSocketChannel.shutdown(ChannelPromise promise) |
ChannelFuture |
NioSocketChannel.shutdownInput() |
ChannelFuture |
NioSocketChannel.shutdownInput(ChannelPromise promise) |
ChannelFuture |
NioSocketChannel.shutdownOutput() |
ChannelFuture |
NioSocketChannel.shutdownOutput(ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
OioDatagramChannel.block(java.net.InetAddress multicastAddress, java.net.InetAddress sourceToBlock) |
ChannelFuture |
OioDatagramChannel.block(java.net.InetAddress multicastAddress, java.net.InetAddress sourceToBlock, ChannelPromise promise) |
ChannelFuture |
OioDatagramChannel.block(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress sourceToBlock) |
ChannelFuture |
OioDatagramChannel.block(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress sourceToBlock, ChannelPromise promise) |
ChannelFuture |
OioDatagramChannel.joinGroup(java.net.InetAddress multicastAddress) |
ChannelFuture |
OioDatagramChannel.joinGroup(java.net.InetAddress multicastAddress, ChannelPromise promise) |
ChannelFuture |
OioDatagramChannel.joinGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source) |
ChannelFuture |
OioDatagramChannel.joinGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source, ChannelPromise promise) |
ChannelFuture |
OioDatagramChannel.joinGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface) |
ChannelFuture |
OioDatagramChannel.joinGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface, ChannelPromise promise) |
ChannelFuture |
OioDatagramChannel.leaveGroup(java.net.InetAddress multicastAddress) |
ChannelFuture |
OioDatagramChannel.leaveGroup(java.net.InetAddress multicastAddress, ChannelPromise promise) |
ChannelFuture |
OioDatagramChannel.leaveGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source) |
ChannelFuture |
OioDatagramChannel.leaveGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source, ChannelPromise promise) |
ChannelFuture |
OioDatagramChannel.leaveGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface) |
ChannelFuture |
OioDatagramChannel.leaveGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface, ChannelPromise promise) |
ChannelFuture |
OioSocketChannel.shutdown() |
ChannelFuture |
OioSocketChannel.shutdown(ChannelPromise promise) |
ChannelFuture |
OioSocketChannel.shutdownInput() |
ChannelFuture |
OioSocketChannel.shutdownInput(ChannelPromise promise) |
ChannelFuture |
OioSocketChannel.shutdownOutput() |
ChannelFuture |
OioSocketChannel.shutdownOutput(ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
protected ChannelFuture |
NioUdtByteConnectorChannel.shutdownInput()
已过时。
|
Modifier and Type | Method and Description |
---|---|
abstract ChannelFuture |
ZlibEncoder.close()
关闭此 ZlibEncoder 并完成编码。
|
ChannelFuture |
Lz4FrameEncoder.close()
关闭此 Lz4FrameEncoder 并完成编码。
|
ChannelFuture |
JdkZlibEncoder.close() |
ChannelFuture |
JZlibEncoder.close() |
ChannelFuture |
Bzip2Encoder.close()
关闭这个 Bzip2Encoder 并完成编码。
|
abstract ChannelFuture |
ZlibEncoder.close(ChannelPromise promise)
关闭此 ZlibEncoder 并完成编码。
|
ChannelFuture |
Lz4FrameEncoder.close(ChannelPromise promise)
关闭这个 Lz4FrameEncoder ,完成编码。
|
ChannelFuture |
JdkZlibEncoder.close(ChannelPromise promise) |
ChannelFuture |
JZlibEncoder.close(ChannelPromise promise) |
ChannelFuture |
Bzip2Encoder.close(ChannelPromise promise)
关闭此 Bzip2Encoder 并完成编码。
|
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
WebSocketServerHandshaker.close(Channel channel, CloseWebSocketFrame frame)
执行关闭握手
|
ChannelFuture |
WebSocketClientHandshaker.close(Channel channel, CloseWebSocketFrame frame)
执行关闭握手
|
ChannelFuture |
WebSocketServerHandshaker00.close(Channel channel, CloseWebSocketFrame frame, ChannelPromise promise)
回显结束帧
|
ChannelFuture |
WebSocketServerHandshaker.close(Channel channel, CloseWebSocketFrame frame, ChannelPromise promise)
执行关闭握手
|
ChannelFuture |
WebSocketClientHandshaker.close(Channel channel, CloseWebSocketFrame frame, ChannelPromise promise)
执行关闭握手
|
ChannelFuture |
WebSocketClientHandshaker.handshake(Channel channel)
开始握手
|
ChannelFuture |
WebSocketClientHandshaker.handshake(Channel channel, ChannelPromise promise)
开始握手
|
ChannelFuture |
WebSocketServerHandshaker.handshake(Channel channel, FullHttpRequest req)
执行开始握手。
|
ChannelFuture |
WebSocketServerHandshaker.handshake(Channel channel, FullHttpRequest req, HttpHeaders responseHeaders, ChannelPromise promise)
执行打开握手当调用此方法必须不保留 FullHttpRequest 这是在过去。
|
ChannelFuture |
WebSocketServerHandshaker.handshake(Channel channel, HttpRequest req)
执行开启握手。
|
ChannelFuture |
WebSocketServerHandshaker.handshake(Channel channel, HttpRequest req, HttpHeaders responseHeaders, ChannelPromise promise)
执行打开握手当调用此方法必须不保留 HttpRequest 这是在过去。
|
ChannelFuture |
WebSocketClientHandshaker.processHandshake(Channel channel, HttpResponse response)
|
ChannelFuture |
WebSocketClientHandshaker.processHandshake(Channel channel, HttpResponse response, ChannelPromise promise)
|
static ChannelFuture |
WebSocketServerHandshakerFactory.sendUnsupportedVersionResponse(Channel channel)
我们需要的返回不能支持Web套接字版本
|
static ChannelFuture |
WebSocketServerHandshakerFactory.sendUnsupportedVersionResponse(Channel channel, ChannelPromise promise)
我们需要的返回不能支持Web套接字版本
|
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
Http2LifecycleManager.goAway(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise)
如果
errorCode 不是
Http2Error.NO_ERROR ,则阻止对等方创建流并关闭连接。
|
ChannelFuture |
Http2ConnectionHandler.goAway(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise) |
ChannelFuture |
Http2LifecycleManager.resetStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise)
确保重置由
streamId 标识的流。
|
ChannelFuture |
Http2ConnectionHandler.resetStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise) |
ChannelFuture |
StreamBufferingEncoder.writeData(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endOfStream, ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeData(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endStream, ChannelPromise promise) |
ChannelFuture |
Http2DataWriter.writeData(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endStream, ChannelPromise promise)
将
DATA 帧写入远程端点。
|
ChannelFuture |
DefaultHttp2FrameWriter.writeData(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endStream, ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeData(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endOfStream, ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeData(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endStream, ChannelPromise promise) |
ChannelFuture |
CompressorHttp2ConnectionEncoder.writeData(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endOfStream, ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeFrame(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload, ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeFrame(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload, ChannelPromise promise)
任何HTTP / 2帧的通用写入方法。
|
ChannelFuture |
Http2ConnectionEncoder.writeFrame(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload, ChannelPromise promise)
将给定的数据写入内部 Http2FrameWriter ,而不对连接/流执行任何状态检查。
|
ChannelFuture |
DefaultHttp2FrameWriter.writeFrame(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload, ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeFrame(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload, ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeFrame(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload, ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeGoAway(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeGoAway(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise)
将GO_AWAY帧写入远程端点。
|
ChannelFuture |
DefaultHttp2FrameWriter.writeGoAway(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeGoAway(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeGoAway(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise) |
ChannelFuture |
StreamBufferingEncoder.writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise)
将HEADERS帧写入远程端点。
|
ChannelFuture |
DefaultHttp2FrameWriter.writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise) |
ChannelFuture |
CompressorHttp2ConnectionEncoder.writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise) |
ChannelFuture |
StreamBufferingEncoder.writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream, ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endStream, ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endStream, ChannelPromise promise)
将指定优先级的HEADERS帧写入远程端点。
|
ChannelFuture |
DefaultHttp2FrameWriter.writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endStream, ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream, ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endStream, ChannelPromise promise) |
ChannelFuture |
CompressorHttp2ConnectionEncoder.writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream, ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writePing(ChannelHandlerContext ctx, boolean ack, long data, ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writePing(ChannelHandlerContext ctx, boolean ack, long data, ChannelPromise promise)
将PING帧写入远程端点。
|
ChannelFuture |
DefaultHttp2FrameWriter.writePing(ChannelHandlerContext ctx, boolean ack, long data, ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writePing(ChannelHandlerContext ctx, boolean ack, long data, ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writePing(ChannelHandlerContext ctx, boolean ack, long data, ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writePriority(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive, ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writePriority(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive, ChannelPromise promise)
将PRIORITY帧写入远程端点。
|
ChannelFuture |
DefaultHttp2FrameWriter.writePriority(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive, ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writePriority(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive, ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writePriority(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive, ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writePushPromise(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding, ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writePushPromise(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding, ChannelPromise promise)
将PUSH_PROMISE帧写入远程端点。
|
ChannelFuture |
DefaultHttp2FrameWriter.writePushPromise(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding, ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writePushPromise(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding, ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writePushPromise(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding, ChannelPromise promise) |
ChannelFuture |
StreamBufferingEncoder.writeRstStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeRstStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeRstStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise)
将RST_STREAM帧写入远程端点。
|
ChannelFuture |
DefaultHttp2FrameWriter.writeRstStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeRstStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeRstStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeSettings(ChannelHandlerContext ctx, Http2Settings settings, ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeSettings(ChannelHandlerContext ctx, Http2Settings settings, ChannelPromise promise)
将一个SETTINGS帧写入远程端点。
|
ChannelFuture |
DefaultHttp2FrameWriter.writeSettings(ChannelHandlerContext ctx, Http2Settings settings, ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeSettings(ChannelHandlerContext ctx, Http2Settings settings, ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeSettings(ChannelHandlerContext ctx, Http2Settings settings, ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeSettingsAck(ChannelHandlerContext ctx, ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeSettingsAck(ChannelHandlerContext ctx, ChannelPromise promise)
将SETTINGS确认写入远程端点。
|
ChannelFuture |
DefaultHttp2FrameWriter.writeSettingsAck(ChannelHandlerContext ctx, ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeSettingsAck(ChannelHandlerContext ctx, ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeSettingsAck(ChannelHandlerContext ctx, ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeWindowUpdate(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement, ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeWindowUpdate(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement, ChannelPromise promise)
将WINDOW_UPDATE帧写入远程端点。
|
ChannelFuture |
DefaultHttp2FrameWriter.writeWindowUpdate(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement, ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeWindowUpdate(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement, ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeWindowUpdate(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement, ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
void |
Http2LifecycleManager.closeStream(Http2Stream stream, ChannelFuture future)
关闭并停用给定的
stream 。
|
void |
Http2ConnectionHandler.closeStream(Http2Stream stream, ChannelFuture future) |
void |
Http2LifecycleManager.closeStreamLocal(Http2Stream stream, ChannelFuture future)
关闭
stream 的本地端。
|
void |
Http2ConnectionHandler.closeStreamLocal(Http2Stream stream, ChannelFuture future)
关闭给定流的本地侧。
|
void |
Http2LifecycleManager.closeStreamRemote(Http2Stream stream, ChannelFuture future)
关闭
stream 的远程端。
|
void |
Http2ConnectionHandler.closeStreamRemote(Http2Stream stream, ChannelFuture future)
关闭给定流的远程端。
|
void |
DefaultHttp2ConnectionEncoder.FlowControlledBase.operationComplete(ChannelFuture future) |
Modifier and Type | Method and Description |
---|---|
protected ChannelFuture |
AbstractRemoteAddressFilter.channelRejected(ChannelHandlerContext ctx, T remoteAddress)
如果这种方法被称为
remoteAddress 被否决
AbstractRemoteAddressFilter.accept(ChannelHandlerContext, SocketAddress) 。
|
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
SslHandler.close()
|
ChannelFuture |
SslHandler.close(ChannelPromise promise)
|
Modifier and Type | Method and Description |
---|---|
void |
DnsQueryLifecycleObserver.queryWritten(java.net.InetSocketAddress dnsServerAddress, ChannelFuture future)
查询已写入。
|
void |
BiDnsQueryLifecycleObserver.queryWritten(java.net.InetSocketAddress dnsServerAddress, ChannelFuture future) |
Copyright © 2008–2018 The Netty Project. All rights reserved.