Netty3 源码分析 - ChannelHandlerContext
发送事件:可以调用 sendUpstream(ChannelEvent)
或sendDownstream(ChannelEvent)将一个事件传递给这个Pipeline中与其最近的那个Handler。
修改pipeline:调用 getPipeline()可以得到这个Handler所属的ChannelPipeline对象,当然也可以运行时更新(加入,移除)这个pipeline中的Handlers。
提取备用(Retrieving for later use):可以持有一个ChannelHandlerContext,为了以后使用。(这里有待深入理解)
存储状态信息:见ChannelHandler。
一个Handler可以有多个Context:这就意味着如果这些Context加入到了不同的pipeline中,这些Handler实例就会执行多次。下面这个API中的例子,对于每次接收到的一个数字,做累积,把结果存在attachment中。
public class FactorialHandler extends SimpleChannelHandler
{
// This handler will receive a sequence of increasing
integers starting
// from 1.
@Override
public void messageReceived(ChannelHandlerContext
ctx, MessageEvent evt) {
Integer a = (Integer) ctx.getAttachment();
Integer b = (Integer) evt.getMessage();
if (a
== null ) {
a = 1;
}
ctx.setAttachment(Integer. valueOf(a * b));
}
}
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);
如果俩pipeline都启动的话,就会正确的执行四次乘法操作。
到这里,再看ChannelHandlerContext 的源码就一目了然了。
public interface ChannelHandlerContext
{
// 得到这个pipeline所属的Channel,等价于getPipeline().getChannel()
Channel getChannel();
// Handler所属的pipeline
ChannelPipeline getPipeline();
// Handler都有对应的名字
String getName();
// 返回这个Context维护的Handler
ChannelHandler getHandler();
// 对应的Handler类型,看是否是ChannelUpstreamHandler,ChannelDownstreamHandler实例
boolean canHandleUpstream();
boolean canHandleDownstream();
//传递事件给最近的Handler
void sendUpstream(ChannelEvent
e);
void sendDownstream(ChannelEvent
e);
Object getAttachment();
void setAttachment(Object
attachment);
}