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.