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.