• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Java SourceInterface类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中cn.nukkit.network.SourceInterface的典型用法代码示例。如果您正苦于以下问题:Java SourceInterface类的具体用法?Java SourceInterface怎么用?Java SourceInterface使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



SourceInterface类属于cn.nukkit.network包,在下文中一共展示了SourceInterface类的13个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: Player

import cn.nukkit.network.SourceInterface; //导入依赖的package包/类
public Player(SourceInterface interfaz, Long clientID, String ip, int port) {
    super(null, new CompoundTag());
    this.interfaz = interfaz;
    this.windows = new HashMap<>();
    this.perm = new PermissibleBase(this);
    this.server = Server.getInstance();
    this.lastBreak = Long.MAX_VALUE;
    this.ip = ip;
    this.port = port;
    this.clientID = clientID;
    this.loaderId = Level.generateChunkLoaderId(this);
    this.chunksPerTick = (int) this.server.getConfig("chunk-sending.per-tick", 4);
    this.spawnThreshold = (int) this.server.getConfig("chunk-sending.spawn-threshold", 56);
    this.spawnPosition = null;
    this.gamemode = this.server.getGamemode();
    this.setLevel(this.server.getDefaultLevel());
    this.viewDistance = this.server.getViewDistance();
    this.chunkRadius = viewDistance;
    //this.newPosition = new Vector3(0, 0, 0);
    this.boundingBox = new AxisAlignedBB(0, 0, 0, 0, 0, 0);

    this.uuid = null;
    this.rawUUID = null;

    this.creationTime = System.currentTimeMillis();
}
 
开发者ID:Rsplwe,项目名称:Nukkit-Java9,代码行数:27,代码来源:Player.java


示例2: Player

import cn.nukkit.network.SourceInterface; //导入依赖的package包/类
public Player(SourceInterface interfaz, Long clientID, String ip, int port) {
    super(null, new CompoundTag());
    this.interfaz = interfaz;
    this.windows = new HashMap<>();
    this.perm = new PermissibleBase(this);
    this.server = Server.getInstance();
    this.lastBreak = Long.MAX_VALUE;
    this.ip = ip;
    this.port = port;
    this.clientID = clientID;
    this.loaderId = Level.generateChunkLoaderId(this);
    this.chunksPerTick = (int) this.server.getConfig("chunk-sending.per-tick", 4);
    this.spawnThreshold = (int) this.server.getConfig("chunk-sending.spawn-threshold", 56);
    this.spawnPosition = null;
    this.gamemode = this.server.getGamemode();
    this.setLevel(this.server.getDefaultLevel());
    this.viewDistance = this.server.getViewDistance();
    //this.newPosition = new Vector3(0, 0, 0);
    this.boundingBox = new AxisAlignedBB(0, 0, 0, 0, 0, 0);

    this.uuid = null;
    this.rawUUID = null;

    this.creationTime = System.currentTimeMillis();
}
 
开发者ID:Creeperface01,项目名称:NukkitGT,代码行数:26,代码来源:Player.java


示例3: PlayerCreationEvent

import cn.nukkit.network.SourceInterface; //导入依赖的package包/类
public PlayerCreationEvent(SourceInterface interfaz, Class<? extends Player> baseClass, Class<? extends Player> playerClass, Long clientId, String address, int port) {
    this.interfaz = interfaz;
    this.clientId = clientId;
    this.address = address;
    this.port = port;

    this.baseClass = baseClass;
    this.playerClass = playerClass;
}
 
开发者ID:Rsplwe,项目名称:Nukkit-Java9,代码行数:10,代码来源:PlayerCreationEvent.java


示例4: Player

import cn.nukkit.network.SourceInterface; //导入依赖的package包/类
public Player(SourceInterface interfaz, Long clientID, String ip, int port) {
    super(null, new CompoundTag());
    this.interfaz = interfaz;
    this.windows = new HashMap<>();
    this.perm = new PermissibleBase(this);
    this.server = Server.getInstance();
    this.lastBreak = Long.MAX_VALUE;
    this.ip = ip;
    this.port = port;
    this.clientID = clientID;
    this.loaderId = Level.generateChunkLoaderId(this);
    this.chunksPerTick = (int) this.server.getConfig("chunk-sending.per-tick", 4);
    this.spawnThreshold = (int) this.server.getConfig("chunk-sending.spawn-threshold", 56);
    this.spawnPosition = null;
    this.gamemode = this.server.getDefaultGamemode();
    this.setLevel(this.server.getDefaultLevel());
    this.viewDistance = this.server.getViewDistance();
    this.chunkRadius = viewDistance;
    //this.newPosition = new Vector3(0, 0, 0);
    this.boundingBox = new AxisAlignedBB(0, 0, 0, 0, 0, 0);

    this.uuid = null;
    this.rawUUID = null;

    this.creationTime = System.currentTimeMillis();
    this.enableRevert = this.server.getJupiterConfigBoolean("enable-revert");
    this.server.getJupiterConfigBoolean("allow-snowball");
    this.server.getJupiterConfigBoolean("allow-egg");
    this.server.getJupiterConfigBoolean("allow-enderpearl");
    this.server.getJupiterConfigBoolean("allow-experience-bottle");
    this.server.getJupiterConfigBoolean("allow-splash-potion");
    this.server.getJupiterConfigBoolean("allow-bow");
    this.server.getJupiterConfigBoolean("allow-fishing-rod");

    this.printPackets = this.getServer().printPackets();
}
 
开发者ID:JupiterDevelopmentTeam,项目名称:Jupiter,代码行数:37,代码来源:Player.java


示例5: SynapseAPI

import cn.nukkit.network.SourceInterface; //导入依赖的package包/类
public SynapseAPI(Server server) {
    instance = this;
    this.server = server;
    enable = (boolean) server.getAdvancedProperty("synapse.enable", true);
    if (!enable) {
        return;
    }
    this.serverIp = (String) server.getAdvancedProperty("synapse.server-ip", "127.0.0.1");
    this.port = (int) server.getAdvancedProperty("synapse.server-port", 10305);
    this.isMainServer = (boolean) server.getAdvancedProperty("synapse.is-main-server", true);
    this.password = (String) server.getAdvancedProperty("synapse.password", "0123456789abcdef");
    if (this.password.length() != 16) {
        this.getLogger().warning("You must use a 16 bit length key!");
        this.getLogger().warning("The Synapse will not be enabled!");
        enable = false;
        return;
    }
    this.serverDescription = (String) server.getAdvancedProperty("synapse.description", "A Synapse client");
    for(SourceInterface interfaz : this.getServer().getNetwork().getInterfaces()){
        if(interfaz instanceof RakNetInterface){
            boolean disableRak = (boolean) server.getAdvancedProperty("synapse.disable-rak", false);
            if(disableRak){
                interfaz.shutdown();
                this.getLogger().notice("RakNet has been disabled by synapse.disable-rak option.");
                break;
            }
        }
    }
    this.synapseInterface = new SynapseInterface(this, this.serverIp, this.port);
    this.synLibInterface = new SynLibInterface(this.synapseInterface);
    this.lastUpdate = System.currentTimeMillis();
    this.lastRecvInfo = System.currentTimeMillis();
    try{
        this.connect();
    } catch(Exception e){
        this.connect(); //Ya, this works!
    }
}
 
开发者ID:PrismarineMC,项目名称:MagmaBlock,代码行数:39,代码来源:SynapseAPI.java


示例6: SynapsePlayerCreationEvent

import cn.nukkit.network.SourceInterface; //导入依赖的package包/类
public SynapsePlayerCreationEvent(SourceInterface interfaz, Class<? extends SynapsePlayer> baseClass, Class<? extends SynapsePlayer> playerClass, Long clientId, String address, int port) {
    this.interfaz = interfaz;
    this.clientId = clientId;
    this.address = address;
    this.port = port;

    this.baseClass = baseClass;
    this.playerClass = playerClass;
}
 
开发者ID:PrismarineMC,项目名称:MagmaBlock,代码行数:10,代码来源:SynapsePlayerCreationEvent.java


示例7: loadEntries

import cn.nukkit.network.SourceInterface; //导入依赖的package包/类
private void loadEntries() {
    this.saveDefaultConfig();
    enable = this.getConfig().getBoolean("enable", true);
    this.autoCompress = this.getConfig().getBoolean("autoCompress", true);
    if (!enable) {
        this.getLogger().warning("The SynapseAPI is not be enabled!");
    } else {
        if (this.getConfig().getBoolean("disable-rak")) {
            for (SourceInterface sourceInterface : this.getServer().getNetwork().getInterfaces()) {
                if (sourceInterface instanceof RakNetInterface) {
                    sourceInterface.shutdown();
                }
            }
        }

        List entries = this.getConfig().getList("entries");

        for (Object entry : entries) {
            @SuppressWarnings("unchecked")
            ConfigSection section = new ConfigSection((LinkedHashMap) entry);
            String serverIp = section.getString("server-ip", "127.0.0.1");
            int port = section.getInt("server-port", 10305);
            boolean isMainServer = section.getBoolean("isMainServer");
            String password = section.getString("password");
            String serverDescription = section.getString("description");
            this.autoConnect = section.getBoolean("autoConnect", true);
            if (this.autoConnect) {
                this.addSynapseAPI(new SynapseEntry(this, serverIp, port, isMainServer, password, serverDescription));
            }
        }

    }
}
 
开发者ID:iTXTech,项目名称:SynapseAPI,代码行数:34,代码来源:SynapseAPI.java


示例8: run

import cn.nukkit.network.SourceInterface; //导入依赖的package包/类
@Override
public void run() {
    PlayerLoginPacket playerLoginPacket;
    while ((playerLoginPacket = playerLoginQueue.poll()) != null) {
        SynapsePlayerCreationEvent ev = new SynapsePlayerCreationEvent(synLibInterface, SynapsePlayer.class, SynapsePlayer.class, new Random().nextLong(), playerLoginPacket.address, playerLoginPacket.port);
        getSynapse().getServer().getPluginManager().callEvent(ev);
        Class<? extends SynapsePlayer> clazz = ev.getPlayerClass();
        try {
            Constructor constructor = clazz.getConstructor(SourceInterface.class, SynapseEntry.class, Long.class, String.class, int.class);
            SynapsePlayer player = (SynapsePlayer) constructor.newInstance(synLibInterface, this.entry, ev.getClientId(), ev.getAddress(), ev.getPort());
            player.setUniqueId(playerLoginPacket.uuid);
            players.put(playerLoginPacket.uuid, player);
            getSynapse().getServer().addPlayer(playerLoginPacket.uuid.toString(), player);
            player.handleLoginPacket(playerLoginPacket);
        } catch (NoSuchMethodException | InvocationTargetException | InstantiationException | IllegalAccessException e) {
            Server.getInstance().getLogger().logException(e);
        }
    }

    RedirectPacketEntry redirectPacketEntry;
    while ((redirectPacketEntry = redirectPacketQueue.poll()) != null) {
        //Server.getInstance().getLogger().warning("C => S  " + redirectPacketEntry.dataPacket.getClass().getSimpleName());
        redirectPacketEntry.player.handleDataPacket(redirectPacketEntry.dataPacket);
    }

    PlayerLogoutPacket playerLogoutPacket;
    while ((playerLogoutPacket = playerLogoutQueue.poll()) != null) {
        UUID uuid1;
        if(players.containsKey(uuid1 = playerLogoutPacket.uuid)){
            players.get(uuid1).close(playerLogoutPacket.reason, playerLogoutPacket.reason, true);
            removePlayer(uuid1);
        }
    }
}
 
开发者ID:iTXTech,项目名称:SynapseAPI,代码行数:35,代码来源:SynapseEntry.java


示例9: forceShutdown

import cn.nukkit.network.SourceInterface; //导入依赖的package包/类
public void forceShutdown() {
    if (this.hasStopped) {
        return;
    }

    try {
        if (!this.isRunning) {
            //todo sendUsage
        }

        // clean shutdown of console thread asap
        this.console.shutdown();

        this.hasStopped = true;

        this.shutdown();

        if (this.rcon != null) {
            this.rcon.close();
        }

        this.getLogger().debug("Disabling all plugins");
        this.pluginManager.disablePlugins();

        for (Player player : new ArrayList<>(this.players.values())) {
            player.close(player.getLeaveMessage(), (String) this.getConfig("settings.shutdown-message", "Server closed"));
        }

        this.getLogger().debug("Unloading all levels");
        for (Level level : new ArrayList<>(this.getLevels().values())) {
            this.unloadLevel(level, true);
        }

        this.getLogger().debug("Removing event handlers");
        HandlerList.unregisterAll();

        this.getLogger().debug("Stopping all tasks");
        this.scheduler.cancelAllTasks();
        this.scheduler.mainThreadHeartbeat(Integer.MAX_VALUE);

        this.getLogger().debug("Closing console");
        this.console.interrupt();

        this.getLogger().debug("Stopping network interfaces");
        for (SourceInterface interfaz : this.network.getInterfaces()) {
            interfaz.shutdown();
            this.network.unregisterInterface(interfaz);
        }

        this.getLogger().debug("Disabling timings");
        Timings.stopServer();
        //todo other things
    } catch (Exception e) {
        this.logger.logException(e); //todo remove this?
        this.logger.emergency("Exception happened while shutting down, exit the process");
        System.exit(1);
    }
}
 
开发者ID:Rsplwe,项目名称:Nukkit-Java9,代码行数:59,代码来源:Server.java


示例10: getInterface

import cn.nukkit.network.SourceInterface; //导入依赖的package包/类
public SourceInterface getInterface() {
    return interfaz;
}
 
开发者ID:Rsplwe,项目名称:Nukkit-Java9,代码行数:4,代码来源:PlayerCreationEvent.java


示例11: SynapsePlayer

import cn.nukkit.network.SourceInterface; //导入依赖的package包/类
public SynapsePlayer(SourceInterface interfaz, Long clientID, String ip, int port) {
    super(interfaz, clientID, ip, port);
}
 
开发者ID:PrismarineMC,项目名称:MagmaBlock,代码行数:4,代码来源:SynapsePlayer.java


示例12: forceShutdown

import cn.nukkit.network.SourceInterface; //导入依赖的package包/类
public void forceShutdown() {
    if (this.hasStopped) {
        return;
    }

    try {
        if (!this.isRunning) {
            //todo sendUsage
        }

        // clean shutdown of console thread asap
        this.console.shutdown();

        this.hasStopped = true;

        this.shutdown();

        if (this.rcon != null) {
            this.rcon.close();
        }

        this.getLogger().debug("Disabling all plugins");
        this.pluginManager.disablePlugins();

        for (Player player : new ArrayList<>(this.players.values())) {
            player.close(player.getLeaveMessage(), (String) this.getConfig("settings.shutdown-message", "Server closed"));
        }

        this.getLogger().debug("Unloading all levels");
        for (Level level : new ArrayList<>(this.getLevels().values())) {
            this.unloadLevel(level, true);
        }

        this.getLogger().debug("Removing event handlers");
        HandlerList.unregisterAll();

        this.getLogger().debug("Stopping all tasks");
        this.scheduler.cancelAllTasks();
        this.scheduler.mainThreadHeartbeat(Integer.MAX_VALUE);

        this.getLogger().debug("Closing console");
        this.console.interrupt();

        if(synapse != null) {
            this.getLogger().debug("Stopping Synapse client");
            synapse.shutdown();
        }

        this.getLogger().debug("Stopping network interfaces");
        for (SourceInterface interfaz : this.network.getInterfaces()) {
            interfaz.shutdown();
            this.network.unregisterInterface(interfaz);
        }

        this.getLogger().debug("Disabling timings");
        Timings.stopServer();
        //todo other things
    } catch (Exception e) {
        this.logger.logException(e); //todo remove this?
        this.logger.emergency("Exception happened while shutting down, exit the process");
        System.exit(1);
    }
}
 
开发者ID:PrismarineMC,项目名称:MagmaBlock,代码行数:64,代码来源:Server.java


示例13: SynapsePlayer

import cn.nukkit.network.SourceInterface; //导入依赖的package包/类
public SynapsePlayer(SourceInterface interfaz, SynapseEntry synapseEntry, Long clientID, String ip, int port) {
    super(interfaz, clientID, ip, port);
    this.synapseEntry = synapseEntry;
    this.isSynapseLogin = this.synapseEntry != null;
}
 
开发者ID:iTXTech,项目名称:SynapseAPI,代码行数:6,代码来源:SynapsePlayer.java



注:本文中的cn.nukkit.network.SourceInterface类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java MessageFactory类代码示例发布时间:2022-05-22
下一篇:
Java PortmapRequest类代码示例发布时间:2022-05-22
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap