首页 > 代码库 > Netty3 源码分析 - ChannelHandlerContext
Netty3 源码分析 - ChannelHandlerContext
Netty3 源码分析 - ChannelHandlerContext
ChannelHandlerContext存在的意义是可以让其管理的Handler与Pipeline或其他handlers进行交互,ChannelHandler的理解在前面说过。
发送事件:可以调用 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);
}
Netty3 源码分析 - ChannelHandlerContext
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。