nosum-gateway/src/main/java/cn/nosum/gateway/container/NettyGateWayContainer.java

package cn.nosum.gateway.container;

import cn.nosum.common.annotation.Adaptive;
import cn.nosum.common.util.Convert;
import cn.nosum.common.util.PropertiesUtil;
import cn.nosum.gateway.handler.build.HandlerProvider;
import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.*;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;


@Adaptive
public class NettyGateWayContainer implements GateWayContainer {
	Logger logger= LoggerFactory.getLogger(NettyGateWayContainer.class);
	private int port = Convert.toInt(PropertiesUtil.getProperty("container.port"));
	public void start(){
		// Boss线程
		EventLoopGroup bossGroup = new NioEventLoopGroup();
		// Worker线程
		EventLoopGroup workerGroup = new NioEventLoopGroup();
		try {
			ServerBootstrap server = new ServerBootstrap();
			server.group(bossGroup, workerGroup)
					.channel(NioServerSocketChannel.class)
					// 子线程处理类 , Handler
					.childHandler(HandlerProvider.newHandlerChannel())
					// 针对主线程的配置 分配线程最大数量 128
					.option(ChannelOption.SO_BACKLOG, 128)
					// 针对子线程的配置 保持长连接
					.childOption(ChannelOption.SO_KEEPALIVE, true);

			// 启动服务器
			ChannelFuture f = server.bind(port).sync();
			logger.debug("NettyGateWayContainer启动成功,访问端口号是：{}",port);
			f.channel().closeFuture().sync();
		}catch (Exception e){
			e.printStackTrace();
		}finally {
			// 关闭线程池
			bossGroup.shutdownGracefully();
			workerGroup.shutdownGracefully();
		}
	}
}