build: 更改版本号

Reviewed-on: #4

README.md

@@ -49,9 +49,9 @@ repositories {
 
 dependencies {
     // 对于 Bukkit 插件
-    compileOnly("cn.hamster3.mc.plugin:ball-bukkit:1.6.3-SNAPSHOT")
+    compileOnly("cn.hamster3.mc.plugin:ball-bukkit:1.6.3")
     // 对于 BungeeCord 插件
-    compileOnly("cn.hamster3.mc.plugin:ball-bungee:1.6.3-SNAPSHOT")
+    compileOnly("cn.hamster3.mc.plugin:ball-bungee:1.6.3")
 }
 ```
 
@@ -77,13 +77,13 @@ dependencies {
         <dependency>
             <groupId>cn.hamster3.mc.plugin</groupId>
             <artifactId>ball-bukkit</artifactId>
-            <version>1.6.3-SNAPSHOT</version>
+            <version>1.6.3</version>
         </dependency>
         <!--对于 BungeeCord 插件-->
         <dependency>
             <groupId>cn.hamster3.mc.plugin</groupId>
             <artifactId>ball-bungee</artifactId>
-            <version>1.6.3-SNAPSHOT</version>
+            <version>1.6.3</version>
         </dependency>
     </dependencies>
 </project>

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

@@ -105,7 +105,6 @@ public abstract class BallAPI {
     }
 
     protected void enable() throws SQLException, InterruptedException {
-        CoreAPI.getInstance().getExecutorService().submit(() -> redisSub.subscribe(BallRedisListener.INSTANCE, BALL_CHANNEL));
         try (Jedis jedis = CoreAPI.getInstance().getJedisPool().getResource()) {
             String key = "HamsterBall:ServerInfo:" + localServerInfo.getId();
             if (jedis.exists(key)) {
@@ -180,6 +179,7 @@ public abstract class BallAPI {
         }
         getLogger().info("从数据库中加载了 " + allServerInfo.size() + " 条服务器信息");
         getLogger().info("从数据库中加载了 " + allPlayerInfo.size() + " 条玩家信息");
+        subscribeRaw(BALL_CHANNEL);
     }
 
     protected void disable() throws SQLException, InterruptedException {
@@ -521,14 +521,13 @@ public abstract class BallAPI {
      * @param channels 频道名称
      */
     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();
-//            }
-//        });
+        CoreAPI.getInstance().getExecutorService().submit(() -> {
+            try {
+                redisSub.subscribe(BallRedisListener.INSTANCE, channels);
+            } catch (Exception | Error e) {
+                e.printStackTrace();
+            }
+        });
     }
 
     /**
@@ -537,10 +536,9 @@ public abstract class BallAPI {
      * @param patterns 频道名称正则表达式
      */
     public void subscribePatterns(@NotNull String patterns) {
-        BallRedisListener.INSTANCE.psubscribe(patterns);
-//        CoreAPI.getInstance().getExecutorService().submit(
-//                () -> redisSub.psubscribe(BallRedisListener.INSTANCE, patterns)
-//        );
+        CoreAPI.getInstance().getExecutorService().submit(
+                () -> redisSub.psubscribe(BallRedisListener.INSTANCE, patterns)
+        );
     }
 
     /**
@@ -548,22 +546,22 @@ public abstract class BallAPI {
      * <p>
      * 会自动加上 config 中设置的频道前缀
      *
-     * @param channels 频道名称
+     * @param channel 频道名称
      */
-    public void unsubscribe(@NotNull String... channels) {
-        for (int i = 0; i < channels.length; i++) {
-            channels[i] = ballConfig.getChannelPrefix() + channels[i];
+    public void unsubscribe(@NotNull String... channel) {
+        for (int i = 0; i < channel.length; i++) {
+            channel[i] = ballConfig.getChannelPrefix() + channel[i];
         }
-        unsubscribeRaw(channels);
+        BallRedisListener.INSTANCE.unsubscribe(channel);
     }
 
     /**
      * 忽略频道前缀配置，取消订阅 redis 消息频道
      *
-     * @param channels 频道名称
+     * @param channel 频道名称
      */
-    public void unsubscribeRaw(@NotNull String... channels) {
-        BallRedisListener.INSTANCE.unsubscribe(channels);
+    public void unsubscribeIgnorePrefix(@NotNull String... channel) {
+        BallRedisListener.INSTANCE.unsubscribe(channel);
     }
 
     /**

build.gradle.kts

@@ -5,7 +5,7 @@ plugins {
 }
 
 group = "cn.hamster3.mc.plugin"
-version = "1.6.3-SNAPSHOT"
+version = "1.6.3"
 description = "基于 Redis 的 Minecraft 服务端通用消息中间件"
 
 subprojects {