netty服务端的创建

就以netty-example中的EchoServer这个经典例子作为楔子吧

// 创建bossGroup和workerGroup,reactor模式的实现

EventLoopGroup bossGroup = new NioEventLoopGroup(1);

EventLoopGroup workerGroup = new NioEventLoopGroup();

final EchoServerHandler serverHandler = new EchoServerHandler();

try {

ServerBootstrap b = new ServerBootstrap();

// 在启动引导类ServerBootstrap中配置各种serverSocketChannel和socketChannel属性

b.group(bossGroup, workerGroup)

.channel(NioServerSocketChannel.class)

.option(ChannelOption.SO_BACKLOG, 100)

.attr(AttributeKey.newInstance("attr"), "attr")

.handler(new LoggingHandler(LogLevel.INFO))

.childHandler(new channelInitializer {

@Override

public void initChannel(SocketChannel ch)throws Exception {

ChannelPipeline p = ch.pipeline();

if (sslCtx != null) {

p.addLast(sslCtx.newHandler(ch.alloc()));

}

//p.addLast(new LoggingHandler(LogLevel.INFO));

p.addLast(serverHandler);

}

})

.childOption(ChannelOption.CONNECT_TIMEOUT_MILLIS, 3000)

.childAttr(AttributeKey.newInstance("childAttr"), "childAttr");

// bind方法开始启动服务端
ChannelFuture f = b.bind(PORT).sync();

// 在sync方法中main线程阻塞直到服务器关闭
f.channel().closeFuture().sync();

标签：netty,ch,addLast,创建,sync,childAttr,workerGroup,new,服务端
来源： https://www.cnblogs.com/spiritsx/p/11839066.html