在netty基本组件介绍中，我们大致了解了netty的一些基本组件，今天我们来搭建一个基于netty的Tcp服务端程序，通过代码来了解和熟悉这些组件的功能和使用方法。
首先我们自己创建一个Server类，命名为TCPServer
第一步初始化ServerBootstrap，ServerBootstrap是netty中的一个服务器引导类，对ServerBootstrap的实例化就是创建netty服务器的入口
public class TCPServer {
private Logger log = LoggerFactory.getLogger(getClass());
//端口号
private int port=5080;
//服务器运行状态
private volatile boolean isRunning = false;
//处理Accept连接事件的线程，这里线程数设置为1即可，netty处理链接事件默认为单线程，过度设置反而浪费cpu资源
private final EventLoopGroup bossGroup = new NioEventLoopGroup(1);
//处理hadnler的工作线程，其实也就是处理IO读写 。线程数据默认为 CPU 核心数乘以2
private final EventLoopGroup workerGroup = new NioEventLoopGroup();
public void init() throws Exception{
//创建ServerBootstrap实例
ServerBootstrap serverBootstrap=new ServerBootstrap();
//初始化ServerBootstrap的线程模型
serverBootstrap.group(workerGroup,workerGroup);//
//设置将要被实例化的ServerChannel类
serverBootstrap.channel(NioServerSocketChannel.class);//
//在ServerChannelInitializer中初始化ChannelPipeline责任链，并添加到serverBootstrap中
serverBootstrap.childHandler(new ServerChannelInitializer());
//标识当服务器请求处理线程全满时，用于临时存放已完成三次握手的请求的队列的最大长度
serverBootstrap.option(ChannelOption.SO_BACKLOG, 1024);
// 是否启用心跳保活机机制
serverBootstrap.childOption(ChannelOption.SO_KEEPALIVE, true);
//绑定端口后，开启监听
ChannelFuture channelFuture = serverBootstrap.bind(port).sync();
if(channelFuture.isSuccess()){
System.out.println("TCP服务启动 成功---------------");
}
}
/**
* 服务启动
*/
public synchronized void startServer() {
try {
this.init();
}catch(Exception ex) {
}
}
/**
* 服务关闭
*/
public synchronized void stopServer() {
if (!this.isRunning) {
throw new IllegalStateException(this.getName() + " 未启动 .");
}
this.isRunning = false;
try {
Future<?> future = this.workerGroup.shutdownGracefully().await();
if (!future.isSuccess()) {
log.error("workerGroup 无法正常停止:{}", future.cause());
}
future = this.bossGroup.shutdownGracefully().await();
if (!future.isSuccess()) {
log.error("bossGroup 无法正常停止:{}", future.cause());
}
} catch (InterruptedException e) {
e.printStackTrace();
}
this.log.info("TCP服务已经停止...");
}
private String getName() {
return "TCP-Server";
}
}
上面的代码中主要使用到的ServerBootstrap类的方法有以下这些：
group ：设置SeverBootstrap要用到的EventLoopGroup，也就是定义netty服务的线程模型，处理Acceptor链接的主"线程池"以及用于I/O工作的从"线程池"；
channel：设置将要被实例化的SeverChannel类；
option ：指定要应用到新创建SeverChannel的ChannelConfig的ChannelOption.其实也就是服务本身的一些配置；
chidOption：子channel的ChannelConfig的ChannelOption。也就是与客户端建立的连接的一些配置；