Practical Netty (4) 父子频道关系&＃xff0c;频道与管道的关系

• 作者&＃xff1a;柳大·Poechant&＃xff08;钟超&＃xff09;
• 邮箱&＃xff1a;zhongchao.ustc#gmail.com&＃xff08;# -> &＃64;&＃xff09;
• 博客&＃xff1a;Blog.CSDN.net/Poechant
• 微博&＃xff1a;weibo.com/lauginhom
• 日期&＃xff1a;June 10^th, 2012

&＃xff08;下面这段话是完成本文后写的&＃xff09;我姑且将 Parent channel 称为父频道&＃xff0c;Child Channel 称为子频道&＃xff0c;Channel 就是频道了&＃xff0c;而 ChannelPipeline 则称为管道。这样的目的只有一个&＃xff0c;就是能在 CSDN 博客里把标题弄短一点。。。当然了&＃xff0c;下文中仍然用了英文名称&＃xff0c;因为上面这几个中文名称是我写完本文后回头起标题的时候&＃xff0c;为了缩短才搞的&＃xff0c;哈哈。

1. Netty 核心概念之三&＃xff1a;Parent Channel 与 Child Channels

一个 ServerBootstrap 启动后&＃xff0c;会创建一个 parent channel&＃xff0c;这个 parent channel 用于接受 connections&＃xff0c;每个 connection 会被分配到一个 child channel 上&＃xff0c;用于后续的处理。

Parent channel 和 child channels 的 options 是由 ServerBootstrap 来设置的。可设置的 key 和 value type 如下&＃xff1a;

• "localAddress"&＃xff0c;InetSocketAddress
• "keepAlive"&＃xff0c;boolean
• "reuseAddress"&＃xff0c;boolean
• "soLinger"&＃xff0c;int
• "tcpNoDelay"&＃xff0c;boolean
• "receiveBufferSize"&＃xff0c;int
• "sendBufferSize"&＃xff0c;int
• "trafficClass"&＃xff0c;int

一段示例代码&＃xff1a;

bootstrap.setOption("reuseAddress", true);
bootstrap.setOption("localAddress", new InetSocketAddress(port));
bootstrap.setOption("child.tcpNoDelay", true);
bootstrap.setOption("child.receiveBufferSize", 1048576);


_{转载请注明来自柳大的CSDN博客&＃xff1a;Blog.CSDN.net/Poechant&＃xff0c;微博&＃xff1a;weibo.com/lauginhom}

2. Netty 核心概念之四&＃xff1a;Channel 与 ChannelPipeline

先看 Netty 官方文档的一段话&＃xff1a;

For each new channel, a new pipeline must be created and attached to the
channel. Once attached, the coupling between the channel and the pipeline
is permanent; the channel cannot attach another pipeline to it nor detach
the current pipeline from it.


每个 Channel 都有对应的一个 ChannelPipe&＃xff0c;而且必须有。对于一个 Bootstrap&＃xff0c;你需要指定它的 ChannelPipeline 如何产生&＃xff0c;这通过&＃xff1a;

bootstrap.setPipelineFactory(ChannelPipelineFactory factory);


来实现。ChannelPipelineFactory是一个Interface&＃xff0c;所以你需要implements它&＃xff0c;举例如下&＃xff1a;

bootstrap.setPipelineFactory(new ChannelPipelineFactory() {ChannelPipeline p &＃61; Channels.pipeline();p.addLast("handler", new PoechantProxyHandler());
});


这是一个匿名类的实现方式&＃xff0c;实名类你也应该懂的。官方那段话告诉我们&＃xff0c;你给一个 Channel 只能 attach 一个 ChannelPipeline&＃xff0c;而且一旦 attach 就不能 detach 了&＃xff0c;这也就是为什么会有一个 setPipelineFactory 的东东的原因&＃xff0c;它来定义给你的 Channel 绑定 ChannelPipeline 的规则&＃xff08;包括什么样的 ChannelPipeline&＃xff09;。

-

转载请注明来自柳大的CSDN博客&＃xff1a;Blog.CSDN.net/Poechant&＃xff0c;微博&＃xff1a;weibo.com/lauginhom

-