多服务器同时连接同一Mirai支持,好耶

MakesYT · May 20, 2023 · 21bb92f · 21bb92f
1 parent 135f955
commit 21bb92f
Show file tree

Hide file tree

Showing 3 changed files with 14 additions and 4 deletions.
diff --git a/pom.xml b/pom.xml
@@ -16,7 +16,7 @@
     </repositories>
     <groupId>top.ncserver</groupId>
     <artifactId>chatsync_bukkit</artifactId>
-    <version>2.3.6</version>
+    <version>2.4.0</version>
 
     <properties>
         <maven.compiler.source>8</maven.compiler.source>

diff --git a/src/main/java/top/ncserver/chatsync/Client.java b/src/main/java/top/ncserver/chatsync/Client.java
@@ -1,6 +1,7 @@
 package top.ncserver.chatsync;
 
 
+import com.alibaba.fastjson.JSONObject;
 import org.bukkit.entity.Player;
 import org.bukkit.scheduler.BukkitRunnable;
 import org.smartboot.socket.StateMachineEnum;
@@ -11,6 +12,8 @@
 import top.ncserver.chatsync.V2.Until.MsgTool;
 
 import java.io.IOException;
+import java.util.HashMap;
+import java.util.Map;
 import java.util.logging.Logger;
 
 
@@ -37,15 +40,20 @@ public void process0(AioSession aioSession, String msg) {
                 }
                 @Override
                 public void stateEvent0(AioSession session, StateMachineEnum stateMachineEnum, Throwable throwable) {
-                    if (stateMachineEnum.equals(StateMachineEnum.NEW_SESSION)){
-                        isConnected=true;
+                    if (stateMachineEnum.equals(StateMachineEnum.NEW_SESSION)) {
+                        isConnected = true;
                         logger.info("连接成功");
                         if (Chatsync.config.getBoolean("NotifyPlayerChatsyncState")) {
                             Object[] players = Chatsync.getPlugin(Chatsync.class).getServer().getOnlinePlayers().toArray();
                             for (Object player : players) {
                                 ((Player) player).getPlayer().sendMessage("消息同步连接成功");
                             }
                         }
+                        Map<String, Object> msg1 = new HashMap<>();
+                        msg1.put("type", "init");
+                        msg1.put("name", Chatsync.config.getString("ServerName"));
+                        JSONObject jo = new JSONObject(msg1);
+                        MsgTool.msgSend(session, jo.toJSONString());
                     }else if (stateMachineEnum.equals(StateMachineEnum.SESSION_CLOSED)){
                         logger.warning("连接丢失");
                         if (Chatsync.config.getBoolean("NotifyPlayerChatsyncState")) {

diff --git a/src/main/resources/config.yml b/src/main/resources/config.yml
@@ -1,9 +1,11 @@
 # 配置文件版本号 请勿更改
-ver: 4
+ver: 5
 # mirai的ip
 ip: "127.0.0.1"
 # mirai的端口号
 port: 1111
+# 服务器名字
+ServerName: "Test Server"
 UnconditionalAutoSync: true
 AutoSyncPrefix: "#"
 # 客户端聊天栏是否显示连接成功