NetWork

/**
 * Adds a channel that listens on publicly accessible network ports
 */
public void addLanEndpoint(InetAddress address, int port) throws IOException
{
    if (address instanceof java.net.Inet6Address) System.setProperty("java.net.preferIPv4Stack", "false");
    synchronized (this.endpoints)
    {
        Class <? extends ServerSocketChannel > oclass;
        LazyLoadBase <? extends EventLoopGroup > lazyloadbase;
    if (Epoll.isAvailable() && this.mcServer.shouldUseNativeTransport())
    {
        oclass = EpollServerSocketChannel.class;
        lazyloadbase = SERVER_EPOLL_EVENTLOOP;
        LOGGER.info(&quot;Using epoll channel type&quot;);
    }
    else
    {
        oclass = NioServerSocketChannel.class;
        lazyloadbase = SERVER_NIO_EVENTLOOP;
        LOGGER.info(&quot;Using default channel type&quot;);
    }

    this.endpoints
					.add(((ServerBootstrap)((ServerBootstrap)(new ServerBootstrap()).channel(oclass)).childHandler(new ChannelInitializer&lt;Channel&gt;()
    {
        protected void initChannel(Channel p_initChannel_1_) throws Exception
        {
							//每有一个连接就会新建一个channel
            try
            {
                p_initChannel_1_.config().setOption(ChannelOption.TCP_NODELAY, Boolean.valueOf(true));
            }
            catch (ChannelException var3)
            {
                ;
            }

            p_initChannel_1_.pipeline().addLast(&quot;timeout&quot;, new ReadTimeoutHandler(net.minecraftforge.fml.common.network.internal.FMLNetworkHandler.READ_TIMEOUT)).addLast(&quot;legacy_query&quot;, new LegacyPingHandler(NetworkSystem.this)).addLast(&quot;splitter&quot;, new NettyVarint21FrameDecoder()).addLast(&quot;decoder&quot;, new NettyPacketDecoder(EnumPacketDirection.SERVERBOUND)).addLast(&quot;prepender&quot;, new NettyVarint21FrameEncoder()).addLast(&quot;encoder&quot;, new NettyPacketEncoder(EnumPacketDirection.CLIENTBOUND));
            NetworkManager networkmanager = new NetworkManager(EnumPacketDirection.SERVERBOUND);
            NetworkSystem.this.networkManagers.add(networkmanager);
            p_initChannel_1_.pipeline().addLast(&quot;packet_handler&quot;, networkmanager);

                networkmanager.setNetHandler(new NetHandlerHandshakeTCP(NetworkSystem.this.mcServer, networkmanager));

            }

}).group(lazyloadbase.getValue()).localAddress(address, port)).bind().syncUninterruptibly());

}

}

/**
 * Sets the NetHandler for this NetworkManager, no checks are made if this handler is suitable for the particular
 * connection state (protocol)
 */
public void setNetHandler(INetHandler handler)
{
    Validate.notNull(handler, "packetListener");
    LOGGER.debug("Set listener of {} to {}", this, handler);
    this.packetListener = handler;
}

            <div style="color: inherit; fill: inherit;">
                <div style="display: flex;">