软件包 | 描述 |
---|---|
io.netty.channel |
核心通道API是异步和事件驱动的各种传输(如
NIO Channel)的抽象 。
|
io.netty.channel.group |
通道注册表,帮助用户维护打开的 Channel 的列表并对其执行批量操作。
|
io.netty.channel.pool |
Channel 池的实现和API。
|
io.netty.handler.codec.http2 |
用于发送和接收HTTP / 2帧的处理程序。
|
io.netty.handler.proxy |
通过代理协议(如
SOCKS和
HTTP CONNECT tunneling)添加对客户端连接的支持
|
io.netty.handler.ssl |
SSL · TLS实施依据
SSLEngine
|
io.netty.resolver |
将表示端点名称的任意字符串解析为地址。
|
io.netty.resolver.dns |
Java的内置域名查找机制的一种替代方法,可以异步解析域名,同样支持任意DNS记录类型的查询。
|
io.netty.util |
在多个包中使用的实用程序类。
|
io.netty.util.concurrent |
并发/异步任务的实用程序类。
|
Modifier and Type | Interface and Description |
---|---|
interface |
ChannelFuture
异步 Channel I / O操作的结果。
|
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 |
---|---|
Future<?> |
ThreadPerChannelEventLoopGroup.shutdownGracefully(long quietPeriod, long timeout, java.util.concurrent.TimeUnit unit) |
Future<?> |
ThreadPerChannelEventLoopGroup.terminationFuture() |
Modifier and Type | Method and Description |
---|---|
VoidChannelPromise |
VoidChannelPromise.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelPromise |
DelegatingChannelPromiseNotifier.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelPromise |
DefaultChannelPromise.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelProgressivePromise |
DefaultChannelProgressivePromise.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelPromise |
ChannelPromise.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelProgressivePromise |
ChannelProgressivePromise.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelProgressiveFuture |
ChannelProgressiveFuture.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelFuture |
ChannelFuture.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
VoidChannelPromise |
VoidChannelPromise.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelPromise |
DelegatingChannelPromiseNotifier.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelPromise |
DefaultChannelPromise.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelProgressivePromise |
DefaultChannelProgressivePromise.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelPromise |
ChannelPromise.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelProgressivePromise |
ChannelProgressivePromise.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelProgressiveFuture |
ChannelProgressiveFuture.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelFuture |
ChannelFuture.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
Modifier and Type | Interface and Description |
---|---|
interface |
ChannelGroupFuture
异步 ChannelGroup 操作的结果。
|
Modifier and Type | Method and Description |
---|---|
ChannelGroupFuture |
ChannelGroupFuture.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelGroupFuture |
ChannelGroupFuture.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
Modifier and Type | Method and Description |
---|---|
Future<Channel> |
SimpleChannelPool.acquire() |
Future<Channel> |
ChannelPool.acquire()
获得 Channel 从这个ChannelPool 。
|
Future<Channel> |
SimpleChannelPool.acquire(Promise<Channel> promise) |
Future<Channel> |
FixedChannelPool.acquire(Promise<Channel> promise) |
Future<Channel> |
ChannelPool.acquire(Promise<Channel> promise)
获得 Channel 从这个ChannelPool 。
|
Future<java.lang.Boolean> |
ChannelHealthChecker.isHealthy(Channel channel)
检查给定通道是否健康,这意味着它可以被使用。
|
Future<java.lang.Void> |
SimpleChannelPool.release(Channel channel) |
Future<java.lang.Void> |
ChannelPool.release(Channel channel)
释放一个 Channel 回到这个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)
释放一个 Channel 回到这个ChannelPool 。
|
Modifier and Type | Method and Description |
---|---|
Future<java.lang.Void> |
Http2Connection.close(Promise<java.lang.Void> promise)
关闭此连接。
|
Future<java.lang.Void> |
DefaultHttp2Connection.close(Promise<java.lang.Void> promise) |
Future<Http2StreamChannel> |
Http2StreamChannelBootstrap.open() |
Future<Http2StreamChannel> |
Http2StreamChannelBootstrap.open(Promise<Http2StreamChannel> promise) |
Modifier and Type | Method and Description |
---|---|
Future<Channel> |
ProxyHandler.connectFuture()
返回到目标连接已建立或连接尝试失败时通知的 Future 。
|
Modifier and Type | Method and Description |
---|---|
Future<Channel> |
SslHandler.handshakeFuture()
返回一个当前TLS握手完成后会通知的 Future 。
|
protected Future<SslContext> |
SniHandler.lookup(ChannelHandlerContext ctx, java.lang.String hostname)
默认实现将简单地调用
AsyncMapping.map(Object, Promise) ,但用户可以重写此方法来实现自定义行为。
|
protected abstract Future<T> |
AbstractSniHandler.lookup(ChannelHandlerContext ctx, java.lang.String hostname)
开始查找给定的SNI值并返回一个 Future ,这反过来会在完成时通知AbstractSniHandler.onLookupComplete(ChannelHandlerContext, String, Future) 。
|
Future<Channel> |
SslHandler.renegotiate()
执行TLS重新协商。
|
Future<Channel> |
SslHandler.renegotiate(Promise<Channel> promise)
执行TLS重新协商。
|
Future<Channel> |
SslHandler.sslCloseFuture()
返回 Future ,如果SSLEngine 的入站已关闭,将会收到通知。
|
Modifier and Type | Method and Description |
---|---|
protected void |
SniHandler.onLookupComplete(ChannelHandlerContext ctx, java.lang.String hostname, Future<SslContext> future) |
protected abstract void |
AbstractSniHandler.onLookupComplete(ChannelHandlerContext ctx, java.lang.String hostname, Future<T> future)
|
Modifier and Type | Method and Description |
---|---|
Future<T> |
AddressResolver.resolve(java.net.SocketAddress address)
解析指定的地址。
|
Future<T> |
AbstractAddressResolver.resolve(java.net.SocketAddress address) |
Future<T> |
AddressResolver.resolve(java.net.SocketAddress address, Promise<T> promise)
解析指定的地址。
|
Future<T> |
AbstractAddressResolver.resolve(java.net.SocketAddress address, Promise<T> promise) |
Future<T> |
SimpleNameResolver.resolve(java.lang.String inetHost) |
Future<T> |
NameResolver.resolve(java.lang.String inetHost)
将指定的名称解析为地址。
|
Future<T> |
SimpleNameResolver.resolve(java.lang.String inetHost, Promise<T> promise) |
Future<T> |
NameResolver.resolve(java.lang.String inetHost, Promise<T> promise)
将指定的名称解析为地址。
|
Future<java.util.List<T>> |
AddressResolver.resolveAll(java.net.SocketAddress address)
解析指定的地址。
|
Future<java.util.List<T>> |
AbstractAddressResolver.resolveAll(java.net.SocketAddress address) |
Future<java.util.List<T>> |
AddressResolver.resolveAll(java.net.SocketAddress address, Promise<java.util.List<T>> promise)
解析指定的地址。
|
Future<java.util.List<T>> |
AbstractAddressResolver.resolveAll(java.net.SocketAddress address, Promise<java.util.List<T>> promise) |
Future<java.util.List<T>> |
SimpleNameResolver.resolveAll(java.lang.String inetHost) |
Future<java.util.List<T>> |
NameResolver.resolveAll(java.lang.String inetHost)
将指定的主机名和端口解析为地址列表。
|
Future<java.util.List<T>> |
SimpleNameResolver.resolveAll(java.lang.String inetHost, Promise<java.util.List<T>> promise) |
Future<java.util.List<T>> |
NameResolver.resolveAll(java.lang.String inetHost, Promise<java.util.List<T>> promise)
将指定的主机名和端口解析为地址列表。
|
Modifier and Type | Method and Description |
---|---|
Future<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> |
DnsNameResolver.query(DnsQuestion question)
用指定的问题发送DNS查询。
|
Future<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> |
DnsNameResolver.query(DnsQuestion question, java.lang.Iterable<DnsRecord> additionals)
用指定的问题发送带有附加记录的DNS查询。
|
Future<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> |
DnsNameResolver.query(DnsQuestion question, Promise<AddressedEnvelope<? extends DnsResponse,java.net.InetSocketAddress>> promise)
用指定的问题发送DNS查询。
|
Future<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> |
DnsNameResolver.query(java.net.InetSocketAddress nameServerAddr, DnsQuestion question)
使用指定的名称服务器列表发送包含指定问题的DNS查询。
|
Future<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> |
DnsNameResolver.query(java.net.InetSocketAddress nameServerAddr, DnsQuestion question, java.lang.Iterable<DnsRecord> additionals)
使用指定的名称服务器列表发送带有指定问题的DNS查询以及其他记录。
|
Future<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> |
DnsNameResolver.query(java.net.InetSocketAddress nameServerAddr, DnsQuestion question, java.lang.Iterable<DnsRecord> additionals, Promise<AddressedEnvelope<? extends DnsResponse,java.net.InetSocketAddress>> promise)
使用指定的名称服务器列表发送带有指定问题的DNS查询以及其他记录。
|
Future<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> |
DnsNameResolver.query(java.net.InetSocketAddress nameServerAddr, DnsQuestion question, Promise<AddressedEnvelope<? extends DnsResponse,java.net.InetSocketAddress>> promise)
使用指定的名称服务器列表发送包含指定问题的DNS查询。
|
Future<java.net.InetAddress> |
DnsNameResolver.resolve(java.lang.String inetHost, java.lang.Iterable<DnsRecord> additionals)
将指定的名称解析为地址。
|
Future<java.net.InetAddress> |
DnsNameResolver.resolve(java.lang.String inetHost, java.lang.Iterable<DnsRecord> additionals, Promise<java.net.InetAddress> promise)
将指定的名称解析为地址。
|
Future<java.util.List<java.net.InetAddress>> |
DnsNameResolver.resolveAll(java.lang.String inetHost, java.lang.Iterable<DnsRecord> additionals)
将指定的主机名和端口解析为地址列表。
|
Future<java.util.List<java.net.InetAddress>> |
DnsNameResolver.resolveAll(java.lang.String inetHost, java.lang.Iterable<DnsRecord> additionals, Promise<java.util.List<java.net.InetAddress>> promise)
将指定的主机名和端口解析为地址列表。
|
Modifier and Type | Method and Description |
---|---|
Future<OUT> |
AsyncMapping.map(IN input, Promise<OUT> promise)
返回将提供映射结果的 Future 。
|
Modifier and Type | Interface and Description |
---|---|
interface |
GenericFutureListener<F extends Future<?>>
听取 Future 的结果。
|
class |
PromiseAggregator<V,F extends Future<V>>
已过时。
使用
PromiseCombiner GenericFutureListener 实现,通过监听单个Future s并在所有Future 完成时产生聚合结果(成功/失败),将多个Future 合并为一个。
|
class |
PromiseNotifier<V,F extends Future<V>>
GenericFutureListener 执行其他Promise s并在完成时通知他们。
|
Modifier and Type | Interface and Description |
---|---|
interface |
ProgressiveFuture<V>
A Future ,用于指示操作的进度。
|
interface |
ProgressivePromise<V>
特别 ProgressiveFuture 这是可写的。
|
interface |
Promise<V>
特别 Future 这是可写的。
|
interface |
ScheduledFuture<V>
预定的异步操作的结果。
|
Modifier and Type | Class and Description |
---|---|
class |
DefaultProgressivePromise<V> |
class |
DefaultPromise<V> |
Modifier and Type | Method and Description |
---|---|
Future<V> |
Future.addListener(GenericFutureListener<? extends Future<? super V>> listener)
将指定的侦听器添加到此将来。
|
Future<V> |
CompleteFuture.addListener(GenericFutureListener<? extends Future<? super V>> listener) |
Future<V> |
Future.addListeners(GenericFutureListener<? extends Future<? super V>>... listeners)
将指定的侦听器添加到此将来。
|
Future<V> |
CompleteFuture.addListeners(GenericFutureListener<? extends Future<? super V>>... listeners) |
Future<V> |
Future.await()
等待这个未来的完成。
|
Future<V> |
CompleteFuture.await() |
Future<V> |
Future.awaitUninterruptibly()
等待这个未来不中断地完成。
|
Future<V> |
CompleteFuture.awaitUninterruptibly() |
<V> Future<V> |
UnorderedThreadPoolEventExecutor.newFailedFuture(java.lang.Throwable cause) |
<V> Future<V> |
EventExecutor.newFailedFuture(java.lang.Throwable cause)
|
<V> Future<V> |
AbstractEventExecutor.newFailedFuture(java.lang.Throwable cause) |
<V> Future<V> |
UnorderedThreadPoolEventExecutor.newSucceededFuture(V result) |
<V> Future<V> |
EventExecutor.newSucceededFuture(V result)
|
<V> Future<V> |
AbstractEventExecutor.newSucceededFuture(V result) |
Future<V> |
Future.removeListener(GenericFutureListener<? extends Future<? super V>> listener)
从此将来删除指定侦听器的第一个匹配项。
|
Future<V> |
CompleteFuture.removeListener(GenericFutureListener<? extends Future<? super V>> listener) |
Future<V> |
Future.removeListeners(GenericFutureListener<? extends Future<? super V>>... listeners)
为将来的每个听众删除第一个匹配项。
|
Future<V> |
CompleteFuture.removeListeners(GenericFutureListener<? extends Future<? super V>>... listeners) |
Future<?> |
UnorderedThreadPoolEventExecutor.shutdownGracefully() |
Future<?> |
NonStickyEventExecutorGroup.shutdownGracefully() |
Future<?> |
EventExecutorGroup.shutdownGracefully()
|
Future<?> |
AbstractEventExecutorGroup.shutdownGracefully() |
Future<?> |
AbstractEventExecutor.shutdownGracefully() |
Future<?> |
UnorderedThreadPoolEventExecutor.shutdownGracefully(long quietPeriod, long timeout, java.util.concurrent.TimeUnit unit) |
Future<?> |
SingleThreadEventExecutor.shutdownGracefully(long quietPeriod, long timeout, java.util.concurrent.TimeUnit unit) |
Future<?> |
NonStickyEventExecutorGroup.shutdownGracefully(long quietPeriod, long timeout, java.util.concurrent.TimeUnit unit) |
Future<?> |
MultithreadEventExecutorGroup.shutdownGracefully(long quietPeriod, long timeout, java.util.concurrent.TimeUnit unit) |
Future<?> |
ImmediateEventExecutor.shutdownGracefully(long quietPeriod, long timeout, java.util.concurrent.TimeUnit unit) |
Future<?> |
GlobalEventExecutor.shutdownGracefully(long quietPeriod, long timeout, java.util.concurrent.TimeUnit unit) |
Future<?> |
EventExecutorGroup.shutdownGracefully(long quietPeriod, long timeout, java.util.concurrent.TimeUnit unit)
该执行者表示该调用者希望执行者被关闭。
|
<T> Future<T> |
UnorderedThreadPoolEventExecutor.submit(java.util.concurrent.Callable<T> task) |
<T> Future<T> |
NonStickyEventExecutorGroup.submit(java.util.concurrent.Callable<T> task) |
<T> Future<T> |
EventExecutorGroup.submit(java.util.concurrent.Callable<T> task) |
<T> Future<T> |
AbstractEventExecutorGroup.submit(java.util.concurrent.Callable<T> task) |
<T> Future<T> |
AbstractEventExecutor.submit(java.util.concurrent.Callable<T> task) |
Future<?> |
UnorderedThreadPoolEventExecutor.submit(java.lang.Runnable task) |
Future<?> |
NonStickyEventExecutorGroup.submit(java.lang.Runnable task) |
Future<?> |
EventExecutorGroup.submit(java.lang.Runnable task) |
Future<?> |
AbstractEventExecutorGroup.submit(java.lang.Runnable task) |
Future<?> |
AbstractEventExecutor.submit(java.lang.Runnable task) |
<T> Future<T> |
UnorderedThreadPoolEventExecutor.submit(java.lang.Runnable task, T result) |
<T> Future<T> |
NonStickyEventExecutorGroup.submit(java.lang.Runnable task, T result) |
<T> Future<T> |
EventExecutorGroup.submit(java.lang.Runnable task, T result) |
<T> Future<T> |
AbstractEventExecutorGroup.submit(java.lang.Runnable task, T result) |
<T> Future<T> |
AbstractEventExecutor.submit(java.lang.Runnable task, T result) |
Future<V> |
Future.sync()
等待这个未来,直到完成,并且在这个未来失败的时候重新引发失败的原因。
|
Future<V> |
FailedFuture.sync() |
Future<V> |
CompleteFuture.sync() |
Future<V> |
Future.syncUninterruptibly()
等待这个未来,直到完成,并且在这个未来失败的时候重新引发失败的原因。
|
Future<V> |
FailedFuture.syncUninterruptibly() |
Future<V> |
CompleteFuture.syncUninterruptibly() |
Future<?> |
UnorderedThreadPoolEventExecutor.terminationFuture() |
Future<?> |
SingleThreadEventExecutor.terminationFuture() |
Future<?> |
NonStickyEventExecutorGroup.terminationFuture() |
Future<?> |
MultithreadEventExecutorGroup.terminationFuture() |
Future<?> |
ImmediateEventExecutor.terminationFuture() |
Future<?> |
GlobalEventExecutor.terminationFuture() |
Future<?> |
EventExecutorGroup.terminationFuture()
返回 Future 当所有被通知EventExecutor 由该被管小号EventExecutorGroup 已经终止。
|
Modifier and Type | Method and Description |
---|---|
void |
PromiseCombiner.add(Future future)
添加了一个新的未来。
|
void |
PromiseCombiner.addAll(Future... futures)
增加新的期货合并。
|
static <X> void |
UnaryPromiseNotifier.cascadeTo(Future<X> completedFuture, Promise<? super X> promise) |
protected static void |
DefaultPromise.notifyListener(EventExecutor eventExecutor, Future<?> future, GenericFutureListener<?> listener)
通知听众未来已完成。
|
void |
UnaryPromiseNotifier.operationComplete(Future<T> future) |
Modifier and Type | Method and Description |
---|---|
Promise<V> |
Promise.addListener(GenericFutureListener<? extends Future<? super V>> listener) |
ProgressivePromise<V> |
ProgressivePromise.addListener(GenericFutureListener<? extends Future<? super V>> listener) |
ProgressiveFuture<V> |
ProgressiveFuture.addListener(GenericFutureListener<? extends Future<? super V>> listener) |
Future<V> |
Future.addListener(GenericFutureListener<? extends Future<? super V>> listener)
将指定的侦听器添加到此将来。
|
Promise<V> |
DefaultPromise.addListener(GenericFutureListener<? extends Future<? super V>> listener) |
ProgressivePromise<V> |
DefaultProgressivePromise.addListener(GenericFutureListener<? extends Future<? super V>> listener) |
Future<V> |
CompleteFuture.addListener(GenericFutureListener<? extends Future<? super V>> listener) |
Promise<V> |
Promise.removeListener(GenericFutureListener<? extends Future<? super V>> listener) |
ProgressivePromise<V> |
ProgressivePromise.removeListener(GenericFutureListener<? extends Future<? super V>> listener) |
ProgressiveFuture<V> |
ProgressiveFuture.removeListener(GenericFutureListener<? extends Future<? super V>> listener) |
Future<V> |
Future.removeListener(GenericFutureListener<? extends Future<? super V>> listener)
从此将来删除指定侦听器的第一个匹配项。
|
Promise<V> |
DefaultPromise.removeListener(GenericFutureListener<? extends Future<? super V>> listener) |
ProgressivePromise<V> |
DefaultProgressivePromise.removeListener(GenericFutureListener<? extends Future<? super V>> listener) |
Future<V> |
CompleteFuture.removeListener(GenericFutureListener<? extends Future<? super V>> listener) |
Copyright © 2008–2018 The Netty Project. All rights reserved.