SimpleEchidnaServer.java 文件源码

@Override
public void start() {
    this.bossGroup = NettyUtils.createEventLoopGroup(1);
    this.workerGroup = NettyUtils.createEventLoopGroup(4);

    Class<? extends ServerChannel> serverChannelClass = NettyUtils.getServerChannelClass();

    this.logger.info("I am going to start a server on {}:{}.", this.config.getServerHost(),
        this.config.getServerPort());

    ServerBootstrap serverBootstrap = new ServerBootstrap();
    try {
        channel = serverBootstrap
            .group(bossGroup, workerGroup)
            .channel(serverChannelClass)
            .childHandler(new ServerChannelInitializer(this))
            .childOption(ChannelOption.SO_KEEPALIVE, true)
            .bind(config.getServerHost(), config.getServerPort())
            .sync().channel();
    } catch (InterruptedException e) {
        e.printStackTrace();
    }

    this.logger.info("Started the server on {}:{}.", this.config.getServerHost(),
        this.config.getServerPort());
}