import cn.nukkit.utils.ThreadedLogger; //导入依赖的package包/类
public UDPServerSocket(ThreadedLogger logger, int port, String interfaz) {
    this.logger = logger;
    try {
        bootstrap = new Bootstrap();
        group = new NioEventLoopGroup();
        bootstrap
                .group(group)
                .channel(NioDatagramChannel.class)
                .handler(this);
        channel = bootstrap.bind(interfaz, port).sync().channel();
    } catch (Exception e) {
        this.logger.critical("**** FAILED TO BIND TO " + interfaz + ":" + port + "!");
        this.logger.critical("Perhaps a server is already running on that port?");
        System.exit(1);
    }
}
 

import cn.nukkit.utils.ThreadedLogger; //导入依赖的package包/类
public UDPServerSocket(ThreadedLogger logger, int port, String interfaz) {
    this.logger = logger;
    try {
        bootstrap = new Bootstrap();
        group = new NioEventLoopGroup();
        bootstrap
                .group(group)
                .channel(NioDatagramChannel.class)
                .handler(this);
        channel = bootstrap.bind(interfaz, port).sync().channel();
    } catch (Exception e) {
        this.logger.critical(FastAppender.get(interfaz, ":", port, " 上でサーバーを開けませんでした。"));
        this.logger.critical("同じポートで複数のサーバーを一度に開いていませんか？");
        System.exit(1);
    }
}
 

import cn.nukkit.utils.ThreadedLogger; //导入依赖的package包/类
public UDPServerSocket(ThreadedLogger logger, int port, String interfaz) {
    this.logger = logger;
    try {
        bootstrap = new Bootstrap();
        group = new NioEventLoopGroup();
        bootstrap
                .group(group)
                .channel(NioDatagramChannel.class)
                .handler(this);
        channel = bootstrap.bind(interfaz, port).sync().channel();
    } catch (InterruptedException e) {
        this.logger.critical("**** FAILED TO BIND TO " + interfaz + ":" + port + "!");
        this.logger.critical("Perhaps a server is already running on that port?");
        System.exit(1);
    }
}
 

import cn.nukkit.utils.ThreadedLogger; //导入依赖的package包/类
public RakNetServer(ThreadedLogger logger, int port, String interfaz) {
    this.port = port;
    if (port < 1 || port > 65536) {
        throw new IllegalArgumentException("Invalid port range");
    }

    this.interfaz = interfaz;
    this.logger = logger;

    this.externalQueue = new ConcurrentLinkedQueue<>();
    this.internalQueue = new ConcurrentLinkedQueue<>();

    this.start();
}
 

import cn.nukkit.utils.ThreadedLogger; //导入依赖的package包/类
public SynapseClient(ThreadedLogger logger, int port, String interfaz) {
    this.logger = logger;
    this.interfaz = interfaz;
    this.port = port;
    if (port < 1 || port > 65536) {
        throw new IllegalArgumentException("Invalid port range");
    }
    this.shutdown = false;
    this.externalQueue = new ConcurrentLinkedQueue<>();
    this.internalQueue = new ConcurrentLinkedQueue<>();

    this.start();
}
 

import cn.nukkit.utils.ThreadedLogger; //导入依赖的package包/类
public ThreadedLogger getLogger() {
    return this.server.getLogger();
}
 

import cn.nukkit.utils.ThreadedLogger; //导入依赖的package包/类
public ThreadedLogger getLogger() {
    return logger;
}