软件包 | 描述 |
---|---|
io.netty.channel |
核心通道API是异步和事件驱动的各种传输(如
NIO Channel)的抽象 。
|
io.netty.channel.pool |
Channel 池的实现和API。
|
io.netty.handler.codec.http2 |
用于发送和接收HTTP / 2帧的处理程序。
|
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 |
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<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.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(Promise<Http2StreamChannel> promise) |
void |
Http2StreamChannelBootstrap.open0(ChannelHandlerContext ctx, Promise<Http2StreamChannel> promise) |
Modifier and Type | Method and Description |
---|---|
Future<Channel> |
SslHandler.renegotiate(Promise<Channel> promise)
执行TLS重新协商。
|
Modifier and Type | Method and Description |
---|---|
protected void |
InetSocketAddressResolver.doResolve(java.net.InetSocketAddress unresolvedAddress, Promise<java.net.InetSocketAddress> promise) |
protected void |
NoopAddressResolver.doResolve(java.net.SocketAddress unresolvedAddress, Promise<java.net.SocketAddress> promise) |
protected void |
RoundRobinInetAddressResolver.doResolve(java.lang.String inetHost, Promise<java.net.InetAddress> promise) |
protected void |
DefaultNameResolver.doResolve(java.lang.String inetHost, Promise<java.net.InetAddress> promise) |
protected abstract void |
SimpleNameResolver.doResolve(java.lang.String inetHost, Promise<T> promise)
由
SimpleNameResolver.resolve(String) 调用来执行实际的名称解析。
|
protected void |
CompositeNameResolver.doResolve(java.lang.String inetHost, Promise<T> promise) |
protected abstract void |
AbstractAddressResolver.doResolve(T unresolvedAddress, Promise<T> promise)
由
AbstractAddressResolver.resolve(SocketAddress) 调用来执行实际的名称解析。
|
protected void |
InetSocketAddressResolver.doResolveAll(java.net.InetSocketAddress unresolvedAddress, Promise<java.util.List<java.net.InetSocketAddress>> promise) |
protected void |
NoopAddressResolver.doResolveAll(java.net.SocketAddress unresolvedAddress, Promise<java.util.List<java.net.SocketAddress>> promise) |
protected void |
RoundRobinInetAddressResolver.doResolveAll(java.lang.String inetHost, Promise<java.util.List<java.net.InetAddress>> promise) |
protected void |
DefaultNameResolver.doResolveAll(java.lang.String inetHost, Promise<java.util.List<java.net.InetAddress>> promise) |
protected abstract void |
SimpleNameResolver.doResolveAll(java.lang.String inetHost, Promise<java.util.List<T>> promise)
由
SimpleNameResolver.resolveAll(String) 调用来执行实际的名称解析。
|
protected void |
CompositeNameResolver.doResolveAll(java.lang.String inetHost, Promise<java.util.List<T>> promise) |
protected abstract void |
AbstractAddressResolver.doResolveAll(T unresolvedAddress, Promise<java.util.List<T>> promise)
由
AbstractAddressResolver.resolveAll(SocketAddress) 调用来执行实际的名称解析。
|
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, 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, 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, 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 |
---|---|
protected void |
DnsNameResolver.doResolve(java.lang.String inetHost, DnsRecord[] additionals, Promise<java.net.InetAddress> promise, DnsCache resolveCache)
Hook专为扩展性而设计,因此可以在每次分辨率尝试时传递不同的缓存,而不是使用全局分辨率。
|
protected void |
DnsNameResolver.doResolve(java.lang.String inetHost, Promise<java.net.InetAddress> promise) |
protected void |
DnsNameResolver.doResolveAll(java.lang.String inetHost, DnsRecord[] additionals, Promise<java.util.List<java.net.InetAddress>> promise, DnsCache resolveCache)
Hook专为扩展性而设计,因此可以在每次分辨率尝试时传递不同的缓存,而不是使用全局分辨率。
|
protected void |
DnsNameResolver.doResolveAll(java.lang.String inetHost, Promise<java.util.List<java.net.InetAddress>> promise) |
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, 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, Promise<java.net.InetAddress> promise)
将指定的名称解析为地址。
|
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 |
ProgressivePromise<V>
特别 ProgressiveFuture 这是可写的。
|
Modifier and Type | Class and Description |
---|---|
class |
DefaultProgressivePromise<V> |
class |
DefaultPromise<V> |
Modifier and Type | Method and Description |
---|---|
Promise<V> |
Promise.addListener(GenericFutureListener<? extends Future<? super V>> listener) |
Promise<V> |
DefaultPromise.addListener(GenericFutureListener<? extends Future<? super V>> listener) |
Promise<V> |
Promise.addListeners(GenericFutureListener<? extends Future<? super V>>... listeners) |
Promise<V> |
DefaultPromise.addListeners(GenericFutureListener<? extends Future<? super V>>... listeners) |
Promise<V> |
Promise.await() |
Promise<V> |
DefaultPromise.await() |
Promise<V> |
Promise.awaitUninterruptibly() |
Promise<V> |
DefaultPromise.awaitUninterruptibly() |
<V> Promise<V> |
UnorderedThreadPoolEventExecutor.newPromise() |
<V> Promise<V> |
ImmediateEventExecutor.newPromise() |
<V> Promise<V> |
EventExecutor.newPromise()
返回一个新的 Promise 。
|
<V> Promise<V> |
AbstractEventExecutor.newPromise() |
Promise<V> |
Promise.removeListener(GenericFutureListener<? extends Future<? super V>> listener) |
Promise<V> |
DefaultPromise.removeListener(GenericFutureListener<? extends Future<? super V>> listener) |
Promise<V> |
Promise.removeListeners(GenericFutureListener<? extends Future<? super V>>... listeners) |
Promise<V> |
DefaultPromise.removeListeners(GenericFutureListener<? extends Future<? super V>>... listeners) |
Promise<V> |
Promise.setFailure(java.lang.Throwable cause)
将这个未来标志为失败并通知所有听众。
|
Promise<V> |
DefaultPromise.setFailure(java.lang.Throwable cause) |
Promise<V> |
Promise.setSuccess(V result)
将这个未来标志为成功并通知所有听众。
|
Promise<V> |
DefaultPromise.setSuccess(V result) |
Promise<V> |
Promise.sync() |
Promise<V> |
DefaultPromise.sync() |
Promise<V> |
Promise.syncUninterruptibly() |
Promise<V> |
DefaultPromise.syncUninterruptibly() |
Modifier and Type | Method and Description |
---|---|
void |
PromiseCombiner.add(Promise promise)
|
PromiseAggregator<V,F> |
PromiseAggregator.add(Promise<V>... promises)
已过时。
将给定的 Promise 添加到聚合器。
|
void |
PromiseCombiner.addAll(Promise... promises)
|
static <X> void |
UnaryPromiseNotifier.cascadeTo(Future<X> completedFuture, Promise<? super X> promise) |
void |
PromiseCombiner.finish(Promise<java.lang.Void> aggregatePromise)
设置所有合并期货完成时的通知承诺。
|
Constructor and Description |
---|
PromiseAggregator(Promise<java.lang.Void> aggregatePromise)
已过时。
|
PromiseAggregator(Promise<java.lang.Void> aggregatePromise, boolean failPending)
已过时。
创建一个新的实例。
|
PromiseNotifier(boolean logNotifyFailure, Promise<? super V>... promises)
创建一个新的实例。
|
PromiseNotifier(Promise<? super V>... promises)
Create a new instance.
|
UnaryPromiseNotifier(Promise<? super T> promise) |
Copyright © 2008–2018 The Netty Project. All rights reserved.