io.netty.util.internal.SocketUtils#accept ( )源码实例Demo

@Override
protected int doReadMessages(List<Object> buf) throws Exception {
    SocketChannel ch = SocketUtils.accept(javaChannel());

    try {
        if (ch != null) {
            buf.add(new NioSocketChannel(this, ch));
            return 1;
        }
    } catch (Throwable t) {
        logger.warn("Failed to create a new channel from an accepted socket.", t);

        try {
            ch.close();
        } catch (Throwable t2) {
            logger.warn("Failed to close a socket.", t2);
        }
    }

    return 0;
}
 

@Override
protected int doReadMessages(List<Object> buf) throws Exception {
    final SocketChannelUDT channelUDT = (SocketChannelUDT) SocketUtils.accept(javaChannel());
    if (channelUDT == null) {
        return 0;
    } else {
        buf.add(newConnectorChannel(channelUDT));
        return 1;
    }
}