public interface ChannelOutboundInvoker | Modifier and Type | Method and Description |
|---|---|
ChannelFuture |
bind(java.net.SocketAddress localAddress)
请求绑定到给定的 SocketAddress并在操作完成后通知ChannelFuture ,无论是因为操作成功还是由于错误。
|
ChannelFuture |
bind(java.net.SocketAddress localAddress, ChannelPromise promise)
请求绑定到给定的 SocketAddress并在操作完成后通知ChannelFuture ,这可能是因为操作成功或者由于错误。
|
ChannelFuture |
close()
请求关闭 Channel,并在操作完成后通知ChannelFuture ,无论是因为操作成功还是由于错误。
|
ChannelFuture |
close(ChannelPromise promise)
请求关闭 Channel,并在操作完成后通知ChannelFuture ,无论是因为操作成功还是由于错误。
|
ChannelFuture |
connect(java.net.SocketAddress remoteAddress)
请求连接到给定的 SocketAddress并在操作完成后通知ChannelFuture ,无论是因为操作成功还是由于错误。
|
ChannelFuture |
connect(java.net.SocketAddress remoteAddress, ChannelPromise promise)
请求连接到给定的 SocketAddress并在操作完成后通知ChannelFuture ,无论是因为操作成功还是由于错误。
|
ChannelFuture |
connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress)
请求在绑定到 SocketAddress时连接到给定的SocketAddress ,并在操作完成后通知ChannelFuture ,无论是因为操作成功还是由于错误。
|
ChannelFuture |
connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
在绑定到 SocketAddress时请求连接到给定的SocketAddress ,并在操作完成后通知ChannelFuture ,无论是因为操作成功还是由于错误。
|
ChannelFuture |
deregister()
请求注销以前分配的 EventExecutor,并在操作完成后通知ChannelFuture ,无论是因为操作成功还是由于错误。
|
ChannelFuture |
deregister(ChannelPromise promise)
请求注销以前分配的 EventExecutor,并在操作完成后通知ChannelFuture ,无论是因为操作成功还是由于错误。
|
ChannelFuture |
disconnect()
请求从远程对等方断开连接,并在操作完成后通知 ChannelFuture ,无论是因为操作成功还是由于错误。
|
ChannelFuture |
disconnect(ChannelPromise promise)
请求从远程对等方断开连接,并在操作完成后通知 ChannelFuture ,因为操作成功或错误。
|
ChannelOutboundInvoker |
flush()
请求通过此ChannelOutboundInvoker清除所有未决消息。
|
ChannelFuture |
newFailedFuture(java.lang.Throwable cause)
创建一个已被标记为失败的新 ChannelFuture 。
|
ChannelProgressivePromise |
newProgressivePromise()
|
ChannelPromise |
newPromise()
返回一个新的 ChannelPromise 。
|
ChannelFuture |
newSucceededFuture()
创建一个新的标记为已成功的 ChannelFuture 。
|
ChannelOutboundInvoker |
read()
请求来读取数据 Channel进入第一入缓冲区,触发ChannelInboundHandler.channelRead(ChannelHandlerContext, Object)如果数据读取事件,并触发channelReadComplete事件,这样的处理可以决定继续读书。
|
ChannelPromise |
voidPromise()
返回可用于不同操作的特殊ChannelPromise。
|
ChannelFuture |
write(java.lang.Object msg)
要求通过 ChannelHandlerContext通过ChannelPipeline写一条消息。
|
ChannelFuture |
write(java.lang.Object msg, ChannelPromise promise)
|
ChannelFuture |
writeAndFlush(java.lang.Object msg)
致电
write(Object)和
flush()的快捷方式。
|
ChannelFuture |
writeAndFlush(java.lang.Object msg, ChannelPromise promise)
致电
write(Object, ChannelPromise)和
flush()的快捷方式。
|
ChannelFuture bind(java.net.SocketAddress localAddress)
SocketAddress并在操作完成时通知ChannelFuture ,无论是因为操作成功还是由于错误。
这将导致在具有ChannelOutboundHandler.bind(ChannelHandlerContext, SocketAddress, ChannelPromise)方法称为下一个的ChannelOutboundHandler包含在ChannelPipeline的的Channel 。
ChannelFuture connect(java.net.SocketAddress remoteAddress)
SocketAddress并在操作完成后通知ChannelFuture ,无论是因为操作成功还是由于错误。
如果连接由于连接超时而失败,则ChannelFuture将失败,并显示ConnectTimeoutException 。 如果因连接拒绝而失败,将使用ConnectException 。
这将导致在具有ChannelOutboundHandler.connect(ChannelHandlerContext, SocketAddress, SocketAddress, ChannelPromise)方法称为下一个的ChannelOutboundHandler包含在ChannelPipeline的的Channel 。
ChannelFuture connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress)
SocketAddress同时绑定到localAddress,并在操作完成后通知ChannelFuture ,无论是因为操作成功还是由于错误。
这将导致在具有ChannelOutboundHandler.connect(ChannelHandlerContext, SocketAddress, SocketAddress, ChannelPromise)方法称为下一个的ChannelOutboundHandler包含在ChannelPipeline的的Channel 。
ChannelFuture disconnect()
ChannelFuture ,无论是因为操作成功还是由于错误。
这将导致在具有ChannelOutboundHandler.disconnect(ChannelHandlerContext, ChannelPromise)方法称为下一个的ChannelOutboundHandler包含在ChannelPipeline的的Channel 。
ChannelFuture close()
Channel并通知ChannelFuture ,无论是因为操作成功还是由于错误。
关闭后不可能再次使用它。
这将导致在具有ChannelOutboundHandler.close(ChannelHandlerContext, ChannelPromise)方法称为下一个的ChannelOutboundHandler包含在ChannelPipeline的的Channel 。
ChannelFuture deregister()
EventExecutor,并在操作完成后通知ChannelFuture ,无论是因为操作成功还是由于错误。
这将导致在具有ChannelOutboundHandler.deregister(ChannelHandlerContext, ChannelPromise)方法称为下一个的ChannelOutboundHandler包含在ChannelPipeline的的Channel 。
ChannelFuture bind(java.net.SocketAddress localAddress, ChannelPromise promise)
SocketAddress并在操作完成后通知ChannelFuture ,无论是因为操作成功还是由于错误。
给定的ChannelPromise将被通知。
这将导致在具有ChannelOutboundHandler.bind(ChannelHandlerContext, SocketAddress, ChannelPromise)方法称为下一个的ChannelOutboundHandler包含在ChannelPipeline的的Channel 。
ChannelFuture connect(java.net.SocketAddress remoteAddress, ChannelPromise promise)
SocketAddress并在操作完成后通知ChannelFuture ,无论是因为操作成功还是由于错误。
给定的ChannelFuture将被通知。
如果连接由于连接超时而失败,则ChannelFuture将失败,并出现ConnectTimeoutException 。 如果因连接拒绝而失败,将使用ConnectException 。
这将导致在具有ChannelOutboundHandler.connect(ChannelHandlerContext, SocketAddress, SocketAddress, ChannelPromise)方法称为下一个的ChannelOutboundHandler包含在ChannelPipeline的的Channel 。
ChannelFuture connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
SocketAddress同时绑定到localAddress,并在操作完成后通知ChannelFuture ,无论是因为操作成功还是由于错误。
给定的ChannelPromise将被通知并且返回。
这将导致在具有ChannelOutboundHandler.connect(ChannelHandlerContext, SocketAddress, SocketAddress, ChannelPromise)方法称为下一个的ChannelOutboundHandler包含在ChannelPipeline的的Channel 。
ChannelFuture disconnect(ChannelPromise promise)
ChannelFuture ,这可能是因为操作成功或错误。
给定的ChannelPromise将被通知。
这将导致在具有ChannelOutboundHandler.disconnect(ChannelHandlerContext, ChannelPromise)方法称为下一个的ChannelOutboundHandler包含在ChannelPipeline的的Channel 。
ChannelFuture close(ChannelPromise promise)
Channel并通知ChannelFuture ,无论是因为操作成功还是由于错误。
关闭后不可能再次使用它。
给定的ChannelPromise将被通知。
这将导致在具有ChannelOutboundHandler.close(ChannelHandlerContext, ChannelPromise)方法称为下一个的ChannelOutboundHandler包含在ChannelPipeline的的Channel 。
ChannelFuture deregister(ChannelPromise promise)
EventExecutor,并在操作完成后通知ChannelFuture ,无论是因为操作成功还是由于错误。
给定的ChannelPromise将被通知。
这将导致在Channel的ChannelPipeline中包含ChannelOutboundHandler的下一个82251383303534方法 。
ChannelOutboundInvoker read()
Channel进入第一入缓冲区,触发ChannelInboundHandler.channelRead(ChannelHandlerContext, Object)如果数据读取事件,并触发channelReadComplete事件,这样的处理可以决定继续读书。
如果已经有待处理的读取操作,则此方法不执行任何操作。
这将导致在具有ChannelOutboundHandler.read(ChannelHandlerContext)方法称为下一个的ChannelOutboundHandler包含在ChannelPipeline的的Channel 。
ChannelFuture write(java.lang.Object msg)
ChannelHandlerContext通过ChannelPipeline写一条消息。
此方法不会请求实际刷新,所以一旦您要请求清除所有未完成的数据到实际的传输,一定要致电flush() 。
ChannelFuture write(java.lang.Object msg, ChannelPromise promise)
ChannelHandlerContext通过ChannelPipeline写一条消息。
此方法不会请求实际刷新,因此,一旦您要请求将所有待处理数据刷新到实际传输,请务必致电flush() 。
ChannelOutboundInvoker flush()
ChannelFuture writeAndFlush(java.lang.Object msg, ChannelPromise promise)
write(Object, ChannelPromise)和
flush()的快捷方式。
ChannelFuture writeAndFlush(java.lang.Object msg)
write(Object)和
flush() 。
ChannelPromise newPromise()
ChannelPromise 。
ChannelProgressivePromise newProgressivePromise()
ChannelFuture newSucceededFuture()
ChannelFuture 。
所以Future.isSuccess()将返回true 。
所有添加到它的FutureListener将直接通知。
同样,每个阻塞方法的调用都会返回而不会阻塞。
ChannelFuture newFailedFuture(java.lang.Throwable cause)
ChannelFuture 。
所以Future.isSuccess()将返回false 。
所有添加到它的FutureListener将直接通知。
同样,每个阻塞方法的调用都会返回而不会阻塞。
ChannelPromise voidPromise()
它仅支持将其用于write(Object, ChannelPromise) 。
请注意,返回的ChannelPromise不支持大多数操作,只应在您希望为每个写入操作保存对象分配时才使用。 在这种情况下,您将无法检测操作是否完成,只有在执行失败时才会调用ChannelPipeline.fireExceptionCaught(Throwable) 。
Copyright © 2008–2018 The Netty Project. All rights reserved.