From b0e149febb6f4ef559290e392588750ea7511276 Mon Sep 17 00:00:00 2001 From: MiniDay <372403923@qq.com> Date: Mon, 18 Mar 2024 18:05:57 +0800 Subject: [PATCH] =?UTF-8?q?perf:=20=E7=AE=80=E5=8C=96=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../hamster3/mc/plugin/ball/bukkit/HamsterBallPlugin.java | 2 +- .../hamster3/mc/plugin/ball/bungee/HamsterBallPlugin.java | 2 +- .../java/cn/hamster3/mc/plugin/ball/common/api/BallAPI.java | 4 ++-- .../hamster3/mc/plugin/ball/velocity/HamsterBallPlugin.java | 6 +++--- 4 files changed, 7 insertions(+), 7 deletions(-) diff --git a/ball-bukkit/src/main/java/cn/hamster3/mc/plugin/ball/bukkit/HamsterBallPlugin.java b/ball-bukkit/src/main/java/cn/hamster3/mc/plugin/ball/bukkit/HamsterBallPlugin.java index 3aec090..24c47e9 100644 --- a/ball-bukkit/src/main/java/cn/hamster3/mc/plugin/ball/bukkit/HamsterBallPlugin.java +++ b/ball-bukkit/src/main/java/cn/hamster3/mc/plugin/ball/bukkit/HamsterBallPlugin.java @@ -98,7 +98,7 @@ public class HamsterBallPlugin extends JavaPlugin { BallBukkitUtils.uploadPlayerInfo(playerInfo); }); } else { - BallAPI.getInstance().subscribeIgnorePrefix(BallAPI.PLAYER_INFO_CHANNEL); + BallAPI.getInstance().subscribeRaw(BallAPI.PLAYER_INFO_CHANNEL); } sync(() -> { if (Bukkit.getPluginManager().isPluginEnabled("PlaceholderAPI")) { diff --git a/ball-bungee/src/main/java/cn/hamster3/mc/plugin/ball/bungee/HamsterBallPlugin.java b/ball-bungee/src/main/java/cn/hamster3/mc/plugin/ball/bungee/HamsterBallPlugin.java index 1dde4cf..6da3873 100644 --- a/ball-bungee/src/main/java/cn/hamster3/mc/plugin/ball/bungee/HamsterBallPlugin.java +++ b/ball-bungee/src/main/java/cn/hamster3/mc/plugin/ball/bungee/HamsterBallPlugin.java @@ -76,7 +76,7 @@ public class HamsterBallPlugin extends Plugin { if (BallAPI.getInstance().getBallConfig().isGameServerUpdatePlayerInfo()) { BallAPI.getInstance().subscribePatterns("*" + BallAPI.PLAYER_INFO_CHANNEL); } else { - BallAPI.getInstance().subscribeIgnorePrefix(BallAPI.PLAYER_INFO_CHANNEL); + BallAPI.getInstance().subscribeRaw(BallAPI.PLAYER_INFO_CHANNEL); } BallAPI.getInstance().sendRawBallMessage( BallAPI.BALL_CHANNEL, BallActions.ServerOnline.name(), diff --git a/ball-common/src/main/java/cn/hamster3/mc/plugin/ball/common/api/BallAPI.java b/ball-common/src/main/java/cn/hamster3/mc/plugin/ball/common/api/BallAPI.java index 7470a85..38d85f3 100644 --- a/ball-common/src/main/java/cn/hamster3/mc/plugin/ball/common/api/BallAPI.java +++ b/ball-common/src/main/java/cn/hamster3/mc/plugin/ball/common/api/BallAPI.java @@ -179,7 +179,7 @@ public abstract class BallAPI { } getLogger().info("从数据库中加载了 " + allServerInfo.size() + " 条服务器信息"); getLogger().info("从数据库中加载了 " + allPlayerInfo.size() + " 条玩家信息"); - subscribeIgnorePrefix(BALL_CHANNEL); + subscribeRaw(BALL_CHANNEL); } protected void disable() throws SQLException, InterruptedException { @@ -522,7 +522,7 @@ public abstract class BallAPI { * * @param channel 频道名称 */ - public void subscribeIgnorePrefix(@NotNull String... channel) { + public void subscribeRaw(@NotNull String... channel) { CoreAPI.getInstance().getExecutorService().submit( () -> redisSub.subscribe(BallRedisListener.INSTANCE, channel) ); diff --git a/ball-velocity/src/main/java/cn/hamster3/mc/plugin/ball/velocity/HamsterBallPlugin.java b/ball-velocity/src/main/java/cn/hamster3/mc/plugin/ball/velocity/HamsterBallPlugin.java index 716e38c..bf5425e 100644 --- a/ball-velocity/src/main/java/cn/hamster3/mc/plugin/ball/velocity/HamsterBallPlugin.java +++ b/ball-velocity/src/main/java/cn/hamster3/mc/plugin/ball/velocity/HamsterBallPlugin.java @@ -95,16 +95,16 @@ public class HamsterBallPlugin { return; } BallAPI.getInstance().getEventBus().register(BallVelocityListener.INSTANCE); - logger.info("已注册监听器 BallBungeeListener"); + logger.info("已注册监听器 BallVelocityListener"); proxyServer.getEventManager().register(this, BallVelocityMainListener.INSTANCE); - logger.info("已注册监听器 BallBungeeMainListener"); + logger.info("已注册监听器 BallVelocityMainListener"); proxyServer.getEventManager().register(this, UpdatePlayerInfoListener.INSTANCE); logger.info("已注册监听器 UpdatePlayerInfoListener"); if (BallAPI.getInstance().getBallConfig().isGameServerUpdatePlayerInfo()) { BallAPI.getInstance().subscribePatterns("*" + BallAPI.PLAYER_INFO_CHANNEL); } else { - BallAPI.getInstance().subscribeIgnorePrefix(BallAPI.PLAYER_INFO_CHANNEL); + BallAPI.getInstance().subscribeRaw(BallAPI.PLAYER_INFO_CHANNEL); } BallAPI.getInstance().sendRawBallMessage( BallAPI.BALL_CHANNEL, BallActions.ServerOnline.name(),