public class DefaultChannelPipeline extends java.lang.Object implements ChannelPipeline
ChannelPipeline实现。
它是由通常创建Channel执行时Channel创建。
| Modifier | Constructor and Description |
|---|---|
protected |
DefaultChannelPipeline(Channel channel) |
| Modifier and Type | Method and Description |
|---|---|
ChannelPipeline |
addAfter(EventExecutorGroup group, java.lang.String baseName, java.lang.String name, ChannelHandler handler)
在此管道的现有处理程序之后插入 ChannelHandler 。
|
ChannelPipeline |
addAfter(java.lang.String baseName, java.lang.String name, ChannelHandler handler)
在此管道的现有处理程序之后插入 ChannelHandler 。
|
ChannelPipeline |
addBefore(EventExecutorGroup group, java.lang.String baseName, java.lang.String name, ChannelHandler handler)
在此管道的现有处理程序之前插入 ChannelHandler 。
|
ChannelPipeline |
addBefore(java.lang.String baseName, java.lang.String name, ChannelHandler handler)
在此管道的现有处理程序之前插入 ChannelHandler 。
|
ChannelPipeline |
addFirst(ChannelHandler... handlers)
在此管道的第一个位置插入 ChannelHandler s。
|
ChannelPipeline |
addFirst(ChannelHandler handler) |
ChannelPipeline |
addFirst(EventExecutorGroup executor, ChannelHandler... handlers)
在此管道的第一个位置插入 ChannelHandler 。
|
ChannelPipeline |
addFirst(EventExecutorGroup group, java.lang.String name, ChannelHandler handler)
在此管道的第一个位置插入 ChannelHandler 。
|
ChannelPipeline |
addFirst(java.lang.String name, ChannelHandler handler)
在此管道的第一个位置插入 ChannelHandler 。
|
ChannelPipeline |
addLast(ChannelHandler... handlers)
在此管道的最后位置插入 ChannelHandler 。
|
ChannelPipeline |
addLast(ChannelHandler handler) |
ChannelPipeline |
addLast(EventExecutorGroup executor, ChannelHandler... handlers)
在此管道的最后位置插入 ChannelHandler s。
|
ChannelPipeline |
addLast(EventExecutorGroup group, java.lang.String name, ChannelHandler handler)
在此管道的最后位置追加 ChannelHandler 。
|
ChannelPipeline |
addLast(java.lang.String name, ChannelHandler handler)
在此管道的最后位置追加 ChannelHandler 。
|
ChannelFuture |
bind(java.net.SocketAddress localAddress)
请求绑定到给定的 SocketAddress并在操作完成后通知ChannelFuture ,无论是因为操作成功还是由于错误。
|
ChannelFuture |
bind(java.net.SocketAddress localAddress, ChannelPromise promise)
请求绑定到给定的 SocketAddress并在操作完成后通知ChannelFuture ,无论是因为操作成功还是由于错误。
|
Channel |
channel()
返回此管道所连接的 Channel 。
|
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同时绑定到localAddress,并在操作完成后通知ChannelFuture ,无论是因为操作成功还是由于错误。
|
ChannelFuture |
connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
请求连接到给定的 SocketAddress同时绑定到localAddress,并在操作完成后通知ChannelFuture ,无论是因为操作成功还是由于错误。
|
ChannelHandlerContext |
context(ChannelHandler handler)
返回此管道中指定的 ChannelHandler的上下文对象。
|
ChannelHandlerContext |
context(java.lang.Class<? extends ChannelHandler> handlerType)
返回此管道中指定类型的 ChannelHandler的上下文对象。
|
ChannelHandlerContext |
context(java.lang.String name)
返回此管道中具有指定名称的 ChannelHandler的上下文对象。
|
protected void |
decrementPendingOutboundBytes(long size) |
ChannelFuture |
deregister()
一旦操作完成,请求从先前分配的 EventExecutor注销并通知ChannelFuture ,无论是因为操作成功还是由于错误。
|
ChannelFuture |
deregister(ChannelPromise promise)
请求注销以前分配的 EventExecutor,并在操作完成后通知ChannelFuture ,无论是因为操作成功还是由于错误。
|
ChannelFuture |
disconnect()
请求从远程对等方断开连接,并在操作完成后通知 ChannelFuture ,可能是因为操作成功或错误。
|
ChannelFuture |
disconnect(ChannelPromise promise)
请求从远程对等方断开连接,并在操作完成后通知 ChannelFuture ,无论是因为操作成功还是由于错误。
|
ChannelPipeline |
fireChannelActive()
A Channel现在处于活动状态,这意味着它已连接。
|
ChannelPipeline |
fireChannelInactive()
A Channel现在不活动,这意味着它已关闭。
|
ChannelPipeline |
fireChannelRead(java.lang.Object msg)
A Channel收到消息。
|
ChannelPipeline |
fireChannelReadComplete()
|
ChannelPipeline |
fireChannelRegistered()
|
ChannelPipeline |
fireChannelUnregistered()
|
ChannelPipeline |
fireChannelWritabilityChanged()
|
ChannelPipeline |
fireExceptionCaught(java.lang.Throwable cause)
A Channel在其一次入境业务中收到Throwable 。
|
ChannelPipeline |
fireUserEventTriggered(java.lang.Object event)
A Channel收到用户定义的事件。
|
ChannelHandler |
first()
返回此管道中的第一个 ChannelHandler 。
|
ChannelHandlerContext |
firstContext()
返回此管道中第一个 ChannelHandler的上下文。
|
ChannelPipeline |
flush()
请求通过此ChannelOutboundInvoker清除所有未决消息。
|
<T extends ChannelHandler> |
get(java.lang.Class<T> handlerType)
返回此管道中指定类型的 ChannelHandler 。
|
ChannelHandler |
get(java.lang.String name)
返回此管道中具有指定名称的 ChannelHandler 。
|
protected void |
incrementPendingOutboundBytes(long size) |
java.util.Iterator<java.util.Map.Entry<java.lang.String,ChannelHandler>> |
iterator() |
ChannelHandler |
last()
返回此管道中的最后一个 ChannelHandler 。
|
ChannelHandlerContext |
lastContext()
返回此管道中最后一个 ChannelHandler的上下文。
|
java.util.List<java.lang.String> |
names()
返回处理程序名称的
List 。
|
ChannelFuture |
newFailedFuture(java.lang.Throwable cause)
创建一个新的已标记为失败的 ChannelFuture 。
|
ChannelProgressivePromise |
newProgressivePromise()
|
ChannelPromise |
newPromise()
返回一个新的 ChannelPromise 。
|
ChannelFuture |
newSucceededFuture()
创建一个新的标记为已成功的 ChannelFuture 。
|
protected void |
onUnhandledChannelWritabilityChanged()
|
protected void |
onUnhandledInboundChannelActive()
|
protected void |
onUnhandledInboundChannelInactive()
|
protected void |
onUnhandledInboundChannelReadComplete()
|
protected void |
onUnhandledInboundException(java.lang.Throwable cause)
在 Throwable结束时调用一次Throwable,而未由用户在ChannelHandler.exceptionCaught(ChannelHandlerContext, Throwable)中处理。
|
protected void |
onUnhandledInboundMessage(java.lang.Object msg)
|
protected void |
onUnhandledInboundUserEventTriggered(java.lang.Object evt)
|
ChannelPipeline |
read()
请求来读取数据 Channel进入第一入缓冲区,触发ChannelInboundHandler.channelRead(ChannelHandlerContext, Object)如果数据读取事件,并触发channelReadComplete事件,这样的处理可以决定继续读书。
|
ChannelPipeline |
remove(ChannelHandler handler)
从此管道中删除指定的 ChannelHandler 。
|
<T extends ChannelHandler> |
remove(java.lang.Class<T> handlerType)
从此管道中移除指定类型的 ChannelHandler 。
|
ChannelHandler |
remove(java.lang.String name)
从该管道中删除具有指定名称的 ChannelHandler 。
|
ChannelHandler |
removeFirst()
删除此管道中的第一个 ChannelHandler 。
|
ChannelHandler |
removeLast()
删除此管道中的最后 ChannelHandler 。
|
ChannelPipeline |
replace(ChannelHandler oldHandler, java.lang.String newName, ChannelHandler newHandler)
用此管道中的新处理程序替换指定的 ChannelHandler 。
|
<T extends ChannelHandler> |
replace(java.lang.Class<T> oldHandlerType, java.lang.String newName, ChannelHandler newHandler)
用此管道中的新处理程序替换指定类型的 ChannelHandler 。
|
ChannelHandler |
replace(java.lang.String oldName, java.lang.String newName, ChannelHandler newHandler)
用此管道中的新处理程序替换指定名称的 ChannelHandler 。
|
java.util.Map<java.lang.String,ChannelHandler> |
toMap()
将此管道转换为有序的
Map其键是处理程序名称,其值是处理程序。
|
java.lang.String |
toString()
返回此管道的
String表示形式。
|
ChannelPromise |
voidPromise()
返回可用于不同操作的特殊ChannelPromise。
|
ChannelFuture |
write(java.lang.Object msg)
要求通过 ChannelHandlerContext通过ChannelPipeline写信息。
|
ChannelFuture |
write(java.lang.Object msg, ChannelPromise promise)
要求通过 ChannelHandlerContext通过ChannelPipeline写信息。
|
ChannelFuture |
writeAndFlush(java.lang.Object msg)
|
ChannelFuture |
writeAndFlush(java.lang.Object msg, ChannelPromise promise)
|
protected DefaultChannelPipeline(Channel channel)
public final Channel channel()
ChannelPipeline
Channel 。
channel接口
ChannelPipeline
null如果此管道尚未连接。
public final ChannelPipeline addFirst(java.lang.String name, ChannelHandler handler)
ChannelPipeline
ChannelHandler 。
addFirst ,界面
ChannelPipeline
name - 要插入的处理程序的名称
handler - 首先插入的处理程序
public final ChannelPipeline addFirst(EventExecutorGroup group, java.lang.String name, ChannelHandler handler)
ChannelPipeline复制的描述
ChannelHandler 。
addFirst ,界面
ChannelPipeline
group -所述EventExecutorGroup ,其将被用于执行所述ChannelHandler种方法
name - 首先插入的处理程序的名称
handler - 首先插入的处理程序
public final ChannelPipeline addLast(java.lang.String name, ChannelHandler handler)
ChannelPipeline
ChannelHandler 。
addLast在界面
ChannelPipeline
name - 要附加的处理程序的名称
handler - 要附加的处理程序
public final ChannelPipeline addLast(EventExecutorGroup group, java.lang.String name, ChannelHandler handler)
ChannelPipeline
ChannelHandler 。
addLast在界面
ChannelPipeline
group -所述EventExecutorGroup ,其将被用于执行所述ChannelHandler种方法
name - 要附加的处理程序的名称
handler - 要附加的处理程序
public final ChannelPipeline addBefore(java.lang.String baseName, java.lang.String name, ChannelHandler handler)
ChannelPipeline复制的描述
ChannelHandler 。
addBefore在界面
ChannelPipeline
baseName - 现有处理程序的名称
name - 之前要插入的处理程序的名称
handler - 之前插入的处理程序
public final ChannelPipeline addBefore(EventExecutorGroup group, java.lang.String baseName, java.lang.String name, ChannelHandler handler)
ChannelPipeline复制的描述
ChannelHandler 。
addBefore接口
ChannelPipeline
group -所述EventExecutorGroup ,其将被用于执行所述ChannelHandler种方法
baseName - 现有处理程序的名称
name - 之前要插入的处理程序的名称
handler - 之前插入的处理程序
public final ChannelPipeline addAfter(java.lang.String baseName, java.lang.String name, ChannelHandler handler)
ChannelPipeline
ChannelHandler 。
addAfter ,界面
ChannelPipeline
baseName - 现有处理程序的名称
name - 要插入的处理程序的名称
handler - 要插入的处理程序
public final ChannelPipeline addAfter(EventExecutorGroup group, java.lang.String baseName, java.lang.String name, ChannelHandler handler)
ChannelPipeline复制的描述
ChannelHandler 。
addAfter接口
ChannelPipeline
group -所述EventExecutorGroup ,其将被用于执行所述ChannelHandler种方法
baseName - 现有处理程序的名称
name - 要插入的处理程序的名称
handler - 之后插入的处理程序
public final ChannelPipeline addFirst(ChannelHandler handler)
public final ChannelPipeline addFirst(ChannelHandler... handlers)
ChannelPipeline
ChannelHandler s。
addFirst在界面
ChannelPipeline
handlers - 首先插入的处理程序
public final ChannelPipeline addFirst(EventExecutorGroup executor, ChannelHandler... handlers)
ChannelPipeline复制的描述
ChannelHandler s。
addFirst ,界面
ChannelPipeline
executor -所述EventExecutorGroup ,其将被用于执行所述ChannelHandler小号方法。
handlers - 首先插入的处理程序
public final ChannelPipeline addLast(ChannelHandler handler)
public final ChannelPipeline addLast(ChannelHandler... handlers)
ChannelPipeline复制的描述
ChannelHandler s。
addLast ,界面
ChannelPipeline
handlers - 最后插入的处理程序
public final ChannelPipeline addLast(EventExecutorGroup executor, ChannelHandler... handlers)
ChannelPipeline
ChannelHandler s。
addLast接口
ChannelPipeline
executor -所述EventExecutorGroup ,其将被用于执行所述ChannelHandler小号方法。
handlers - 最后插入的处理程序
public final ChannelPipeline remove(ChannelHandler handler)
ChannelPipeline复制的描述
ChannelHandler 。
remove接口
ChannelPipeline
handler - 将ChannelHandler删除
public final ChannelHandler remove(java.lang.String name)
ChannelPipeline复制的描述
ChannelHandler 。
remove在界面
ChannelPipeline
name -在其名称ChannelHandler储存。
public final <T extends ChannelHandler> T remove(java.lang.Class<T> handlerType)
ChannelPipeline复制的描述
ChannelHandler 。
remove接口
ChannelPipeline
T - 处理程序的类型
handlerType - 处理程序的类型
public final ChannelHandler removeFirst()
ChannelPipeline复制的描述
ChannelHandler 。
removeFirst接口
ChannelPipeline
public final ChannelHandler removeLast()
ChannelPipeline复制的描述
ChannelHandler 。
removeLast在界面
ChannelPipeline
public final ChannelPipeline replace(ChannelHandler oldHandler, java.lang.String newName, ChannelHandler newHandler)
ChannelPipeline复制的描述
ChannelHandler 。
replace在界面
ChannelPipeline
oldHandler - 将被替换的ChannelHandler
newName - 应该添加替换的名称
newHandler - 用作替换的ChannelHandler
public final ChannelHandler replace(java.lang.String oldName, java.lang.String newName, ChannelHandler newHandler)
ChannelPipeline复制的描述
ChannelHandler 。
replace ,界面
ChannelPipeline
oldName - 要替换的ChannelHandler的名称
newName - 应该添加替换的名称
newHandler - 用作替换的ChannelHandler
public final <T extends ChannelHandler> T replace(java.lang.Class<T> oldHandlerType, java.lang.String newName, ChannelHandler newHandler)
ChannelPipeline复制的描述
ChannelHandler 。
replace接口
ChannelPipeline
oldHandlerType - 要移除的处理程序的类型
newName - 应该添加替换的名称
newHandler - 用作替换的ChannelHandler
public final ChannelHandler first()
ChannelPipeline复制的描述
ChannelHandler 。
first在界面
ChannelPipeline
null如果此管道是空的。
public final ChannelHandlerContext firstContext()
ChannelPipeline
ChannelHandler的上下文。
firstContext在界面
ChannelPipeline
null如果此管道是空的。
public final ChannelHandler last()
ChannelPipeline
ChannelHandler 。
last ,界面
ChannelPipeline
null如果此管道是空的。
public final ChannelHandlerContext lastContext()
ChannelPipeline复制的描述
ChannelHandler的上下文。
lastContext在界面
ChannelPipeline
null如果此管道是空的。
public final ChannelHandler get(java.lang.String name)
ChannelPipeline
ChannelHandler 。
get接口
ChannelPipeline
null如果在这个管道中没有这样的处理程序。
public final <T extends ChannelHandler> T get(java.lang.Class<T> handlerType)
ChannelPipeline复制的描述
ChannelHandler 。
get ,界面
ChannelPipeline
null如果在这个管道中没有这样的处理程序。
public final ChannelHandlerContext context(java.lang.String name)
ChannelPipeline
ChannelHandler的上下文对象。
context接口
ChannelPipeline
null如果在这个管道中没有这样的处理程序。
public final ChannelHandlerContext context(ChannelHandler handler)
ChannelPipeline复制的描述
ChannelHandler的上下文对象。
context ,界面
ChannelPipeline
null如果在这个管道中没有这样的处理程序。
public final ChannelHandlerContext context(java.lang.Class<? extends ChannelHandler> handlerType)
ChannelPipeline复制的描述
ChannelHandler的上下文对象。
context ,界面
ChannelPipeline
null如果在这个管道中没有这样的处理程序。
public final java.util.List<java.lang.String> names()
ChannelPipeline复制的描述
List 。
names接口
ChannelPipeline
public final java.util.Map<java.lang.String,ChannelHandler> toMap()
ChannelPipeline
Map其键是处理程序名称,其值是处理程序。
toMap接口
ChannelPipeline
public final java.util.Iterator<java.util.Map.Entry<java.lang.String,ChannelHandler>> iterator()
iterator在界面
java.lang.Iterable<java.util.Map.Entry<java.lang.String,ChannelHandler>>
public final java.lang.String toString()
String表示形式。
toString在课堂上
java.lang.Object
public final ChannelPipeline fireChannelRegistered()
ChannelInboundInvoker复制的描述
Channel已注册到其EventLoop 。
这将导致在具有ChannelInboundHandler.channelRegistered(ChannelHandlerContext)方法称为下一个的ChannelInboundHandler包含在ChannelPipeline的的Channel 。
fireChannelRegistered在界面
ChannelInboundInvoker
fireChannelRegistered在界面
ChannelPipeline
public final ChannelPipeline fireChannelUnregistered()
ChannelInboundInvoker
Channel从其EventLoop未注册。
这将导致在具有ChannelInboundHandler.channelUnregistered(ChannelHandlerContext)方法称为下一个的ChannelInboundHandler包含在ChannelPipeline的的Channel 。
fireChannelUnregistered在界面
ChannelInboundInvoker
fireChannelUnregistered ,界面
ChannelPipeline
public final ChannelPipeline fireChannelActive()
ChannelInboundInvoker复制的描述
Channel现在处于活动状态,这意味着它已连接。
这将导致Channel的ChannelPipeline中包含ChannelInboundHandler的下一个ChannelInboundHandler方法 。
fireChannelActive ,界面
ChannelInboundInvoker
fireChannelActive接口
ChannelPipeline
public final ChannelPipeline fireChannelInactive()
ChannelInboundInvoker复制的描述
Channel现在不活动,这意味着它已关闭。
这将导致在具有ChannelInboundHandler.channelInactive(ChannelHandlerContext)方法称为下一个的ChannelInboundHandler包含在ChannelPipeline的的Channel 。
fireChannelInactive在界面
ChannelInboundInvoker
fireChannelInactive在界面
ChannelPipeline
public final ChannelPipeline fireExceptionCaught(java.lang.Throwable cause)
ChannelInboundInvoker复制的描述
Channel在其一项入境业务中收到Throwable 。
这将导致在具有ChannelInboundHandler.exceptionCaught(ChannelHandlerContext, Throwable)方法称为下一个的ChannelInboundHandler包含在ChannelPipeline的的Channel 。
fireExceptionCaught接口
ChannelInboundInvoker
fireExceptionCaught接口
ChannelPipeline
public final ChannelPipeline fireUserEventTriggered(java.lang.Object event)
ChannelInboundInvoker
Channel收到用户定义的事件。
这将导致在具有ChannelInboundHandler.userEventTriggered(ChannelHandlerContext, Object)方法称为下一个的ChannelInboundHandler包含在ChannelPipeline的的Channel 。
fireUserEventTriggered ,界面
ChannelInboundInvoker
fireUserEventTriggered ,界面
ChannelPipeline
public final ChannelPipeline fireChannelRead(java.lang.Object msg)
ChannelInboundInvoker
Channel收到了消息。
这将导致在具有ChannelInboundHandler.channelRead(ChannelHandlerContext, Object)方法称为下一个的ChannelInboundHandler包含在ChannelPipeline的的Channel 。
fireChannelRead ,界面
ChannelInboundInvoker
fireChannelRead接口
ChannelPipeline
public final ChannelPipeline fireChannelReadComplete()
ChannelInboundInvoker
ChannelInboundHandler.channelReadComplete(ChannelHandlerContext)事件到ChannelPipeline中的下一个ChannelInboundHandler 。
fireChannelReadComplete接口
ChannelInboundInvoker
fireChannelReadComplete在界面
ChannelPipeline
public final ChannelPipeline fireChannelWritabilityChanged()
ChannelInboundInvoker
ChannelInboundHandler.channelWritabilityChanged(ChannelHandlerContext)事件到ChannelPipeline中的下一个ChannelInboundHandler 。
fireChannelWritabilityChanged在界面
ChannelInboundInvoker
fireChannelWritabilityChanged在界面
ChannelPipeline
public final ChannelFuture bind(java.net.SocketAddress localAddress)
ChannelOutboundInvoker
SocketAddress并在操作完成后通知ChannelFuture ,无论是因为操作成功还是由于错误。
这将导致ChannelPipeline中包含的ChannelOutboundHandler.bind(ChannelHandlerContext, SocketAddress, ChannelPromise)方法被称为87260760727729的下一个ChannelOutboundHandler 。
bind接口
ChannelOutboundInvoker
public final ChannelFuture connect(java.net.SocketAddress remoteAddress)
ChannelOutboundInvoker复制的描述
SocketAddress并在操作完成后通知ChannelFuture ,可能是因为操作成功或出现错误。
如果由于连接超时而导致连接失败,则ChannelFuture将失败,并显示ConnectTimeoutException 。 如果因连接拒绝而失败,则将使用ConnectException 。
这将导致在具有ChannelOutboundHandler.connect(ChannelHandlerContext, SocketAddress, SocketAddress, ChannelPromise)方法称为下一个的ChannelOutboundHandler包含在ChannelPipeline的的Channel 。
connect接口
ChannelOutboundInvoker
public final ChannelFuture connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress)
ChannelOutboundInvoker
SocketAddress同时绑定到localAddress,并在操作完成后通知ChannelFuture ,无论是因为操作成功还是由于错误。
这将导致在具有ChannelOutboundHandler.connect(ChannelHandlerContext, SocketAddress, SocketAddress, ChannelPromise)方法称为下一个的ChannelOutboundHandler包含在ChannelPipeline的的Channel 。
connect接口
ChannelOutboundInvoker
public final ChannelFuture disconnect()
ChannelOutboundInvoker复制的描述
ChannelFuture ,这可能是因为操作成功或者由于错误。
这将导致在具有ChannelOutboundHandler.disconnect(ChannelHandlerContext, ChannelPromise)方法称为下一个的ChannelOutboundHandler包含在ChannelPipeline的的Channel 。
disconnect在界面
ChannelOutboundInvoker
public final ChannelFuture close()
ChannelOutboundInvoker
Channel并通知ChannelFuture ,无论是因为操作成功还是由于错误。
关闭后不可能再次使用它。
这将导致在具有ChannelOutboundHandler.close(ChannelHandlerContext, ChannelPromise)方法称为下一个的ChannelOutboundHandler包含在ChannelPipeline的的Channel 。
close接口
ChannelOutboundInvoker
public final ChannelFuture deregister()
ChannelOutboundInvoker复制的描述
EventExecutor注销并通知ChannelFuture ,无论是因为操作成功还是由于错误。
这将导致在具有ChannelOutboundHandler.deregister(ChannelHandlerContext, ChannelPromise)方法称为下一个的ChannelOutboundHandler包含在ChannelPipeline的的Channel 。
deregister在界面
ChannelOutboundInvoker
public final ChannelPipeline flush()
ChannelOutboundInvoker复制的描述
flush在界面
ChannelOutboundInvoker
flush在界面
ChannelPipeline
public final ChannelFuture bind(java.net.SocketAddress localAddress, ChannelPromise promise)
ChannelOutboundInvoker复制的描述
SocketAddress并在操作完成后通知ChannelFuture ,这可能是因为操作成功或者由于错误。
给定的ChannelPromise将被通知。
这将导致在具有ChannelOutboundHandler.bind(ChannelHandlerContext, SocketAddress, ChannelPromise)方法称为下一个的ChannelOutboundHandler包含在ChannelPipeline的的Channel 。
bind在界面
ChannelOutboundInvoker
public final ChannelFuture connect(java.net.SocketAddress remoteAddress, ChannelPromise promise)
ChannelOutboundInvoker
SocketAddress并在操作完成后通知ChannelFuture ,这可能是因为操作成功或错误。
给定的ChannelFuture将被通知。
如果由于连接超时而导致连接失败,则ChannelFuture将失败,并显示ConnectTimeoutException 。 如果因连接拒绝而失败,将使用ConnectException 。
这将导致在具有ChannelOutboundHandler.connect(ChannelHandlerContext, SocketAddress, SocketAddress, ChannelPromise)方法称为下一个的ChannelOutboundHandler包含在ChannelPipeline的的Channel 。
connect ,界面
ChannelOutboundInvoker
public final ChannelFuture connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
ChannelOutboundInvoker复制的描述
SocketAddress同时绑定到localAddress,并在操作完成后通知ChannelFuture ,无论是因为操作成功还是由于错误。
给定的ChannelPromise将被通知并且返回。
这将导致在具有ChannelOutboundHandler.connect(ChannelHandlerContext, SocketAddress, SocketAddress, ChannelPromise)方法称为下一个的ChannelOutboundHandler包含在ChannelPipeline的的Channel 。
connect接口
ChannelOutboundInvoker
public final ChannelFuture disconnect(ChannelPromise promise)
ChannelOutboundInvoker
ChannelFuture ,无论是由于操作成功还是由于错误。
给定的ChannelPromise将被通知。
这将导致在具有ChannelOutboundHandler.disconnect(ChannelHandlerContext, ChannelPromise)方法称为下一个的ChannelOutboundHandler包含在ChannelPipeline的的Channel 。
disconnect接口
ChannelOutboundInvoker
public final ChannelFuture close(ChannelPromise promise)
ChannelOutboundInvoker
Channel,并在操作完成后通知ChannelFuture ,无论是因为操作成功还是由于错误。
关闭后不可能再次使用它。
给定的ChannelPromise将被通知。
这将导致在具有ChannelOutboundHandler.close(ChannelHandlerContext, ChannelPromise)方法称为下一个的ChannelOutboundHandler包含在ChannelPipeline的的Channel 。
close在界面
ChannelOutboundInvoker
public final ChannelFuture deregister(ChannelPromise promise)
ChannelOutboundInvoker
EventExecutor,并在操作完成后通知ChannelFuture ,无论是因为操作成功还是由于错误。
给定的ChannelPromise将被通知。
这将导致在具有ChannelOutboundHandler.deregister(ChannelHandlerContext, ChannelPromise)方法称为下一个的ChannelOutboundHandler包含在ChannelPipeline的的Channel 。
deregister在界面
ChannelOutboundInvoker
public final ChannelPipeline read()
ChannelOutboundInvoker
Channel进入第一入缓冲区,触发ChannelInboundHandler.channelRead(ChannelHandlerContext, Object)如果数据读取事件,并触发channelReadComplete事件,这样的处理可以决定继续读书。
如果已经有待处理的读取操作,则此方法不执行任何操作。
这将导致在具有ChannelOutboundHandler.read(ChannelHandlerContext)方法称为下一个的ChannelOutboundHandler包含在ChannelPipeline的的Channel 。
read ,界面
ChannelOutboundInvoker
public final ChannelFuture write(java.lang.Object msg)
ChannelOutboundInvoker复制的描述
ChannelHandlerContext通过ChannelPipeline写信息。
此方法不会请求实际刷新,因此,一旦要请求将所有待处理数据清除到实际传输,请务必调用ChannelOutboundInvoker.flush() 。
write接口
ChannelOutboundInvoker
public final ChannelFuture write(java.lang.Object msg, ChannelPromise promise)
ChannelOutboundInvoker复制的描述
ChannelHandlerContext通过ChannelPipeline写信息。
此方法不会请求实际刷新,因此,一旦要请求将所有待处理数据刷新到实际传输,一定要致电ChannelOutboundInvoker.flush() 。
write接口
ChannelOutboundInvoker
public final ChannelFuture writeAndFlush(java.lang.Object msg, ChannelPromise promise)
ChannelOutboundInvoker复制的描述
writeAndFlush接口
ChannelOutboundInvoker
public final ChannelFuture writeAndFlush(java.lang.Object msg)
ChannelOutboundInvoker
writeAndFlush接口
ChannelOutboundInvoker
public final ChannelPromise newPromise()
ChannelOutboundInvoker
ChannelPromise 。
newPromise接口
ChannelOutboundInvoker
public final ChannelProgressivePromise newProgressivePromise()
ChannelOutboundInvoker复制的描述
newProgressivePromise在界面
ChannelOutboundInvoker
public final ChannelFuture newSucceededFuture()
ChannelOutboundInvoker复制的描述
ChannelFuture 。
所以Future.isSuccess()将返回true 。
所有FutureListener添加到它将直接通知。
同样,每个阻塞方法的调用都会返回而不会阻塞。
newSucceededFuture接口
ChannelOutboundInvoker
public final ChannelFuture newFailedFuture(java.lang.Throwable cause)
ChannelOutboundInvoker复制的描述
ChannelFuture 。
所以Future.isSuccess()将返回false 。
所有FutureListener添加到它将直接通知。
同样,每个阻塞方法的调用都会返回而不会阻塞。
newFailedFuture接口
ChannelOutboundInvoker
public final ChannelPromise voidPromise()
ChannelOutboundInvoker
它仅支持将其用于ChannelOutboundInvoker.write(Object, ChannelPromise) 。
请注意,返回的ChannelPromise不支持大多数操作,只应在您希望为每个写入操作保存对象分配时才使用。 您将无法检测到操作是否完成,只有在操作失败的情况下执行才会在此情况下调用ChannelPipeline.fireExceptionCaught(Throwable) 。
voidPromise在界面
ChannelOutboundInvoker
protected void onUnhandledInboundException(java.lang.Throwable cause)
Throwable命中Throwable的结尾, 而未由用户在ChannelHandler.exceptionCaught(ChannelHandlerContext, Throwable)处理。
protected void onUnhandledInboundChannelActive()
protected void onUnhandledInboundChannelInactive()
protected void onUnhandledInboundMessage(java.lang.Object msg)
ChannelPipeline结束时消息被调用,而用户未在ChannelInboundHandler.channelRead(ChannelHandlerContext, Object)中处理该消息 。
此方法负责在给定的msg上调用ReferenceCountUtil.release(Object) 。
protected void onUnhandledInboundChannelReadComplete()
protected void onUnhandledInboundUserEventTriggered(java.lang.Object evt)
ChannelPipeline的末尾而未被用户在ChannelInboundHandler.userEventTriggered(ChannelHandlerContext, Object)中处理,则调用该事件。
此方法负责在某个时间点对给定事件调用ReferenceCountUtil.release(Object) 。
protected void onUnhandledChannelWritabilityChanged()
@UnstableApi protected void incrementPendingOutboundBytes(long size)
@UnstableApi protected void decrementPendingOutboundBytes(long size)
Copyright © 2008–2018 The Netty Project. All rights reserved.