由于文章篇幅的关系，作为 Reactor 在 netty 中实现的第一篇我们主要来介绍主从 Reactor
Group 的创建流程，骨架脉络先搭好。
下面我们来看一段 Netty 服务端代码的编写模板，从代码模板的流程中我们来解析下主从
Reactor 的创建流程以及在这个过程中所涉及到的 Netty 核心类。
Netty 服务端代码模板
/**
* Echoes back any received data from a client.
*/
public final class EchoServer {
static final int PORT = Integer.parseInt(System.getProperty(“port”, “8007”));
public static void main(String[] args) throws Exception {
// Configure the server.
//创建主从 Reactor 线程组
EventLoopGroup bossGroup = new NioEventLoopGroup(1);
EventLoopGroup workerGroup = new NioEventLoopGroup();
final EchoServerHandler serverHandler = new EchoServerHandler();
try {
ServerBootstrap b = new ServerBootstrap();
b.group(bossGroup, workerGroup)//配置主从 Reactor
.channel(NioServerSocketChannel.class)//配置主 Reactor 中的 channel 类型
.option(ChannelOption.SO_BACKLOG, 100)//设置主 Reactor 中 channel 的 option
选项
.handler(new LoggingHandler(LogLevel.INFO))// 设 置 主 Reactor 中
Channel->pipline->handler
.childHandler(new ChannelInitializer() {//设置从 Reactor 中注册 channel 的 pipeline
@Override
public void initChannel(SocketChannel ch) throws Exception {
ChannelPipeline p = ch.pipeline();
//p.addLast(new LoggingHandler(LogLevel.INFO));
p.addLast(serverHandler);
}
});
// Start the server. 绑定端口启动服务，开始监听 accept 事件
ChannelFuture f = b.bind(PORT).sync();
// Wait until the server socket is closed.
f.channel().closeFuture().sync();
} finally {
// Shut down all event loops to terminate all threads.
bossGroup.shutdownGracefully();
