public interface ChannelHandlerContext extends AttributeMap, ChannelInboundInvoker, ChannelOutboundInvoker
ChannelHandler
能够与其ChannelPipeline
和其他处理程序进行交互。
在其他方面的处理程序可以通知下一个ChannelHandler
在ChannelPipeline
以及修改ChannelPipeline
它属于动态。
ChannelPipeline
中最接近的处理程序。
请参阅ChannelPipeline
以了解事件如何流动。
ChannelPipeline
致电处理器属于pipeline()
。
一个非平凡的应用程序可以在运行时动态地插入,移除或替换管道中的处理程序。
ChannelHandlerContext
供以后使用,例如触发处理程序方法之外的事件,即使是从其他线程触发。
public class MyHandler extends ChannelDuplexHandler
{
private ChannelHandlerContext
ctx;
public void beforeAdd(ChannelHandlerContext
ctx) {
this.ctx = ctx;
}
public void login(String username, password) {
ctx.write(new LoginMessage(username, password));
}
...
}
attr(AttributeKey)
允许您存储和访问与处理程序及其上下文相关的有状态信息。
请参阅ChannelHandler
了解各种推荐的管理有状态信息的方法。
ChannelHandler
实例可以添加到多个ChannelPipeline
。
这意味着一个ChannelHandler
实例可以有多个ChannelHandlerContext
,因此如果一个实例可以多次添加到一个或多个ChannelPipeline
,则可以使用不同的ChannelHandlerContext
调用单个实例。
例如,以下处理程序将具有与添加到管道的次数相同的多个独立AttributeKey
,而不管它是多次添加到同一管道还是多次添加到不同管道:
public class FactorialHandler extends ChannelInboundHandlerAdapter
{
private final AttributeKey
<Integer
> counter = AttributeKey
.valueOf("counter");
// This handler will receive a sequence of increasing integers starting
// from 1.
@Override
public void channelRead(ChannelHandlerContext
ctx, Object msg) {
Integer a = ctx.attr(counter).get();
if (a == null) {
a = 1;
}
attr.set(a * (Integer) msg);
}
}
// Different context objects are given to "f1", "f2", "f3", and "f4" even if
// they refer to the same handler instance. Because the FactorialHandler
// stores its state in a context object (using an AttributeKey
), the factorial is
// calculated correctly 4 times once the two pipelines (p1 and p2) are active.
FactorialHandler fh = new FactorialHandler();
ChannelPipeline
p1 = Channels
.pipeline();
p1.addLast("f1", fh);
p1.addLast("f2", fh);
ChannelPipeline
p2 = Channels
.pipeline();
p2.addLast("f3", fh);
p2.addLast("f4", fh);
请参阅ChannelHandler
和ChannelPipeline
,以了解有关入站和出站操作的更多信息,它们具有哪些基本差异,它们如何在流水线中流动以及如何处理应用程序中的操作。
bind, bind, close, close, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, voidPromise, write, write, writeAndFlush, writeAndFlush
Channel channel()
Channel
其绑定到ChannelHandlerContext
。
EventExecutor executor()
EventExecutor
。
java.lang.String name()
ChannelHandlerContext
的唯一名称。当ChannelHandler
被添加到ChannelPipeline
时使用该名称。
该名称也可用于访问ChannelHandler
中的注册ChannelHandler
。
ChannelHandler handler()
boolean isRemoved()
true
如果ChannelHandler
属于这种情况下从取出ChannelPipeline
。
请注意,此方法仅用于在EventLoop
中使用 。
ChannelHandlerContext fireChannelRegistered()
ChannelInboundInvoker
复制的描述
Channel
已注册到其EventLoop
。
这将导致在具有ChannelInboundHandler.channelRegistered(ChannelHandlerContext)
方法称为下一个的ChannelInboundHandler
包含在ChannelPipeline
的的Channel
。
fireChannelRegistered
在界面
ChannelInboundInvoker
ChannelHandlerContext fireChannelUnregistered()
ChannelInboundInvoker
Channel
从其EventLoop
未注册。
这将导致在具有ChannelInboundHandler.channelUnregistered(ChannelHandlerContext)
方法称为下一个的ChannelInboundHandler
包含在ChannelPipeline
的的Channel
。
fireChannelUnregistered
接口
ChannelInboundInvoker
ChannelHandlerContext fireChannelActive()
ChannelInboundInvoker
复制的描述
Channel
现在处于活动状态,这意味着它已连接。
这将导致在具有ChannelInboundHandler.channelActive(ChannelHandlerContext)
方法称为下一个的ChannelInboundHandler
包含在ChannelPipeline
的的Channel
。
fireChannelActive
接口
ChannelInboundInvoker
ChannelHandlerContext fireChannelInactive()
ChannelInboundInvoker
Channel
现在不活动,这意味着它已关闭。
这将导致在具有ChannelInboundHandler.channelInactive(ChannelHandlerContext)
方法称为下一个的ChannelInboundHandler
包含在ChannelPipeline
的的Channel
。
fireChannelInactive
在界面
ChannelInboundInvoker
ChannelHandlerContext fireExceptionCaught(java.lang.Throwable cause)
ChannelInboundInvoker
复制的描述
Channel
在其一项入境业务中收到Throwable
。
这将导致在具有ChannelInboundHandler.exceptionCaught(ChannelHandlerContext, Throwable)
方法称为下一个的ChannelInboundHandler
包含在ChannelPipeline
的的Channel
。
fireExceptionCaught
在界面
ChannelInboundInvoker
ChannelHandlerContext fireUserEventTriggered(java.lang.Object evt)
ChannelInboundInvoker
复制的描述
Channel
收到用户定义的事件。
这将导致在具有ChannelInboundHandler.userEventTriggered(ChannelHandlerContext, Object)
方法称为下一个的ChannelInboundHandler
包含在ChannelPipeline
的的Channel
。
fireUserEventTriggered
在界面
ChannelInboundInvoker
ChannelHandlerContext fireChannelRead(java.lang.Object msg)
ChannelInboundInvoker
复制的描述
Channel
收到了一条消息。
这将导致在具有ChannelInboundHandler.channelRead(ChannelHandlerContext, Object)
方法称为下一个的ChannelInboundHandler
包含在ChannelPipeline
的的Channel
。
fireChannelRead
在界面
ChannelInboundInvoker
ChannelHandlerContext fireChannelReadComplete()
ChannelInboundInvoker
复制的描述
ChannelInboundHandler.channelReadComplete(ChannelHandlerContext)
事件到下一个ChannelInboundHandler
在ChannelPipeline
。
fireChannelReadComplete
在界面
ChannelInboundInvoker
ChannelHandlerContext fireChannelWritabilityChanged()
ChannelInboundInvoker
复制的描述
ChannelInboundHandler.channelWritabilityChanged(ChannelHandlerContext)
事件到ChannelPipeline
中的下一个ChannelInboundHandler
。
fireChannelWritabilityChanged
在界面
ChannelInboundInvoker
ChannelHandlerContext read()
ChannelOutboundInvoker
复制的描述
Channel
读取到第一个入站缓冲区,如果读取数据,则触发ChannelInboundHandler.channelRead(ChannelHandlerContext, Object)
事件,并触发channelReadComplete
事件,以便处理程序可以决定继续读取数据。
如果已经有待处理的读取操作,则此方法不执行任何操作。
这将导致在具有ChannelOutboundHandler.read(ChannelHandlerContext)
方法称为下一个的ChannelOutboundHandler
包含在ChannelPipeline
的的Channel
。
read
接口
ChannelOutboundInvoker
ChannelHandlerContext flush()
ChannelOutboundInvoker
flush
在界面
ChannelOutboundInvoker
ChannelPipeline pipeline()
ChannelPipeline
ByteBufAllocator alloc()
ByteBufAllocator
这将被用于分配ByteBuf
秒。
@Deprecated <T> Attribute<T> attr(AttributeKey<T> key)
AttributeMap
复制的描述
AttributeKey
的Attribute
。
此方法永远不会返回null,但可能会返回尚未设置值的Attribute
。
attr
在界面
AttributeMap
@Deprecated <T> boolean hasAttr(AttributeKey<T> key)
AttributeMap
Attribute
存在于这个AttributeMap
。
hasAttr
在界面
AttributeMap
Copyright © 2008–2018 The Netty Project. All rights reserved.