feat: 添加 singleton-server-id 配置

README.md

@@ -1,6 +1,6 @@
 # [HamsterBall](https://git.airgame.net/MiniDay/hamster-ball)
 
-仓鼠球：一个基于 Redis 的 Minecraft 服务端通用消息中间件（原HamsterService）
+基于 Redis 的 Minecraft 服务端通用消息中间件
 
 该插件依赖于 [仓鼠核心](https://git.airgame.net/MiniDay/hamster-core)
 
@@ -49,9 +49,9 @@ repositories {
 
 dependencies {
     // 对于 Bukkit 插件
-    compileOnly("cn.hamster3.mc.plugin:ball-bukkit:1.6.2")
+    compileOnly("cn.hamster3.mc.plugin:ball-bukkit:1.6.4")
     // 对于 BungeeCord 插件
-    compileOnly("cn.hamster3.mc.plugin:ball-bungee:1.6.2")
+    compileOnly("cn.hamster3.mc.plugin:ball-bungee:1.6.4")
 }
 ```
 
@@ -77,13 +77,13 @@ dependencies {
         <dependency>
             <groupId>cn.hamster3.mc.plugin</groupId>
             <artifactId>ball-bukkit</artifactId>
-            <version>1.6.2</version>
+            <version>1.6.4</version>
         </dependency>
         <!--对于 BungeeCord 插件-->
         <dependency>
             <groupId>cn.hamster3.mc.plugin</groupId>
             <artifactId>ball-bungee</artifactId>
-            <version>1.6.2</version>
+            <version>1.6.4</version>
         </dependency>
     </dependencies>
 </project>

ball-bukkit/src/main/resources/config.yml

@@ -1,6 +1,13 @@
 # 是否允许在控制台输出调试信息
 debug: false
 
+# 是否启用服务器 ID 单例模式
+# 启用后，当一个服务器启动后将会占用 服务器唯一识别码
+# 其他使用相同 服务器唯一识别码 的服务器将无法启动
+# 测试端中可关闭该功能
+# 推荐在正式服中开启该功能以防止服务器 ID 重复
+singleton-server-id: false
+
 # 频道名前缀
 # 使用这个配置选项可以划分子服消息通信分组
 # 只有在同一个频道名的子服才能互相通信

ball-bukkit/src/main/resources/plugin.yml

@@ -4,8 +4,15 @@ version: ${version}
 api-version: 1.13
 
 author: MiniDay
+description: ${description}
 website: https://git.airgame.net/MiniDay/hamster-ball
-description: 仓鼠球：一个基于 Redis 的 Minecraft 服务端通用消息中间件（原HamsterService）
+
+UPDATE_CHECKER:
+  VERSION: ${version}
+  CHECK_TYPE: GITEA_RELEASES
+  GIT_BASE_URL: https://git.airgame.net
+  GIT_REPO: MiniDay/hamster-ball
+  DOWNLOAD_URL: https://jenkins.airgame.net/job/opensource/job/hamster-ball/
 
 load: STARTUP
 

ball-bukkit/src/main/resources/update.yml

@@ -1,6 +0,0 @@
-version: ${version}
-CHECK_TYPE: GITEA_RELEASES
-GIT_BASE_URL: https://git.airgame.net
-GIT_REPO: MiniDay/hamster-ball
-GIT_TOKEN: a44a69a4d1b8601bf6091403247759cd28764d5e
-DOWNLOAD_URL: https://jenkins.airgame.net/job/opensource/job/hamster-ball/

ball-bungee/src/main/resources/bungee.yml

@@ -3,7 +3,15 @@ main: cn.hamster3.mc.plugin.ball.bungee.HamsterBallPlugin
 version: ${version}
 
 author: MiniDay
-description: 仓鼠球：一个基于 Redis 的 Minecraft 服务端通用消息中间件（原HamsterService）
+description: ${description}
+website: https://git.airgame.net/MiniDay/hamster-ball
+
+UPDATE_CHECKER:
+  VERSION: ${version}
+  CHECK_TYPE: GITEA_RELEASES
+  GIT_BASE_URL: https://git.airgame.net
+  GIT_REPO: MiniDay/hamster-ball
+  DOWNLOAD_URL: https://jenkins.airgame.net/job/opensource/job/hamster-ball/
 
 depend:
   - HamsterCore

ball-bungee/src/main/resources/config.yml

@@ -1,6 +1,10 @@
 # 是否允许在控制台输出调试信息
 debug: false
 
+# 是否启用服务器 ID 单例模式
+# 启用后，服务器唯一识别码 相同的服务器将无法启动
+singleton-server-id: false
+
 # 频道名前缀
 # 使用这个配置选项可以划分子服消息通信分组
 # 只有在同一个频道名的子服才能互相通信

ball-bungee/src/main/resources/update.yml

@@ -1,6 +0,0 @@
-version: ${version}
-CHECK_TYPE: GITEA_RELEASES
-GIT_BASE_URL: https://git.airgame.net
-GIT_REPO: MiniDay/hamster-ball
-GIT_TOKEN: a44a69a4d1b8601bf6091403247759cd28764d5e
-DOWNLOAD_URL: https://jenkins.airgame.net/job/opensource/job/hamster-ball/

ball-common/src/main/java/cn/hamster3/mc/plugin/ball/common/api/BallAPI.java

@@ -102,12 +102,13 @@ public abstract class BallAPI {
             getLogger().warning("已启用调试模式");
             eventBus.register(BallDebugListener.INSTANCE);
         }
+        CoreAPI.getInstance().getExecutorService().submit(() -> redisSub.subscribe(BallRedisListener.INSTANCE, BALL_CHANNEL));
     }
 
     protected void enable() throws SQLException, InterruptedException {
         try (Jedis jedis = CoreAPI.getInstance().getJedisPool().getResource()) {
             String key = "HamsterBall:ServerInfo:" + localServerInfo.getId();
-            if (jedis.exists(key)) {
+            if (jedis.exists(key) && ballConfig.isSingletonServerID()) {
                 throw new IllegalStateException("已经有一个服务器占用了该 ID");
             }
             jedis.hset(key, "id", localServerInfo.getId());
@@ -179,7 +180,6 @@ public abstract class BallAPI {
         }
         getLogger().info("从数据库中加载了 " + allServerInfo.size() + " 条服务器信息");
         getLogger().info("从数据库中加载了 " + allPlayerInfo.size() + " 条玩家信息");
-        subscribeRaw(BALL_CHANNEL);
     }
 
     protected void disable() throws SQLException, InterruptedException {
@@ -506,26 +506,29 @@ public abstract class BallAPI {
      * <p>
      * 会自动加上 config 中设置的频道前缀
      *
-     * @param channel 频道名称
+     * @param channels 频道名称
      */
-    public void subscribe(@NotNull String... channel) {
-        for (int i = 0; i < channel.length; i++) {
-            channel[i] = ballConfig.getChannelPrefix() + channel[i];
+    public void subscribe(@NotNull String... channels) {
+        for (int i = 0; i < channels.length; i++) {
+            channels[i] = ballConfig.getChannelPrefix() + channels[i];
         }
-        CoreAPI.getInstance().getExecutorService().submit(
-                () -> redisSub.subscribe(BallRedisListener.INSTANCE, channel)
-        );
+        subscribeRaw(channels);
     }
 
     /**
      * 忽略频道前缀配置，订阅 redis 消息频道
      *
-     * @param channel 频道名称
+     * @param channels 频道名称
      */
-    public void subscribeRaw(@NotNull String... channel) {
-        CoreAPI.getInstance().getExecutorService().submit(
-                () -> redisSub.subscribe(BallRedisListener.INSTANCE, channel)
-        );
+    public void subscribeRaw(@NotNull String... channels) {
+        BallRedisListener.INSTANCE.subscribe(channels);
+//        CoreAPI.getInstance().getExecutorService().submit(() -> {
+//            try {
+//                redisSub.subscribe(BallRedisListener.INSTANCE, channels);
+//            } catch (Exception | Error e) {
+//                e.printStackTrace();
+//            }
+//        });
     }
 
     /**
@@ -534,9 +537,10 @@ public abstract class BallAPI {
      * @param patterns 频道名称正则表达式
      */
     public void subscribePatterns(@NotNull String patterns) {
-        CoreAPI.getInstance().getExecutorService().submit(
-                () -> redisSub.psubscribe(BallRedisListener.INSTANCE, patterns)
-        );
+        BallRedisListener.INSTANCE.psubscribe(patterns);
+//        CoreAPI.getInstance().getExecutorService().submit(
+//                () -> redisSub.psubscribe(BallRedisListener.INSTANCE, patterns)
+//        );
     }
 
     /**
@@ -544,22 +548,22 @@ public abstract class BallAPI {
      * <p>
      * 会自动加上 config 中设置的频道前缀
      *
-     * @param channel 频道名称
+     * @param channels 频道名称
      */
-    public void unsubscribe(@NotNull String... channel) {
-        for (int i = 0; i < channel.length; i++) {
-            channel[i] = ballConfig.getChannelPrefix() + channel[i];
+    public void unsubscribe(@NotNull String... channels) {
+        for (int i = 0; i < channels.length; i++) {
+            channels[i] = ballConfig.getChannelPrefix() + channels[i];
         }
-        BallRedisListener.INSTANCE.unsubscribe(channel);
+        unsubscribeRaw(channels);
     }
 
     /**
      * 忽略频道前缀配置，取消订阅 redis 消息频道
      *
-     * @param channel 频道名称
+     * @param channels 频道名称
      */
-    public void unsubscribeIgnorePrefix(@NotNull String... channel) {
-        BallRedisListener.INSTANCE.unsubscribe(channel);
+    public void unsubscribeRaw(@NotNull String... channels) {
+        BallRedisListener.INSTANCE.unsubscribe(channels);
     }
 
     /**

ball-common/src/main/java/cn/hamster3/mc/plugin/ball/common/config/BallConfig.java

@@ -11,13 +11,16 @@ import java.util.List;
 @AllArgsConstructor
 public class BallConfig {
     private boolean debug;
+    private boolean singletonServerID;
     @NotNull
     private String channelPrefix;
     private boolean gameServerUpdatePlayerInfo;
+    @NotNull
     private List<String> loadPlayerInfoFilter;
 
     public BallConfig(@NotNull ConfigSection config) {
         debug = config.getBoolean("debug", false);
+        singletonServerID = config.getBoolean("singleton-server-id", false);
         channelPrefix = config.getString("channel-prefix", "");
         channelPrefix = channelPrefix.isEmpty() ? channelPrefix : channelPrefix + ":";
         gameServerUpdatePlayerInfo = config.getBoolean("game-server-update-player-info", false);

ball-common/src/main/java/cn/hamster3/mc/plugin/ball/common/listener/BallRedisListener.java

@@ -15,8 +15,11 @@ public class BallRedisListener extends JedisPubSub {
 
     @Override
     public void onMessage(String channel, String message) {
-        if (channel.startsWith(BallAPI.getInstance().getBallConfig().getChannelPrefix())) {
-            channel = channel.substring(BallAPI.getInstance().getBallConfig().getChannelPrefix().length());
+        CoreAPI.getInstance().getExecutorService().submit(() -> {
+            try {
+                String finalChannel = channel;
+                if (finalChannel.startsWith(BallAPI.getInstance().getBallConfig().getChannelPrefix())) {
+                    finalChannel = finalChannel.substring(BallAPI.getInstance().getBallConfig().getChannelPrefix().length());
                 }
                 BallMessage ballMessage = CoreAPI.getInstance().getGson().fromJson(message, BallMessage.class);
                 BallAPI ballAPI = BallAPI.getInstance();
@@ -27,7 +30,11 @@ public class BallRedisListener extends JedisPubSub {
                 if (ballMessage.getReceiverID() != null && !ballAPI.isLocalServer(ballMessage.getReceiverID())) {
                     return;
                 }
-        eventBus.post(new MessageReceivedEvent(channel, ballMessage));
+                eventBus.post(new MessageReceivedEvent(finalChannel, ballMessage));
+            } catch (Exception | Error e) {
+                e.printStackTrace();
+            }
+        });
     }
 
     @Override

ball-velocity/src/main/resources/config.yml

@@ -1,6 +1,10 @@
 # 是否允许在控制台输出调试信息
 debug: false
 
+# 是否启用服务器 ID 单例模式
+# 启用后，服务器唯一识别码 相同的服务器将无法启动
+singleton-server-id: false
+
 # 频道名前缀
 # 使用这个配置选项可以划分子服消息通信分组
 # 只有在同一个频道名的子服才能互相通信

ball-velocity/src/main/resources/update.yml

@@ -1,6 +1,5 @@
-version: ${version}
+VERSION: ${version}
 CHECK_TYPE: GITEA_RELEASES
 GIT_BASE_URL: https://git.airgame.net
 GIT_REPO: MiniDay/hamster-ball
-GIT_TOKEN: a44a69a4d1b8601bf6091403247759cd28764d5e
 DOWNLOAD_URL: https://jenkins.airgame.net/job/opensource/job/hamster-ball/

build.gradle.kts

@@ -5,7 +5,8 @@ plugins {
 }
 
 group = "cn.hamster3.mc.plugin"
-version = "1.6.2"
+version = "1.6.5-SNAPSHOT"
+description = "基于 Redis 的 Minecraft 服务端通用消息中间件"
 
 subprojects {
     apply {
@@ -16,6 +17,7 @@ subprojects {
 
     group = rootProject.group
     version = rootProject.version
+    description = rootProject.description
 
     repositories {
         maven("https://maven.airgame.net/maven-public/")
@@ -43,11 +45,6 @@ subprojects {
             from(rootProject.file("LICENSE"))
             duplicatesStrategy = DuplicatesStrategy.EXCLUDE
         }
-        processResources {
-            filesMatching("update.yml") {
-                expand(rootProject.properties)
-            }
-        }
         build {
             dependsOn(shadowJar)
         }